|
ActiveMQ supports advisory messages which allows you to watch the system using regular JMS messages. Currently we have advisory messages that support
Advisory messages can be thought as some kind of administrative channel where you receive information regarding what is happening on your JMS provider along with whats happening with producers, consumers and destinations. When you look at a broker via JMX you will see the advisory topics prefixed with ActiveMQ.Advisory.. The following advisory topics are supported Client based advisories
Note that the consumer start/stop advisory messages also have a consumerCount header to indicate the number of active consumers on the destintation when the advisory message was sent. This means you can use the following selector to be notified when there are no active consumers on a given destination... consumerCount = 0 Destination and Message based advisories
Using the destinationsAll of the above destinations are really prefixes which are appended with important information (like the actual topic or queue, the client ID, producer ID, consumer ID etc). This allows you to reuse the power of publish/subscribe, Wildcards and Selectors to filter the advisory messages as you see fit. For example if you want to subscribe to expired messages on a topic FOO.BAR you could subscribe to ActiveMQ.Advisory.Expired.Topic.FOO.BAR. To subscribe to all messages of a certain kind of advisory just append .> to the topic. e.g. to subscribe to all the consumers starting and stopping to topics and queues subscribe to ActiveMQ.Advisory.Consumer..>. Helper methodsMethods to get the advisory destination objects are available in AdvisorySupport AdvisorySupport.getConsumerAdvisoryTopic() AdvisorySupport.getProducerAdvisoryTopic() AdvisorySupport.getExpiredTopicMessageAdvisoryTopic() AdvisorySupport.getExpiredQueueMessageAdvisoryTopic() AdvisorySupport.getNoTopicConsumersAdvisoryTopic() AdvisorySupport.getNoQueueConsumersAdvisoryTopic() AdvisorySupport.getDestinationAdvisoryTopic() A subscription to each of the destination returns an ActiveMQMessage. Specific DataStructure objects (ie. ConsumerInfo, ProducerInfo,ConnectionInfo) can be retrieve via getDataStructure method of ActiveMQMessage. For example: ...
Destination advisoryDestination = AdvisorySupport.getProducerAdvisoryTopic(destination)
MessageConsumer consumer = session.createConsumer(advisoryDestination);
consumer.setMessageListener(this);
....
public void onMessage(Message msg){
if (msg instanceof ActiveMQMessage){
try {
ActiveMQMessage aMsg = (ActiveMQMessage)msg;
ProducerInfo prod = (ProducerInfo) aMsg.getDataStructure();
} catch (JMSException e) {
log.error("Failed to process message: " + msg);
}
}
}
Some helper classes to deal with advisory messages are available in the advisories For users of previous releases see the Advisory Support in ActiveMQ 3 |
OverviewSearchSub ProjectsCommunity
Features
Connectivity
Using ActiveMQ 5
Using ActiveMQ 4
ToolsSupportRelated ProjectsDevelopersTests
Project Reports |