"milind.uc" wrote : yes ,, hay thanks for ur reply as I get confidence from your
reply because before reading your reply I did the things which you mentioned but the
thing is that only the getQueueDepth is working which is nothing but the tolal number fo
the messages in the queue..Other attributes like the
getSchedulemessagecount(),getReceiversCount() are giving the values zero ..Still writing
this reply I used all thses things only on the receivers side.. I did in the foloowing
way while sending the messages and still not on the receivers side...
|
|
| | MBeanServerConnection mbean_server = null;
| | ObjectName dm = null;
| | try{
| |
| |
| | mbean_server =(MBeanServerConnection)
ctx.lookup("jmx/rmi/RMIAdaptor");
| | dm = new ObjectName("jboss.mq:service=DestinationManager");
| |
| | String domain = "jboss.mq.destination";
| | String service = "service=Queue";
| | String name = "name=queue/C";
| |
| | String stringObjectName = domain + ":" + service + "," +
name;
| |
| |
| |
| |
| | ObjectName queueObjectName = ObjectName.getInstance(stringObjectName);
| |
| | org.jboss.mq.server.jmx.QueueMBean queueMBean =
| | (org.jboss.mq.server.jmx.QueueMBean)
MBeanServerInvocationHandler.newProxyInstance(
| | mbean_server,
| | queueObjectName,
| | org.jboss.mq.server.jmx.QueueMBean.class,
| | false
| | );
| | System.out.println("queue depth is :" +
queueMBean.getQueueDepth());
| | System.out.println("getScheduledMessageCount count is :" +
queueMBean.getScheduledMessageCount());
| | System.out.println("History Limit
:"+queueMBean.getMessageCounterHistoryDayLimit());
| | System.out.println("MAximmum depth :"+ queueMBean.getMaxDepth());
| | System.out.println("Receiver Count is :"
+queueMBean.getReceiversCount());
| | System.out.println("Redelivery
Limit:"+queueMBean.getRedeliveryLimit());
| | System.out.println("Name is :"+queueMBean.getName());
| | System.out.println("queue name is :"+queueMBean.getQueueName());
| |
| |
| |
|
| Again if I did the org.jboss.mq.server MessageCounter meas []=
queueMBean.getMessageCounter(); then I got the exception as===
| java.lang.reflect.UndeclaredThrowableException
| at $Proxy1.getMessageCounter(Unknown Source)
| at Statstic.Sender_Count.main(Sender_Count.java:220)
| Caused by: java.io.NotSerializableException: org.jboss.mq.server.MessageCounter
| at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1054)
| at java.io.ObjectOutputStream.writeArray(ObjectOutputStream.java:1224)
| .....
|
| Beside the total count of the messages in the queue I also needed how many messages
are scheduled(Recived by reciver ) ,pending.If u have idea then please suggest and guide
me.
|
| Thanks for all your help it is pleasurable :)
|
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4031958#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...