Re: ActiveMQ Inactivity Monitor

2013-04-29 Thread pp123
Hi , Please help me to fix this . Scenario : Protocol :Mqtt client : Subscriber Active Mq version : 5.8.0 I connected to Broker using client ID : 1000 .After that without sending disconnect command (removed the lan cable ) i disconnected the client .So expectation is after 1.5* keepalive ti

Re: InactivityMonitor issue

2013-04-29 Thread pp123
Thanks for the reply. There is no test case for this as i am just trying to figure out when ActiveMq removes the dead connection ? According to http://activemq.apache.org/mqtt.html , it should remove in the time span of 1.5* keepalive which is not happening . In detail A client connec

Re: Memory leak??

2013-04-29 Thread SledgeHammer
Hmm... I switched the response queue to be a "permanent" queue and it looks like it doesn't have the same memory leak issue. -- View this message in context: http://activemq.2283324.n4.nabble.com/Memory-leak-tp4666300p4666412.html Sent from the ActiveMQ - User mailing list archive at Nabble.co

Re: Query around ActiveMQ.DLQ

2013-04-29 Thread Christian Posta
Are the consumer and producer on the same connection? When doing normal sync sends for producer sending persistent messages, even if producer and consumer are on same connection, ActiveMQ shouldn't block the entire connection. if doing async sends, you may end up with entire connection blocked. On

Re: Query around ActiveMQ.DLQ

2013-04-29 Thread deepak_a
Also, - we are using JDBC store to persist messages. Does this mean messages that are persisted will also be held up in memory/cache? i.e. will that also be occupying the broker memory? -- View this message in context: http://activemq.2283324.n4.nabble.com/Query-around-ActiveMQ-DLQ-tp4666277p4

Re: Memory leak??

2013-04-29 Thread SledgeHammer
I am using persistent messages. I have not mucked with any of the backing or memory options, so thats all stock. The way I have this working right now is (on the consumer side): Consumer creates IMessageConsumer on ActiveMQ.Advisory.Queue Consumer uses Listener += method when I get a Queue Add a

Re: Query around ActiveMQ.DLQ

2013-04-29 Thread deepak_a
Hi, Also what was noticed in my test is that - when the CursorMemoryUsage reached/exceeded the limit (64MB), the producer was blocked (which is understandable) - but it was surprising to note that consumer was also blocked (i.e. the camel route that pulled messages from the Queue also froze) - is

Re: Issue when receiving java object

2013-04-29 Thread Christian Posta
Is the correct class on the consumer's classpath? in general, object messages over JMS create lots of headache... might want to switch to some other formatting... xml, json, etc. On Sun, Apr 28, 2013 at 8:32 AM, Balachandar R.A. wrote: > Hello, > > I wanted to send a java object to activeMQ. I c

Re: Brokers of a machine steal the lock

2013-04-29 Thread Christian Posta
what kind of file system are you using? does it support exclusive distributed locking? On Fri, Apr 26, 2013 at 3:38 AM, davinci wrote: > Hi, this is the scenario: > machine1 master1 slave2 > machine2 master2 slave1 > > when I run slave1, this steals the lock and master1 stop. > when I run maste

Re: Memory leak??

2013-04-29 Thread Christian Posta
persistent, or non persistent messages? you want to be careful using non-persistent messages and disabling producer flow control. also temporary destinations don't provide a backing store and everything is in memory. this means even for persistent messages you can run oom with PFC off. you can use

Re: Memory leak??

2013-04-29 Thread SledgeHammer
Hi Christian, here is my complete config. Its pretty standard. FYI: I tried bumping up the to 128 mb, and I still get the error. I have producer flow control disabled as you can see. How do I "check using jmx" in a Windows environ

Re: InactivityMonitor issue

2013-04-29 Thread Christian Posta
put together a test case and i can help you. On Mon, Apr 29, 2013 at 5:28 AM, pp123 wrote: > Hi , > > Please help me to fix this . > > Scenario : > Protocol :Mqtt > client : Subscriber > Active Mq version : 5.8.0 > I connected to Broker using client ID : 1000 .After that without sending > disco

Re: Memory leak??

2013-04-29 Thread Christian Posta
you must have some other destinations that have messages are using broker memory. check using jmx. what are your settings for destination and system memory? http://activemq.apache.org/producer-flow-control.html On Mon, Apr 29, 2013 at 9:38 AM, SledgeHammer wrote: > Any advice on this issue guys

Re: Exception in thread "ActiveMQ Transport: tcp:///10.80.0.35:38499" java.lang.ClassCastException: org.apache.activemq.command.ReplayCommand

2013-04-29 Thread Christian Posta
Yah, port scanning sends bytes that the wire format codec does not recognize. upgrading to a new version will not fix this. On Mon, Apr 29, 2013 at 12:24 AM, mmg wrote: > We dont use udp protocol. Also all the clients are at same version (4.0.1) > > We have found that this exception is thrown o

Re: Memory leak??

2013-04-29 Thread SledgeHammer
Any advice on this issue guys? -- View this message in context: http://activemq.2283324.n4.nabble.com/Memory-leak-tp4666300p4666394.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Message priority

2013-04-29 Thread metatech
gtully wrote > policyEntry queue="xxx" useCache="false" > expireMessagesPeriod="0"queuePrefetch="1" Gary,Even tough we configured our queue using all these options, we still have problems when a JDBC persistence adapter is used : 1. sometimes low priority messages are consumed although there are t

InactivityMonitor issue

2013-04-29 Thread pp123
Hi , Please help me to fix this . Scenario : Protocol :Mqtt client : Subscriber Active Mq version : 5.8.0 I connected to Broker using client ID : 1000 .After that without sending disconnect command (removed the lan cable ) i disconnected the client .So expectation is after 1.5* keepalive time ina

Re: Error bin/activemq stop Failed to execute main task. Reason: java.lang.NoClassDefFoundError: com.ibm.tools.attach.javaSE.AttachProvider

2013-04-29 Thread jandeclercq
Hey, I had to install this IBM version of the java runtime environment to get Informix installed/running. I installed a non-IBM version of java in a different path, and pointed ActiveMQ to that jre version. With that, the problem is fixed. Thanks for pointing me in the right direction. --

Re: Exception in thread "ActiveMQ Transport: tcp:///10.80.0.35:38499" java.lang.ClassCastException: org.apache.activemq.command.ReplayCommand

2013-04-29 Thread mmg
We dont use udp protocol. Also all the clients are at same version (4.0.1) We have found that this exception is thrown only when Qualys vulnerability tool is executed. It seems this tool blocks the 61616 port for few secs for scanning. during this time, we can see IOExceptions and SocektExceptions