Hi Gary,
Thanks for your thoughtful response once again.
I tried adding htis call in my code:
connectionFactory.setClientIDPrefix("ID:ReplyDest.hostname");
And then added this in activemq.xml in staticallyIncludedDestinations tag:
"/>
However I noticed that ActiveMQ ignored prefix string set
To be honest I've had a tough time doing this with the API. Our goals may be
a bit different from yours, we are trying to determine how many messages are
on the queue that have not been picked up by a consumer. One of the issues
is dealing with prefetch sizes for different consumers and taking th
*java.lang.OutOfMemoryError: unable to create new native thread*
Generally means that there isn't enough free memory for the OS to create a
new thread. I would suggest freeing up memory on the machine or REDUCING
the heap size of the JVM.
J
On Thu, Mar 24, 2011 at 8:08 AM, Laures wrote:
> Hi,
On Thu, 2011-03-24 at 13:27 +0100, Oscar Pernas wrote:
> Hi all (again),
>
>
> Im trying to understand well, how the failover transport works. I know that
> if you have an active-pasive architecture and your active broker goes down,
> all messages are send to the pasive broker. But, for example,
Hi all (again),
Im trying to understand well, how the failover transport works. I know that
if you have an active-pasive architecture and your active broker goes down,
all messages are send to the pasive broker. But, for example, if we have a
machine that have configured an active-pasive brokers
Hi all,
Why I try to run activemq-cpp in windows environment, with this kind of
uris:
failover://(tcp://localhost:61616)?startupMaxReconnectAttemps=3&initialReconnectDelay=3000
if a producer configured in failover with only one ip but non-blocking (with
maxreconnect attemps and initialreconnect
Hi,
I'm currently load testing the native REST Api of activemq on our hardware.
I'm using pylot to generate several users.
Some time into the test i start to get:
WARN | Error for /rest/message/FOO/BAR
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.st
You got to use ConnectionInfo.getConnectionId(), and your supplied
clientIDPrefix will be the start of the returned id.
fyi, the java doc from the website is a good reference:
http://activemq.apache.org/maven/5.4.0/activemq-core/apidocs/org/apache/activemq/command/ConnectionInfo.html
Maybe the si
Hi Gary
Thank you.
I will follow your advice.
I looked into IdGenerator.java source
I imagine that I should retreive "ID:myProject.-one port
number-timestamp-instanceCount:sequence"
Since "ConnectionInfo" usage is not documented at all on the website, can I
use ConnectionInfo.getClientId() an
