Re: How to check if 'jms.useAsyncSend=true' is set in an inbound message?

Thanks much for your reply. I will try that. thanks, Damu -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-check-if-jms-useAsyncSend-true-is-set-in-an-inbound-message-tp4672842p4672966.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: "OpenWireFormatNegotiator::onewayWire format negotiation timeout" when creating connection/session

http://docs.oracle.com/javase/7/docs/technotes/tools/share/jstack.html On Thu, Oct 17, 2013 at 11:13 AM, JRR wrote: > How do I take a stack track of the broker? > > Thanks, > > -=John > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/OpenWireFormatNegotiator-one

Re: The consumers couldn't disconnect from broker properly

Add a shutdown hook. It doesn't sound like it has anything whatsoever to do with broker code. On Oct 14, 2013, at 2:21 AM, HellKnight wrote: > I typed "netstat -anp | grep 61616" in the server command window, and I find > that "192.168.28.66 : 7042" is connected to server port 61616. > > > >

Re: The consumers couldn't disconnect from broker properly

I typed "netstat -anp | grep 61616" in the server command window, and I find that "192.168.28.66 : 7042" is connected to server port 61616. -- View this message in context: http://activemq.2283324.n4.nabble.com/The-consumers-couldn-t-disconnect-from-broker-properly-tp4672722p4672724.html Sent

Re: "OpenWireFormatNegotiator::onewayWire format negotiation timeout" when creating connection/session

How do I take a stack track of the broker? Thanks, -=John -- View this message in context: http://activemq.2283324.n4.nabble.com/OpenWireFormatNegotiator-onewayWire-format-negotiation-timeout-when-creating-connection-session-tp4672902p4672960.html Sent from the ActiveMQ - User mailing list ar

Re: The consumers couldn't disconnect from broker properly

Mr.Bish: Thanks for helping me using ActiveMQ these days. I turned off Inactivity monitor on the broker. I know it could kill old stale connections after a given time. However, I think why there is "old stale connections" in the first place is the real problem---If the client program and the

Re: "OpenWireFormatNegotiator::onewayWire format negotiation timeout" when creating connection/session

Take a stack trace of the broker and post it here. On Thu, Oct 17, 2013 at 8:51 AM, JRR wrote: > It appears that we are using Active MQ 5.8.0 > > And we are using the Active MQ C++ client version 3.7.0. > > Is it reproducible? Well, sort of in a way. We've entered this state and > and > now it

Re: Is it possible to view and delete individual messages in the queue on Apollo

Not sure about the web interface, but you should be able to create a consumer that reads the message from a queue using a selector on the JMS ID (if you know it). -- View this message in context: http://activemq.2283324.n4.nabble.com/Is-it-possible-to-view-and-delete-individual-messages-in-the-

Recovering from running out of persistence storage - testing

Hi, I'm writing some tests to replicate activemq running out of persistence storage. To do this, I am simply testing some sending and receiving messages, then filling up a test queue with persistent messages, purge the queue via JMX, then trying to send and receive messages again to see if all rec

Message Queue Slows Down after 2 million plus message

Hi Everyone, I have a message queue named amq570queue, after accumulating 2 million messages it started to slow down. What broker settings do I need to adjust to fix this issue? I temporarily moved it into a new message queue(in the same broker) and it is working fine. I initially thought that

Is it possible to view and delete individual messages in the queue on Apollo

Using the web interface on Apollo, I can delete all messages in a queue, but I do not see anyway to remove just one. Is this possible through the web interface or programmatically? Thanks, Darren -- View this message in context: http://activemq.2283324.n4.nabble.com/Is-it-possible-to-view-an

Message Queue Slows Down after 2 million plus message

Hi Everyone, I have a message queue named amq570queue, after accumulating 2 million messages it started to slow down. What broker settings do I need to adjust to fix this issue? I temporarily moved it into a new message queue(in the same broker) and it is working fine. I initially thought that t

Re: "OpenWireFormatNegotiator::onewayWire format negotiation timeout" when creating connection/session

It appears that we are using Active MQ 5.8.0 And we are using the Active MQ C++ client version 3.7.0. Is it reproducible? Well, sort of in a way. We've entered this state and and now it happens for every message we attempt to send (I'm assuming the QA folks haven't reset their applications yet).

Re: Re:Re: Is it possible to dispatch a message in the topic to only a certain queues while using virtual topic?

because you didn't include them upfront... suonayi came up with valid solution, but with missing details, it wasn't clear what your requirements were. back to the story... why don't you just have a camel route that listens for a "delete user" message and then uses JMX to remove the queue in quest

Re: How to check if 'jms.useAsyncSend=true' is set in an inbound message?

I don't think there is an easier way to set asyncSend in your setup. But to validate it is in use, in your camel context is you can get the in message and cast to ActiiveMQMessage you can check org.apache.activemq.command.BaseCommand#isResponseRequired with asyncSend that will be false. On 15 Oct

Re: Re:Re: Is it possible to dispatch a message in the topic to only a certain queues while using virtual topic?

The login process is something like our forum , loginName and password is sent to some web service, the web service verify these data from what's stored in database of server side.If loginName and password is legal, the client program will receive an OK message and a consumer is created , starti

Re: How to generate slow consumers.

Twice the prefetch limit == slow consumer On Wed, Oct 16, 2013 at 10:21 PM, johnbing wrote: > Thanks for the reply, In addition to the above context, Can you please tell > me when broker is decide that the consumer is slow ? There must have been > some limit, is it that as soon as as broker rea

Re: Poor performance while using virtual topic mode

Your disk drive/OS will correlate heavily with your persistence performance. Also whether or not you sync to disk, your message sizes, how much of the index is kept in memory, write buffer sizes, etc, etc. Take a look at http://activemq.apache.org/kahadb.html and start benchmarking :) On Wed,

Re: Re:Re: Is it possible to dispatch a message in the topic to only a certain queues while using virtual topic?

Tell a little more about how users 'login', how long to keep the messages if they log out, and what event causes a queue in the virtual topic to be removed On Wed, Oct 16, 2013 at 10:35 PM, HellKnight wrote: > only online consumers could receive message if I use non-durable > subscriptions.

Re: Rebalance not working in 5.8.0

Created ticket: https://issues.apache.org/jira/browse/AMQ-4812 -- View this message in context: http://activemq.2283324.n4.nabble.com/Rebalance-not-working-in-5-8-0-tp4672890p4672939.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Replicated LevelDB Store filling up memory

I have 2 slaves and 1 master running and using persistent messges. The master's memory usage is going high. The following are the objects i see building up: byte: 2.77G LinkedList:235MB (9.8 mil instances) org.apache.activemq.leveldb.replicated.FileTransferFrame:78.7M (2.45 mil. instances) ..Repl

Re: How to generate slow consumers.

waiting for someone to reply... One more thing. Other than slow consumer handling, is there any case when a message is discarded ? After discarding a message, where does it go, is it deleted forever or send to some disk ? -- View this message in context: http://activemq.2283324.n4.nabble.com

Re: Re:XA transaction not working on Broker redelivery.

Thanks for the info...I am now trying with this example http://code.google.com/p/camelinaction/source/browse/trunk/chapter9/xa/src/test/resources/spring-context.xml?r=344 but whatever i do i cant get e.g. delayed redelivery to work on the consumer side. It sounds like you did it...do you mind shari

Poor performance while using virtual topic mode

I am using virtual topic mode of ActiveMQ in my system.However, I found that performance degrades magnificantly if you add queues mapping to the virtual Topic. I did some simple tests in my Envrionment, the result is as follow : For each queue I added, it will costs the producer an extra 20 ms to

Re: maxConnections in org.apache.activemq.pool.PooledConnectionFactory

On 10/17/2013 04:27 AM, Jose María Zaragoza wrote: Hello: I'm using AMQ 5.8 and I would like to undertand the meaning of maxConnections in org.apache.activemq.pool.PooledConnectionFactory About Java doc, "the maximum number to pooled Connections that this factory will allow before it begins t

Re: "OpenWireFormatNegotiator::onewayWire format negotiation timeout" when creating connection/session

On 10/16/2013 09:30 PM, JRR wrote: Hello, I've encountered a problem where a user of our product reported their AMQ messages stopped working, and when I dug into the details I found that we are getting an exception for: "OpenWireFormatNegotiator::onewayWire format negotiation timeout" when we c

Re: Poor performance while using virtual topic mode

I did some more tests and I found the performance issue is due to message persistence. If I chose to send non-persistent messages , it took less than 1ms to send a message , even though by synchronous sends.I did not change the default configration about message persistence in activemq.xml. Can any

Re: Rebalance not working in 5.8.0

OK - so can you raise an issue for this thanks! Rob On 17 Oct 2013, at 02:31, waydena wrote: > See Broker 1 config file attached. > > activemq.xml > > > > > -- > View this message in context: > http://activemq.2283324.n4

maxConnections in org.apache.activemq.pool.PooledConnectionFactory

Hello: I'm using AMQ 5.8 and I would like to undertand the meaning of maxConnections in org.apache.activemq.pool.PooledConnectionFactory About Java doc, "the maximum number to pooled Connections that this factory will allow before it begins to return connections from the pool on calls to" but

Re: How to generate slow consumers.

Thanks for the reply, In addition to the above context, Can you please tell me when broker is decide that the consumer is slow ? There must have been some limit, is it that as soon as as broker realize that pre-fetch limit for consumer is exceeded, it report that consumer as slow ? Another questi