なぜ消費者がActiveMQ Temp Queue用に作成されないのですか？

Question

SimpleMessageListenerContainerオプションを除くと、コンシューマは一時キュー用に作成されません。私は次のコードhere.

に直面していましたが

     using (IConnection connection = connectionFactory.CreateConnection()) 
        using (ISession session = connection.CreateSession()) 
        { 
         IDestination destination = SessionUtil.GetDestination(session, aQueueName); 
         var replyDestination = session.CreateTemporaryQueue(); 

         // Create a consumer and producer 
         using (IMessageProducer producer = session.CreateProducer(destination)) 
         { 
          // Start the connection so that messages will be processed. 
          connection.Start(); 

          IBytesMessage request = session.CreateBytesMessage(aMsg); 
          request.NMSReplyTo = replyDestination; 

          IMessageConsumer consumer = session.CreateConsumer(replyDestination); 
          consumer.Listener += new MessageListener(this.OnAckRecieved); 

          // Send a message 
          producer.Send(request); 
          ack = this.autoEvent.WaitOne(this.msgConsumeTimeOut, true); 

          consumer.Close(); 
          consumer.Dispose(); 
          ConnectionFactoryUtils.GetTargetSession(session).DeleteDestination(replyDestination); 
         } 
         connection.Close(); 
         session.Close(); 

（でも一時キューが作成されません）...ワーキングコードをFlollowingされていないいくつかの問題のためにSimpleMessageListenerContainerを使用することはありません が働いている：キューがいるようだ - ブタそれは永続的なキューを作成working.butある（NmsDestinationAccessorの使用）上記のコードで永続キューない一時キュー

     using (IConnection connection = connectionFactory.CreateConnection()) 
        using (ISession session = connection.CreateSession()) 
        { 
         IDestination destination = SessionUtil.GetDestination(session, aQueueName); 
         var replyDestination = session.CreateTemporaryQueue(); 

         // Create a consumer and producer 
         using (IMessageProducer producer = session.CreateProducer(destination)) 
         { 
          // Start the connection so that messages will be processed. 
          connection.Start(); 

          IBytesMessage request = session.CreateBytesMessage(aMsg); 
          request.NMSReplyTo = replyDestination; 

          IDestination tempDestination = this.destinationResolver.ResolveDestinationName(session, request.NMSReplyTo.ToString()); 
          IMessageConsumer consumer = session.CreateConsumer(tempDestination); 
          consumer.Listener += new MessageListener(this.OnAckRecieved); 

          // Send a message 
          producer.Send(request); 
          ack = this.autoEvent.WaitOne(this.msgConsumeTimeOut, true); 

          consumer.Close(); 
          consumer.Dispose(); 
          ConnectionFactoryUtils.GetTargetSession(session).DeleteDestination(tempDestination); 
         } 
         connection.Close(); 
         session.Close(); 

です。だから、私は一時的なキューの返信先を直接使用して、それは動作していません。

Answer 1

1. C＃を使用するのではなく、Javaでコードを記述してください。これはActiveMQのベストスイートです。 here for examples using temp queue in java.
2. を読み、その後、JARファイルにそれをコンパイルして、あなたが
3. hereが、それはこの協力をお願いし説明したようIKVM.NETを経由してあなたのC＃コードでそれをインポートすることができます。

注意：異なるセッションでテモゾルキューを使用することはできません。

Answer 2

メソッドから直接ActiveMQTempQueueオブジェクトを作成すると、ToStringメソッドは、一致する宛先を作成できる値を返すことが保証されていない可能性があります。送信者が一時的な送信先を指定したのか、通常の送信先を指定したのかがわからないので、悪いコーディングも同様です。正しいことは、単にNSMReplyTo宛先をそのまま使用して、セッションのコンシューマー作成メソッドを使用して新しいコンシューマーを作成することです。

ここには、Apache.NMS.StompとApache.NMS.ActiveMQで動作するNMSプロジェクトの簡単なリクエスト応答テストケースがあります。

namespace Apache.NMS.Test 
{ 
[TestFixture] 
public class RequestResponseTest : NMSTestSupport 
{ 
    protected static string DESTINATION_NAME = "RequestDestination"; 

    [Test] 
    [Category("RequestResponse")]  
    public void TestRequestResponseMessaging() 
    { 
     using(IConnection connection = CreateConnection()) 
     { 
      connection.Start(); 
      using(ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge)) 
      { 
       IDestination destination = SessionUtil.GetDestination(session, DESTINATION_NAME); 
       ITemporaryQueue replyTo = session.CreateTemporaryQueue(); 

       using(IMessageConsumer consumer = session.CreateConsumer(destination)) 
       using(IMessageProducer producer = session.CreateProducer(destination)) 
       { 
        IMessage request = session.CreateMessage(); 

        request.NMSReplyTo = replyTo; 

        producer.Send(request); 

        request = consumer.Receive(TimeSpan.FromMilliseconds(3000)); 
        Assert.IsNotNull(request); 
        Assert.IsNotNull(request.NMSReplyTo); 

        using(IMessageProducer responder = session.CreateProducer(request.NMSReplyTo)) 
        { 
         IMessage response = session.CreateTextMessage("RESPONSE");       
         responder.Send(response); 
        }      
       } 

       using(IMessageConsumer consumer = session.CreateConsumer(replyTo)) 
       { 
        ITextMessage response = consumer.Receive(TimeSpan.FromMilliseconds(3000)) as ITextMessage; 
        Assert.IsNotNull(response); 
        Assert.AreEqual("RESPONSE", response.Text); 
       } 
      } 
     } 
    } 
} 

Answer 3

一時的なキューは、それを作成した接続が存在する間のみ存在します。あなたのサンプルコードでは、接続を開始する前にそれを作成しているので、アクティブな接続がないので、静かにエラーを出力すると思います。