Get number of messages on a queue 1

[jbabad]

Hi,

Does anyone know how to get the number
of messages on a queue?
There are some utility program that SeeBeyond
provide, but I'm looking to it with some sort
of API from within a Java program.
I don't really want to have to exec a program
from within my Java code.

Cheers.

 

[Guest_imported]

I believe the e*Gate monitor has an iq manager that allows you to view the # of messages and the contents of the messages. Its part of the e*Gate Monitor GUI.

 

[rdsojer]

hi,

you can de-compile the stcqviewer class (you see that seebeyond uses the topic STCMS.Control to retrieve the number of messages from a specific queue manager).
Now, you should be able to implement your own QueueBrowser (which is missing in the stc api).

regards,

reinhold

here comes an example ...

private void init() throws JMSException {
Properties properties = new Properties();
properties.put("com.seebeyond.jms.sockets.RetryCount", "0"
properties.put("com.seebeyond.jms.sockets.RetryInterval", "0"

topicConnectionFactory = new STCTopicConnectionFactory(properties);

((STCTopicConnectionFactory)topicConnectionFactory).setHost(getHost());
((STCTopicConnectionFactory)topicConnectionFactory).setPort(getPort());

topicConnection = topicConnectionFactory.createTopicConnection();
topicConnection.start();

topicSession = topicConnection.createTopicSession(false, 2);
Topic controlTopic = topicSession.createTopic("STCMS.Control"
topicPublisher = topicSession.createPublisher(controlTopic);
topicPublisher.setDeliveryMode(1);
TemporaryTopic tempReplyTopic = topicSession.createTemporaryTopic();
topicSubscriber = topicSession.createSubscriber(tempReplyTopic);
message = topicSession.createMessage();
message.setJMSReplyTo(tempReplyTopic);
message.setJMSDeliveryMode(1);
}

public void update() throws JMSException {
message.setIntProperty("Message.Type", 9); // get topic statistics
message.setStringProperty("QueueManager.TopicName", getTopicName());
topicPublisher.publish(message);
replyMessage = topicSubscriber.receive(5000L);

if(replyMessage == null) {
/** throw exception */
return ;
}
if(!replyMessage.getBooleanProperty("Success.Code&quot) {
/** throw exception */
return ;
} else {
// replyMessage.getStringProperty("TopicStats.TopicName"
setFirstSequence(replyMessage.getLongProperty("TopicStats.FirstSequence&quot);
setLastSequence(replyMessage.getLongProperty("TopicStats.LastSequence&quot);
setLowestSubscriberSequence(replyMessage.getLongProperty("TopicStats.LowestSubcriberSequence&quot); // possibly change this to ...Subscriber...
setHighestSubscriberSequence(replyMessage.getLongProperty("TopicStats.HighestSubscriberSequence&quot);
setFirstEnqueue(replyMessage.getLongProperty("TopicStats.FirstEnqueue&quot);
setLastEnqueue(replyMessage.getLongProperty("TopicStats.LastEnqueue&quot);
setTotalSubscribers(replyMessage.getLongProperty("TopicStats.TotalSubscribers&quot);
setCurrentSubscribers(replyMessage.getLongProperty("TopicStats.CurrentSubscribers&quot);
setMessageCount(replyMessage.getLongProperty("TopicStats.MessageCount&quot);
}
}

 

[jbabad]

Hi,

Thanks, that was useful.

Cheers,
Joseph.