I have finally manage to make it work.
Added following to my context file.
<bean id="brokerQuery" class="org.apache.activemq.web.LocalBrokerFacade"
autowire="constructor" scope="prototype"/>
Then READ: Collection<QueueViewMBean> queues = brokerQuery.getQueues();
for (QueueViewMBean queueViewMBean : queues) {
@SuppressWarnings("unchecked")
List<Message> browseMessages = (List<Message>)
queueViewMBean.browseMessages();
}
For Remove:
Collection<QueueViewMBean> queues = brokerQuery.getQueues();
for (QueueViewMBean queueViewMBean : queues) {
boolean isMessageRemoved =
queueViewMBean.removeMessage(messageID);
if (isMessageRemoved) {
log.info("Message removed from queue. Message Id: " +
messageID);
break;
}
}
It works amazingly. Thanks for all suggestions and help.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Can-not-remove-message-from-Queue-tp4697351p4697651.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
