Query about ActiveMQ connection id and client id format

Hi ActiveMQ team, Could somebody please help me understand the format of ActiveMQ connection id and client id. For example, I see this line in broker logs. 20130926 11:52:52:284 IST (ActiveMQ Transport: tcp:///10.240.170.64:40739@61616) org.apache.activemq.broker.util.LoggingBrokerPlugin 188 INFO

Re: Configuration of custom plugins with XBeans

yah probably because you're declaring the to be in the spring schema, so everything else within the bean def will expect to be w/in spring schema. would probably need to augment the auto generated activemq schema to support your new schema On Wed, Sep 25, 2013 at 2:54 PM, Frizz wrote: > He

Re: Did I turn off producer flow control correctly?

@someword: might be best to take stack traces of both brokers at 10s intervals for about 4-5 periods... i saw some suspicious threads, but would need to see what kind of progress they made. and curious about what the network bridge was doing on the spoke. in any event, it would be best to try and

Re: Did I turn off producer flow control correctly?

"Maybe you can post more about your clients? So your flow is Client -> Hub -> Spoke -> Server at which point the server responds to a temporary destination which flows messages Server -> Spoke -> Hub -> Client right?" That is correct. "How many messages does the server respond w/ over the te

Re: Configuration of custom plugins with XBeans

Hello Christian, that was an interesting read. Thank you. I tried to "incorporate" your simpleController example into my activemq.xml. It works fine outside of the definition, but when I do something like this I get an IllegalArgumentException: Cannot locate BeanDefinitionDecorator for element

Re: Did I turn off producer flow control correctly?

Maybe you can post more about your clients? So your flow is Client -> Hub -> Spoke -> Server at which point the server responds to a temporary destination which flows messages Server -> Spoke -> Hub -> Client right? How many messages does the server respond w/ over the temporary destination for ea

Re: Did I turn off producer flow control correctly?

I tried using 5.9 SNAPSHOT and get the same behavior. Here is a link to a thread dump from the broker where the blocking is occurring - http://pastebin.com/ew0cL6Kd. Additionally I've captured some strace/gdb output of the ruby client in case that's helpful - http://pastebin.com/FTKfczVd. Any id

Applet Class Loader Problems

I am having a problem loading classes when my applet reconnects to the backup server after a network failure. My messages are taking a very long time to be processed and I think that it is because the ClassLoadingAwareObjectInputStream is still trying to connect to the original server that served

Apollo subscribing with selector does not consume existing messages

We are using Apollo 1.6 placing messages on the queue and reading them on the client. The producer adds message headers and stomp client (via web socket) uses a subscription with SELECTOR to read the messages. If the consumer is already listening then the message is delivered as expected when pro

Re: Retained Flag in MQTT

And on the other side, it is working perfectly with Apollo. Is there any major difference in Apollo and Activemq MQTT distribution ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Retained-Flag-in-MQTT-tp4668333p4671833.html Sent from the ActiveMQ - User mailing list a

Re: [ActiveMQ 5.5.1] - Communication got stuck between Producer and Consumer

Thank you for you reply, ceposta. ceposta wrote > The broker has fired an advisory because a new consumer has been added. > But > you're contended around the lock to send messages because some other > thread > has the lock (dead lock possibly)? >From this thread trace, we can tell that the mess

Re: Consumers fail after reconnect

So far I have not been able to reproduce this outside of the applet. I have setup small test applications on the same machine as the client, but they never seem to fail. I can run them both at the same time and the applet will fail to reconnect completely while the test app operates just fine. I s

SOAP over JMS fails with AMQ 5.8.0 and AMQ-4312 patch

Once upon a time when we were using AMQ 5.6.0, we run into the https://issues.apache.org/jira/browse/AMQ-4076. For us, the effects of this bug were a failure in CXF over JMS when the envelopes size exceeded a 20KB size (more or less). To solve the problem we upgraded to 5.8.0 and the problem disap

Re: NIO transport performance for ActiveMQ

You are correct. It's a pool of threads that expand and contract. There isn't a necessary 1-to-1. On Wed, Sep 25, 2013 at 6:58 AM, johnbing wrote: > During this stack trace 20 clients were there, but I sent you snapshot of > small portion of the stack trace, if you want I can send the whole sta

Re: NIO transport performance for ActiveMQ

During this stack trace 20 clients were there, but I sent you snapshot of small portion of the stack trace, if you want I can send the whole stack trace for 20 clients. But as I specified NIO threads are continuously increasing with number of clients, So is there a threshold value, or some estimate

Re: Is it possible to use Client Certs for Authentication/Authorization for Apollo?

I just gave it a try, works great. Did you build from here? origin : https://github.com/apache/activemq-apollo.git (fetch) origin : https://github.com/apache/activemq-apollo.git (push) On Tue, Sep 24, 2013 at 4:48 PM, vatsal12 wrote: > Hi Chirino, > > I just tried the same Authorizer. > It is

Re: [ActiveMQ 5.5.1] - Communication got stuck between Producer and Consumer

in-line i hope to at least explain what's possibly going on in each thread, maybe that will be enough since you know your topology and producer/consumer configs and use cases better that we do: On Mon, Sep 23, 2013 at 7:17 PM, Jeff.Huang wrote: > I have a product built upon ActiveMQ 5.5.1. Syste

Re: ActiveMQ 5.8 Message Persistence with LevelDB

I don't think there isn't a comparable option in LevelDB. LevelDB does have an option to delay writes, but that is disabled and not configurable at the moment. You could try shutting off the cache to your queues which should cause the writes to store to be synchronous: On Wed, Sep 25, 2013 at

Re: PrefetchSize not working as expected

do you have a quick test case? post your configs broker/clients and might as well post your patch too. On Tue, Sep 24, 2013 at 1:38 AM, BenDahl wrote: > Hi all, > > we're experiencing some unexpected behavior in ActiveMQ 5.7.0.1 regarding > the PrefetchSize. When a client connects to the messag

Re: Configuration of custom plugins with XBeans

not sure if this will help, but i did write a blog about how ActiveMQ uses xbeans to generate its XSD: http://www.christianposta.com/blog/?p=111 On Wed, Sep 25, 2013 at 3:26 AM, Frizz wrote: > Hello, > > I create my own BrokerPlugin and configured it in activemq.xml like this: > > http://activ

Re: Statistics Plugin for ActiveMQ broker

Could easily deploy a camel route w/ the broker and have it retrieve stats and log to the activemq log file. On Wed, Sep 25, 2013 at 4:49 AM, johnbing wrote: > I think StatisticsBrokerPlugin class can be used for this purpose. To > retrieve stats on the broker send a empty message to > ActiveMQ

Re: NIO transport performance for ActiveMQ

How many connections are opened during your stack trace? I only see 10 NIO threads at that particular snapshot. On Wed, Sep 25, 2013 at 3:21 AM, johnbing wrote: > Hi, > > Please find attached configuration file. NIO_broker_configuration.txt > < > http://activemq.2283324.n4.nabble.com/file/n4671

Re: Statistics Plugin for ActiveMQ broker

I think StatisticsBrokerPlugin class can be used for this purpose. To retrieve stats on the broker send a empty message to ActiveMQ.Statistics.Broker (Queue or Topic) with a replyTo set to the destination you want the stats returned to. But using this I am not sure you can log stats into the log

Configuration of custom plugins with XBeans

Hello, I create my own BrokerPlugin and configured it in activemq.xml like this: http://activemq.apache.org/schema/core"; brokerName="localhost" dataDirectory="${activemq.data}"> http://www.springframework.org/schema/beans"; id="myBrokerPlugin" class="myPackage.MyBrokerPlugin">

Re: NIO transport performance for ActiveMQ

Hi, Please find attached configuration file. NIO_broker_configuration.txt My launcher file contains : max_heap_size = "2700M" max_perm_size = "128M" name = "mqbroker" activemq_jar

PrefetchSize not working as expected

Hi all, we're experiencing some unexpected behavior in ActiveMQ 5.7.0.1 regarding the PrefetchSize. When a client connects to the message queue, all messages are pushed immediately to the client. However, the default is set to 1 in our case, since we've patched the ../transport/stomp/ProtocolConve

[ActiveMQ 5.5.1] - Communication got stuck between Producer and Consumer

I have a product built upon ActiveMQ 5.5.1. System architecture looks like this: - | Central Server ---> Central Broker | -- | Broker A1 <--- A1 |

ActiveMQ 5.8 Message Persistence with LevelDB

Hello I am currently evaluating performance and reliability of ActiveMQ 5.8.0 and LevelDB with Amazon AWS EBS volumes and provisioned IOPS, using the activemq-perftest plugin. Message persistence is of primary importance for my client. When I run my tests with the broker, producer and consumer, I