JavaプログラミングによるActiveMQを使用してキューメッセージの有効期限を設定する方法を教えてください。

Question

このコードでは、パブリッシャ側からのキューに1秒の有効期限切れのメッセージに対してsetJMSExpiration（1000）を使用しています。しかし、Consumer Sideからは、nullではなく1秒後に適切にメッセージが返されます。

 public class RegistrationPublisher extends Thread{ 
      public void run() { 
       publisherQueue("Registration.Main.*"); 
      } 

      public void publisherQueue(String server){ 
       try { 
        String url="tcp://192.168.20.49:61616"; 
        // Create a ConnectionFactory 
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url); 

        Connection connection = connectionFactory.createConnection(); 
        connection.start(); 

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 

        Destination destination = session.createQueue(server); 

        MessageProducer producer = session.createProducer(destination); 
        producer.setDeliveryMode(DeliveryMode.PERSISTENT); 

        String text = "Test"; 
        TextMessage message = session.createTextMessage(text); 

        message.setJMSExpiration(1000);// For Expire message in one second 


     producer.send(message); 


        producer.close(); 
        session.close(); 
        connection.close(); 

       } 
       catch (Exception e) { 
        e.printStackTrace(); 
       } 
      } 

      public static void main(String args[]) throws IOException{ 

       RegistrationPublisher registrationPublisher=new RegistrationPublisher(); 
       registrationPublisher.start(); 
      } 
     } 

Answer 1

あなたはTTLを受け入れるか、すべての送信されたメッセージに同じTTLを追加プロデューサーににsetTimeToLiveを呼び出すことにより、sendメソッドを経由してあなたのためにそれを行うにはJMSのMessageProducerを構成することによって、これを行います。メッセージバージョンのJMS APIは、メッセージでセッターを呼び出すことは効果がないことは明らかです。

ボイドsetJMSExpiration（長い有効期限）JMSExceptionを

は、メッセージの有効期限の値を設定しますスローされます。

このメソッドは、JMSプロバイダがメッセージの送信時にのみこのフィールドを設定するために使用します。このメッセージは、クライアントがメッセージの有効期限を設定するために使用することはできません。実装が独自のものではないメッセージを送信するときにJMSプロバイダがこのフィールドを設定できるようにするには、このメソッドはpublicです。