You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by oscarfh2 <os...@gmail.com> on 2011/01/19 12:30:56 UTC
Get the number of pending messages programatically
Hi,
I am developing a tool which gather information about queues in a server.
One of these informations is how many pending messages.
My approach now is to open a browser and iterate through all the messages,
it works, but it is not good:
1-it is slow
2-each "next message" will make a network call, that makes it unacceptable
Is there any other way to get this number? It would be perfect to have
something like this:
queue.getPendingMessageNumber()
But I couldn't find... Any ideas of how I could do that?
The server has this information, because I can see it in the server console.
The question is: how can I reach it?
Tks,
Oscar
--
View this message in context: http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3225127.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
Re: Get the number of pending messages programatically
Posted by Norman Maurer <no...@apache.org>.
You could also access this information via JMX, but I think the plugin
is the "easier" way ..
Bye,
Norman
2011/1/19 oscarfh2 <os...@gmail.com>:
>
> That is great, I will take a look at the plugin and ask about the possibility
> of installing it on the servers.
>
> Would be any way of doing without the plugin?
>
> Tks,
> Oscar
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3225171.html
> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
>
Re: Get the number of pending messages programatically
Posted by oscarfh2 <os...@gmail.com>.
Ok, thanks!
A higher priority problem just came up, so I will have to stop working on
this issue for some time, but thanks a lot for your help!
Oscar
2011/1/20 Norman Maurer-3 [via ActiveMQ] <
ml-node+3225605-1219858116-208859@n4.nabble.com<ml...@n4.nabble.com>
>
> I just had a quick look at our activemq broker and the ObjectName should
> be:
>
> org.apache.activemq:BrokerName=$YOURBROKERNAME,Type=Queue,Destination=$QUEUENAME
>
>
>
> Bye,
> Norman
>
> 2011/1/19 oscarfh2 <[hidden email]<http://user/SendEmail.jtp?type=node&node=3225605&i=0>>:
>
>
> >
> > Yes, this link I had, but it doesn't help me much regarding how to invoke
> the
> > operations using java code.
> > But this name you gave (QueueViewMBean) can help me a lot. I will do some
>
> > research.
> >
> > thanks a lot for your help, your really helped a lot!
> > Oscar
> > --
> > View this message in context:
> http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3225408.html<http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3225408.html?by-user=t>
>
> > Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
> >
>
>
> ------------------------------
> If you reply to this email, your message will be added to the discussion
> below:
>
> http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3225605.html
> To unsubscribe from Get the number of pending messages programatically, click
> here<http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=3225127&code=b3NjYXJmaEBnbWFpbC5jb218MzIyNTEyN3wxMDUyOTk1NzA1>.
>
>
--
View this message in context: http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3233492.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
Re: Get the number of pending messages programatically
Posted by Norman Maurer <no...@apache.org>.
I just had a quick look at our activemq broker and the ObjectName should be:
org.apache.activemq:BrokerName=$YOURBROKERNAME,Type=Queue,Destination=$QUEUENAME
Bye,
Norman
2011/1/19 oscarfh2 <os...@gmail.com>:
>
> Yes, this link I had, but it doesn't help me much regarding how to invoke the
> operations using java code.
> But this name you gave (QueueViewMBean) can help me a lot. I will do some
> research.
>
> thanks a lot for your help, your really helped a lot!
> Oscar
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3225408.html
> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
>
Re: Get the number of pending messages programatically
Posted by oscarfh2 <os...@gmail.com>.
Yes, this link I had, but it doesn't help me much regarding how to invoke the
operations using java code.
But this name you gave (QueueViewMBean) can help me a lot. I will do some
research.
thanks a lot for your help, your really helped a lot!
Oscar
--
View this message in context: http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3225408.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
Re: Get the number of pending messages programatically
Posted by Norman Maurer <no...@apache.org>.
I think you want to access the QueueViewMBean.
See http://activemq.apache.org/jmx.html
Bye,
Norman
2011/1/19 oscarfh2 <os...@gmail.com>:
>
> I talked with my project manager and we are going to use the JMX approach to
> follow some standards we already have in the project.
> I am able to connect, but I am having problems to call operations.
>
> I have this code:
>
> // Get MBean server connection
> ObjectName destMgrConfigName = new
> ObjectName(MQObjectName.DESTINATION_MANAGER_MONITOR_MBEAN_NAME);
>
> // Create operation's parameter and signature arrays
> Object opParams[] = {};
> String opSig[] = {};
>
> // Invoke operation
> ObjectName[] objectNames;
> objectNames = (ObjectName[]) connection.invoke(destMgrConfigName,
> DestinationOperations.GET_DESTINATIONS, opParams, opSig);
>
> and get this exception in the last line:
>
> javax.management.InstanceNotFoundException:
> com.sun.messaging.jms.server:type=DestinationManager,subtype=Monitor
> at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getMBean(DefaultMBeanServerInterceptor.java:1094)
> at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getClassLoaderFor(DefaultMBeanServerInterceptor.java:1438)
> at
> com.sun.jmx.mbeanserver.JmxMBeanServer.getClassLoaderFor(JmxMBeanServer.java:1276)
> at
> javax.management.remote.rmi.RMIConnectionImpl$5.run(RMIConnectionImpl.java:1326)
> at java.security.AccessController.doPrivileged(Native Method)
> at
> javax.management.remote.rmi.RMIConnectionImpl.getClassLoaderFor(RMIConnectionImpl.java:1323)
> at
> javax.management.remote.rmi.RMIConnectionImpl.invoke(RMIConnectionImpl.java:771)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:305)
> at sun.rmi.transport.Transport$1.run(Transport.java:159)
> at java.security.AccessController.doPrivileged(Native Method)
> at sun.rmi.transport.Transport.serviceCall(Transport.java:155)
> at sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:535)
> at
> sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:790)
> at
> sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:649)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
> at sun.rmi.transport.StreamRemoteCall.exceptionReceivedFromServer(Unknown
> Source)
> at sun.rmi.transport.StreamRemoteCall.executeCall(Unknown Source)
> at sun.rmi.server.UnicastRef.invoke(Unknown Source)
> at com.sun.jmx.remote.internal.PRef.invoke(Unknown Source)
> at javax.management.remote.rmi.RMIConnectionImpl_Stub.invoke(Unknown
> Source)
> at
> javax.management.remote.rmi.RMIConnector$RemoteMBeanServerConnection.invoke(Unknown
> Source)
> at
> ActiveMQJMXConnectionTest.getMsgNumber(ActiveMQJMXConnectionTest.java:43)
> at ActiveMQJMXConnectionTest.main(ActiveMQJMXConnectionTest.java:24)
>
>
> This makes me think it is completely wrong.
> Would you know an useful link to help me?
>
> tks,
> Oscar
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3225364.html
> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
>
Re: Get the number of pending messages programatically
Posted by oscarfh2 <os...@gmail.com>.
I talked with my project manager and we are going to use the JMX approach to
follow some standards we already have in the project.
I am able to connect, but I am having problems to call operations.
I have this code:
// Get MBean server connection
ObjectName destMgrConfigName = new
ObjectName(MQObjectName.DESTINATION_MANAGER_MONITOR_MBEAN_NAME);
// Create operation's parameter and signature arrays
Object opParams[] = {};
String opSig[] = {};
// Invoke operation
ObjectName[] objectNames;
objectNames = (ObjectName[]) connection.invoke(destMgrConfigName,
DestinationOperations.GET_DESTINATIONS, opParams, opSig);
and get this exception in the last line:
javax.management.InstanceNotFoundException:
com.sun.messaging.jms.server:type=DestinationManager,subtype=Monitor
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getMBean(DefaultMBeanServerInterceptor.java:1094)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getClassLoaderFor(DefaultMBeanServerInterceptor.java:1438)
at
com.sun.jmx.mbeanserver.JmxMBeanServer.getClassLoaderFor(JmxMBeanServer.java:1276)
at
javax.management.remote.rmi.RMIConnectionImpl$5.run(RMIConnectionImpl.java:1326)
at java.security.AccessController.doPrivileged(Native Method)
at
javax.management.remote.rmi.RMIConnectionImpl.getClassLoaderFor(RMIConnectionImpl.java:1323)
at
javax.management.remote.rmi.RMIConnectionImpl.invoke(RMIConnectionImpl.java:771)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:305)
at sun.rmi.transport.Transport$1.run(Transport.java:159)
at java.security.AccessController.doPrivileged(Native Method)
at sun.rmi.transport.Transport.serviceCall(Transport.java:155)
at sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:535)
at
sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:790)
at
sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:649)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
at sun.rmi.transport.StreamRemoteCall.exceptionReceivedFromServer(Unknown
Source)
at sun.rmi.transport.StreamRemoteCall.executeCall(Unknown Source)
at sun.rmi.server.UnicastRef.invoke(Unknown Source)
at com.sun.jmx.remote.internal.PRef.invoke(Unknown Source)
at javax.management.remote.rmi.RMIConnectionImpl_Stub.invoke(Unknown
Source)
at
javax.management.remote.rmi.RMIConnector$RemoteMBeanServerConnection.invoke(Unknown
Source)
at
ActiveMQJMXConnectionTest.getMsgNumber(ActiveMQJMXConnectionTest.java:43)
at ActiveMQJMXConnectionTest.main(ActiveMQJMXConnectionTest.java:24)
This makes me think it is completely wrong.
Would you know an useful link to help me?
tks,
Oscar
--
View this message in context: http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3225364.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
Re: Get the number of pending messages programatically
Posted by oscarfh2 <os...@gmail.com>.
That is great, I will take a look at the plugin and ask about the possibility
of installing it on the servers.
Would be any way of doing without the plugin?
Tks,
Oscar
--
View this message in context: http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3225171.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
Re: Get the number of pending messages programatically
Posted by Norman Maurer <no...@apache.org>.
Hi,
you could use the statisticsplugin:
http://activemq.apache.org/statisticsplugin.html
Bye,
Norman
2011/1/19 oscarfh2 <os...@gmail.com>:
>
> Hi,
> I am developing a tool which gather information about queues in a server.
> One of these informations is how many pending messages.
>
> My approach now is to open a browser and iterate through all the messages,
> it works, but it is not good:
> 1-it is slow
> 2-each "next message" will make a network call, that makes it unacceptable
>
> Is there any other way to get this number? It would be perfect to have
> something like this:
>
> queue.getPendingMessageNumber()
>
> But I couldn't find... Any ideas of how I could do that?
> The server has this information, because I can see it in the server console.
> The question is: how can I reach it?
>
> Tks,
> Oscar
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Get-the-number-of-pending-messages-programatically-tp3225127p3225127.html
> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
>
Strange behavior
Posted by Adam Kaminiecki <ad...@dgt.com.pl>.
Hi all,
Happened to me a strange situation in which one of the clients received
the 5 copies of the same message.
All logs are from the same machine.
Log from my application maybe will help:
Message sender:
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515181:AMQ.INFO: BrokerUri set =
tcp://localhost:61616
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515182:AMQ.INFO: Connecting to:
tcp://localhost:61616/
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515184:AMQ.DEBUG: Opening socket
to: localhost on port: 61616
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515185:AMQ.DEBUG: Connected to
localhost:61616 using InterNetwork protocol.
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515194:AMQ.DEBUG: Creating
Inactivity Monitor
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515303:AMQ.DEBUG: Inactivity: Read
Check time interval: 30000
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515303:AMQ.DEBUG: Inactivity:
Initial Delay time interval: 0
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515304:AMQ.DEBUG: Inactivity: Write
Check time interval: 10000
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515305:AMQ.DEBUG: Message sent
since last write check. Resetting flag
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515306:AMQ.DEBUG: A receive is in
progress or already failed.
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515764:AMQ.DEBUG: MessageProducer
created with a Window Size of: 1024000
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515773:AMQ.INFO: BrokerUri set =
tcp://localhost:61616
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515773:AMQ.INFO: Connecting to:
tcp://localhost:61616/
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515773:AMQ.DEBUG: Opening socket
to: localhost on port: 61616
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515773:AMQ.DEBUG: Connected to
localhost:61616 using InterNetwork protocol.
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515773:AMQ.DEBUG: Creating
Inactivity Monitor
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515774:AMQ.DEBUG: Inactivity: Read
Check time interval: 30000
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515774:AMQ.DEBUG: Inactivity:
Initial Delay time interval: 0
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515775:AMQ.DEBUG: Inactivity: Write
Check time interval: 10000
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515775:AMQ.DEBUG: Message sent
since last write check. Resetting flag
Jan 19 17:45:15 127.0.0.1 [SUDWEB]: 4515775:AMQ.DEBUG: A receive is in
progress or already failed.
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516230:AMQ.DEBUG: MessageProducer
created with a Window Size of: 1024000
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516246:AMQ.DEBUG: MemoryUsage:
Increase Usage to: 2135 bytes.
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: Object
sent:SUDWebPingAliveRequest[ConsumerID=-112805952, Gateway=192.168.44.133]
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516249:AMQ.DEBUG: Closing down the
Consumer
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516252:AMQ.DEBUG: Consumer instance
Closed.
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516253:AMQ.INFO: Closing Connection.
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516254:AMQ.INFO: Asynchronously
disposing of Connection.
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516254:AMQ.INFO: Oneway command
sent to broker.
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516254:AMQ.INFO: Disposing of the
Transport.
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: BEFORE RECEIVE
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: AFTER RECEIVE
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516261:AMQ.DEBUG: Closing down the
Consumer
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516262:AMQ.ERROR: No such consumer
active: ID:sud-37492-634310559151963650-1:1:1:1
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516262:AMQ.ERROR: No such consumer
active: ID:sud-37492-634310559151963650-1:1:1:1
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516262:AMQ.ERROR: No such consumer
active: ID:sud-37492-634310559151963650-1:1:1:1
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516262:AMQ.ERROR: No such consumer
active: ID:sud-37492-634310559151963650-1:1:1:1
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516264:AMQ.DEBUG: Consumer instance
Closed.
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516264:AMQ.ERROR: No such consumer
active: ID:sud-37492-634310559151963650-1:1:1:1
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516264:AMQ.ERROR: No such consumer
active: ID:sud-37492-634310559151963650-1:1:1:1
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516264:AMQ.ERROR: No such consumer
active: ID:sud-37492-634310559151963650-1:1:1:1
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516264:AMQ.INFO: Closing Connection.
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516264:AMQ.INFO: Asynchronously
disposing of Connection.
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516264:AMQ.INFO: Oneway command
sent to broker.
Jan 19 17:45:16 127.0.0.1 [SUDWEB]: 4516264:AMQ.INFO: Disposing of the
Transport.
Message reciver:
Jan 19 17:45:16 sud SUD[26814]: ContextPoolManager (32): New message
received(SUDWebPingAliveRequest[ConsumerID=-112805952,
Gateway=192.168.44.133])
Jan 19 17:45:16 sud SUD[26814]: ContextPoolManager (32):
Aastra6739iContext(00-08-5D-13-E1-0B): new Task Added
Jan 19 17:45:16 sud SUD[26814]: ContextPoolManager (32): New message
received(SUDWebPingAliveRequest[ConsumerID=-112805952,
Gateway=192.168.44.133])
Jan 19 17:45:16 sud SUD[26814]: ContextPoolManager (32):
Aastra6739iContext(00-08-5D-13-E1-0B): new Task Added
Jan 19 17:45:16 sud SUD[26814]: ContextPoolManager (32): New message
received(SUDWebPingAliveRequest[ConsumerID=-112805952,
Gateway=192.168.44.133])
Jan 19 17:45:16 sud SUD[26814]: ContextPoolManager (32):
Aastra6739iContext(00-08-5D-13-E1-0B): new Task Added
Jan 19 17:45:16 sud SUD[26814]: ContextPoolManager (32): New message
received(SUDWebPingAliveRequest[ConsumerID=-112805952,
Gateway=192.168.44.133])
Jan 19 17:45:16 sud SUD[26814]: ContextPoolManager (32):
Aastra6739iContext(00-08-5D-13-E1-0B): new Task Added
Jan 19 17:45:16 sud SUD[26814]: ContextPoolManager (32): New message
received(SUDWebPingAliveRequest[ConsumerID=-112805952,
Gateway=192.168.44.133])
Jan 19 17:45:16 sud SUD[26814]: ContextPoolManager (32):
Aastra6739iContext(00-08-5D-13-E1-0B): new Task Added
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): New message
received(ContextServiceRequest)
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): Starting
processing context Aastra6739iContext(00-08-5D-13-E1-0B)
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): New exclusive
message received(SUDWebPingAliveRequest[ConsumerID=-112805952,
Gateway=192.168.44.133])
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): PingAlive
package received from Aastra[00-08-5D-13-E1-0B] { RegisterState = 200 }
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06):
Aastra6739iContext.validateAastraXMLObject(AastraXMLIPPhoneExecute)
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): New exclusive
message received(SUDWebPingAliveRequest[ConsumerID=-112805952,
Gateway=192.168.44.133])
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): PingAlive
package received from Aastra[00-08-5D-13-E1-0B] { RegisterState = 200 }
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06):
Aastra6739iContext.validateAastraXMLObject(AastraXMLIPPhoneExecute)
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): New exclusive
message received(SUDWebPingAliveRequest[ConsumerID=-112805952,
Gateway=192.168.44.133])
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): PingAlive
package received from Aastra[00-08-5D-13-E1-0B] { RegisterState = 200 }
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06):
Aastra6739iContext.validateAastraXMLObject(AastraXMLIPPhoneExecute)
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): New exclusive
message received(SUDWebPingAliveRequest[ConsumerID=-112805952,
Gateway=192.168.44.133])
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): PingAlive
package received from Aastra[00-08-5D-13-E1-0B] { RegisterState = 200 }
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06):
Aastra6739iContext.validateAastraXMLObject(AastraXMLIPPhoneExecute)
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): New exclusive
message received(SUDWebPingAliveRequest[ConsumerID=-112805952,
Gateway=192.168.44.133])
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06): PingAlive
package received from Aastra[00-08-5D-13-E1-0B] { RegisterState = 200 }
Jan 19 17:45:16 sud SUD[26814]: ServingThread (06):
Aastra6739iContext.validateAastraXMLObject(AastraXMLIPPhoneExecute)
I have 4 broker in cluster
Log from broker 44.133
2011-01-19 17:45:16,231 | DEBUG | localhost adding consumer:
ID:sud-37492-634310559151963650-1:1:1:1 for destination:
topic://WEB.topic | org.apache.activemq.broker.region.AbstractRegion |
ActiveMQ Transport: tcp:///127.0.0.1:35618
2011-01-19 17:45:16,245 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-12:2:1:5, destination
topic://SUD.topic, brokerPath: [ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 5, responseRequired = false,
messageId = ID:sud-37492-634310559151963650-1:0:1:1:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-12:1:1:1, destination = topic://SUD.topic,
transactionId = null, expiration = 0, timestamp = 1295455516235, arrival
= 0, brokerInTime = 1295455516245, brokerOutTime = 1295455516245,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@346bda, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 2135,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#18
2011-01-19 17:45:16,246 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-3:2:1:5, destination
topic://SUD.topic, brokerPath: [ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 5, responseRequired = false,
messageId = ID:sud-37492-634310559151963650-1:0:1:1:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-3:1:1:1, destination = topic://SUD.topic,
transactionId = null, expiration = 0, timestamp = 1295455516235, arrival
= 0, brokerInTime = 1295455516245, brokerOutTime = 1295455516246,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@346bda, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 2135,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#2
2011-01-19 17:45:16,246 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-4:2:1:3, destination
topic://SUD.topic, brokerPath: [ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 5, responseRequired = false,
messageId = ID:sud-37492-634310559151963650-1:0:1:1:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-4:1:1:1, destination = topic://SUD.topic,
transactionId = null, expiration = 0, timestamp = 1295455516235, arrival
= 0, brokerInTime = 1295455516245, brokerOutTime = 1295455516246,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@346bda, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 2135,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#4
2011-01-19 17:45:16,250 | DEBUG | Expiring messages .. |
org.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost]
Scheduler
2011-01-19 17:45:16,250 | DEBUG | asystentAdam@CZABANMSI toPageIn: 0,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0 |
org.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost]
Scheduler
2011-01-19 17:45:16,250 | DEBUG | Expiring messages .. |
org.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost]
Scheduler
2011-01-19 17:45:16,250 | DEBUG | ActiveMQ.DLQ toPageIn: 37, Inflight:
0, pagedInMessages.size 0, enqueueCount: 37, dequeueCount: 0 |
org.apache.activemq.broker.region.Queue | ActiveMQ Broker[localhost]
Scheduler
2011-01-19 17:45:16,250 | DEBUG | ActiveMQ.DLQ toPageIn: 37, Inflight:
0, pagedInMessages.size 0, enqueueCount: 37, dequeueCount: 0 |
org.apache.activemq.broker.region.Queue | Queue:ActiveMQ.DLQ
2011-01-19 17:45:16,252 | DEBUG | localhost removing consumer:
ID:sud-37492-634310559151963650-1:0:1:1 for destination:
topic://SUD.topic | org.apache.activemq.broker.region.AbstractRegion |
ActiveMQ Transport: tcp:///127.0.0.1:35617
2011-01-19 17:45:16,254 | DEBUG | remove connection id:
ID:sud-37492-634310559151963650-1:0 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
tcp:///127.0.0.1:35617
2011-01-19 17:45:16,255 | DEBUG | Stopping connection: /127.0.0.1:35617
| org.apache.activemq.broker.TransportConnection | ActiveMQ Task
2011-01-19 17:45:16,255 | DEBUG | Stopping transport
tcp:///127.0.0.1:35617 | org.apache.activemq.transport.tcp.TcpTransport
| ActiveMQ Task
2011-01-19 17:45:16,257 | DEBUG | Stopped transport: /127.0.0.1:35617 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Task
2011-01-19 17:45:16,259 | DEBUG | Connection Stopped: /127.0.0.1:35617 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Task
2011-01-19 17:45:16,260 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-3:2:1:1229, destination
topic://WEB.topic, brokerPath: [ID:dgtl-38008-1295021911958-0:1,
ID:dgt2_p-59933-1295021914007-0:1, ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 394038, responseRequired =
false, messageId = ID:sud-37823-634310558783521020-1:0:1:67:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-3:1:1:1, destination = topic://WEB.topic,
transactionId = null, expiration = 0, timestamp = 1295455516255, arrival
= 0, brokerInTime = 1295455516260, brokerOutTime = 1295455516260,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@1460902, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 1973,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#2
2011-01-19 17:45:16,261 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-3:2:1:1229, destination
topic://WEB.topic, brokerPath: [ID:dgtl-38008-1295021911958-0:1,
ID:dgt2_p-59933-1295021914007-0:1, ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 394039, responseRequired =
false, messageId = ID:sud-37823-634310558783521020-1:0:1:68:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-3:1:1:1, destination = topic://WEB.topic,
transactionId = null, expiration = 0, timestamp = 1295455516256, arrival
= 0, brokerInTime = 1295455516260, brokerOutTime = 1295455516261,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@f9911e, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 1973,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#2
2011-01-19 17:45:16,261 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-3:2:1:1229, destination
topic://WEB.topic, brokerPath: [ID:dgtl-38008-1295021911958-0:1,
ID:dgt2_p-59933-1295021914007-0:1, ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 394040, responseRequired =
false, messageId = ID:sud-37823-634310558783521020-1:0:1:69:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-3:1:1:1, destination = topic://WEB.topic,
transactionId = null, expiration = 0, timestamp = 1295455516257, arrival
= 0, brokerInTime = 1295455516260, brokerOutTime = 1295455516261,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@a67320, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 1973,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#2
2011-01-19 17:45:16,261 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-4:2:1:4, destination
topic://WEB.topic, brokerPath: [ID:dgtl-38008-1295021911958-0:1,
ID:dgt2_l-48559-1295021913503-0:1, ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 231201, responseRequired =
false, messageId = ID:sud-37823-634310558783521020-1:0:1:67:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-4:1:1:1, destination = topic://WEB.topic,
transactionId = null, expiration = 0, timestamp = 1295455516255, arrival
= 0, brokerInTime = 1295455516260, brokerOutTime = 1295455516261,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@1d07ad5, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 1973,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#4
2011-01-19 17:45:16,261 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-4:2:1:4, destination
topic://WEB.topic, brokerPath: [ID:dgtl-38008-1295021911958-0:1,
ID:dgt2_l-48559-1295021913503-0:1, ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 231202, responseRequired =
false, messageId = ID:sud-37823-634310558783521020-1:0:1:68:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-4:1:1:1, destination = topic://WEB.topic,
transactionId = null, expiration = 0, timestamp = 1295455516256, arrival
= 0, brokerInTime = 1295455516261, brokerOutTime = 1295455516261,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@30681e, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 1973,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#4
2011-01-19 17:45:16,265 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-3:2:1:1229, destination
topic://WEB.topic, brokerPath: [ID:dgtl-38008-1295021911958-0:1,
ID:dgt2_p-59933-1295021914007-0:1, ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 394044, responseRequired =
false, messageId = ID:sud-37823-634310558783521020-1:0:1:70:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-3:1:1:1, destination = topic://WEB.topic,
transactionId = null, expiration = 0, timestamp = 1295455516258, arrival
= 0, brokerInTime = 1295455516262, brokerOutTime = 1295455516262,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@6af2d2, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 1973,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#2
2011-01-19 17:45:16,265 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-3:2:1:1229, destination
topic://WEB.topic, brokerPath: [ID:dgtl-38008-1295021911958-0:1,
ID:dgt2_p-59933-1295021914007-0:1, ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 394045, responseRequired =
false, messageId = ID:sud-37823-634310558783521020-1:0:1:71:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-3:1:1:1, destination = topic://WEB.topic,
transactionId = null, expiration = 0, timestamp = 1295455516259, arrival
= 0, brokerInTime = 1295455516262, brokerOutTime = 1295455516265,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@16bf4b4, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 1973,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#2
2011-01-19 17:45:16,266 | DEBUG | Transport failed:
java.net.SocketException: Broken pipe |
org.apache.activemq.broker.TransportConnection.Transport | Async
Exception Handler
java.net.SocketException: Broken pipe
at java.net.SocketOutputStream.socketWrite0(Native Method)
at java.net.SocketOutputStream.socketWrite(Unknown Source)
at java.net.SocketOutputStream.write(Unknown Source)
at
org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:115)
at java.io.DataOutputStream.flush(Unknown Source)
at
org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:182)
at
org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:255)
at
org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85)
at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
at
org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1249)
at
org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:810)
at
org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:846)
at
org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
at
org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36)
2011-01-19 17:45:16,266 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-4:2:1:4, destination
topic://WEB.topic, brokerPath: [ID:dgtl-38008-1295021911958-0:1,
ID:dgt2_l-48559-1295021913503-0:1, ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 231204, responseRequired =
false, messageId = ID:sud-37823-634310558783521020-1:0:1:69:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-4:1:1:1, destination = topic://WEB.topic,
transactionId = null, expiration = 0, timestamp = 1295455516257, arrival
= 0, brokerInTime = 1295455516262, brokerOutTime = 1295455516266,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@be292d, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 1973,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#4
2011-01-19 17:45:16,266 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-4:2:1:4, destination
topic://WEB.topic, brokerPath: [ID:dgtl-38008-1295021911958-0:1,
ID:dgt2_l-48559-1295021913503-0:1, ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 231207, responseRequired =
false, messageId = ID:sud-37823-634310558783521020-1:0:1:70:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-4:1:1:1, destination = topic://WEB.topic,
transactionId = null, expiration = 0, timestamp = 1295455516258, arrival
= 0, brokerInTime = 1295455516266, brokerOutTime = 1295455516266,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@816eaa, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 1973,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#4
2011-01-19 17:45:16,267 | DEBUG | bridging (localhost -> localhost,
consumer: ID:sud-56354-1295064310147-4:2:1:4, destination
topic://WEB.topic, brokerPath: [ID:dgtl-38008-1295021911958-0:1,
ID:dgt2_l-48559-1295021913503-0:1, ID:sud-56354-1295064310147-0:1],
message: ActiveMQObjectMessage {commandId = 231208, responseRequired =
false, messageId = ID:sud-37823-634310558783521020-1:0:1:71:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:sud-56354-1295064310147-4:1:1:1, destination = topic://WEB.topic,
transactionId = null, expiration = 0, timestamp = 1295455516259, arrival
= 0, brokerInTime = 1295455516266, brokerOutTime = 1295455516267,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@18879ee, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 1973,
properties = null, readOnlyProperties = false, readOnlyBody = false,
droppable = false} |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Connection Dispatcher: vm://localhost#4
2011-01-19 17:45:16,269 | DEBUG | Stopping connection: /127.0.0.1:35618
| org.apache.activemq.broker.TransportConnection | ActiveMQ Task
2011-01-19 17:45:16,269 | DEBUG | Stopping transport
tcp:///127.0.0.1:35618 | org.apache.activemq.transport.tcp.TcpTransport
| ActiveMQ Task
Hope this helps. If u need more log tell me.
Regards,
Adam
--
This message has been scanned for viruses and
dangerous content by MailScanner, and is
believed to be clean.