Spring JMSプロデューサとコンシューマとのやりとり

Question

コンシューマがプロデューサからメッセージをすでに受信しているかどうか、またはプロデューサにSpring JMSでメッセージがすでに送信/消費されたことをプロデューサに通知する方法を教えてください。

Answer 1

プロデューサ側でorg.springframework.jms.core.JmsTemplate.sendAndReceive(...)を使用して要求/応答を使用する必要があり、コンシューマ側では、コンテナに設定されたMessageListenerメソッドが値を返す必要があります。

やあなたのプロデューサーは、メッセージがorignalMessageIdのようないくつかのプロパティにアクセスすることによって消費されたときに通知されるようにActiveMQ.Advisory.MessageConsumed.Queueに加入させる、ここでhttp://activemq.apache.org/advisory-message.html

を見て、あなたはこのようにそれを使用することができます：

  Destination advisoryDestination = org.apache.activemq.advisory.AdvisorySupport 
        .getMessageConsumedAdvisoryTopic(session.createQueue("yourQueue")); 
      MessageConsumer consumer = session.createConsumer(advisoryDestination); 
      consumer.setMessageListener(new MessageListener() { 
       @Override 
       public void onMessage(Message msg) { 
        System.out.println(msg); 
        System.out.println(((ActiveMQMessage) msg).getMessageId()); 
        ActiveMQMessage aMsg = (ActiveMQMessage) ((ActiveMQMessage) msg).getDataStructure(); 
        System.out.println(aMsg.getMessageId()); 
       } 
      });