I need to be able to receive notification when a ActiveMQ client consumes a
MQTT message.  I tried to first post on stackoverflow but haven't got a
reponse yet. 
*See:* 
http://stackoverflow.com/questions/31079067/issues-getting-activemq-advisory-messages-for-messageconsumed
<http://stackoverflow.com/questions/31079067/issues-getting-activemq-advisory-messages-for-messageconsumed>
  

*activemq.xml*

<destinationPolicy>
    <policyMap>
      <policyEntries>
            <policyEntry topic=">" advisoryForConsumed="true" />
      </policyEntries>
    </policyMap>
</destinationPolicy>
In the below code, I get MQTT messages on myTopic fine. I do not get
advisory messages in processAdvisoryMessage / processAdvisoryBytesMessage.

@Component
public class MqttMessageListener {
    @JmsListener(destination = "mytopic")
    public void processMessage(BytesMessage message) {
    }

    @JmsListener(destination = "ActiveMQ.Advisory.MessageConsumed.Topic.>")
    public void processAdvisoryMessage(Message message) {
        System.out.println("processAdvisoryMessage Got a message");
    }
}

*What am I doing wrong?*



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Need-help-with-subscribing-to-MessageConsumed-advisory-tp4698366.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Reply via email to