作成者のActiveMQパージ・エンキュー・メッセージ

Question

私はJAVAアプリケーションを持っています。作成コンシューマですべてのエンキュー・メッセージをパージする必要があります。私はエンキューされたメッセージを削除してから処理されてからキューに入れられたメッセージを防ぐために、消費者を作成するにはどうすればよい

ActiveMQConnectionFactory connectionFactory = new   ActiveMQConnectionFactory(messageBrokerUrl); 
    try { 
     connection = connectionFactory.createConnection(); 
     connection.start(); 
     this.session = connection.createSession(this.transacted, ackMode); 
     Destination adminQueue = this.session.createQueue(messageQueueName); 

     this.replyProducer = this.session.createProducer(null); 
     this.replyProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); 
     //Set up a consumer to consume messages off of the admin queue 
     MessageConsumer consumer = this.session.createConsumer(adminQueue); 
     consumer.setMessageListener(this); 
    } catch (JMSException e) { 
     log.error("Error al configurar servicio de colas MQ. " + e.getMessage()); 
    } 

：

は、私は次のコードを持っています。

Answer 1

JMS APIには宛先をパージするためのメソッドが定義されていないため、JMS APIを単独で使用することはできません。宛先にコンシューマを作成し、consumer.receive(1000)または類似。

ActiveMQオブジェクトを直接使用しても構わない場合は、ActiveMQConnectionでdestroyDestinationメソッドを使用してみてください。このメソッドは、ブローカから宛先を削除しますIFその宛先にアクティブなサブスクライバが存在しません。

それ以外の場合は、ActiveMQブローカによって公開されたJMX APIを使用して、目的の宛先を実際にパージします。