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
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
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
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
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
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
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
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
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
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
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
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
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
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
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.
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
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
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.
--
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
19 matches
Mail list logo