Re: ActiveMQ replicated leveldb update ordering with zookeeper.

Hi, I was checking the source code of ActiveMQ and found this (MasterElector,scala): // Do we need to elect a new master? if (elected == null) { // Find the member with the most updates. va

Re: ActiveMQ replicated leveldb update ordering with zookeeper.

Did anyone get a chance to look at this ? -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-replicated-leveldb-update-ordering-with-zookeeper-tp4686932p4687014.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: paranoid check and verify checksum configuration for levelDB

Tim, How come "paranoid check and verify checksum " parameters are related to leveldb and not activemq. These parameters are mentioned http://activemq.apache.org/leveldb-store.html but only with one line. No detailed documentation is provided. Same with all other parameters. If we want to explore

Re: ActiveMQ replicated leveldb update ordering with zookeeper.

Please respond . -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-replicated-leveldb-update-ordering-with-zookeeper-tp4686932p4686961.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: paranoid check and verify checksum configuration for levelDB

Really confuse between both the parameters. Can someone help me here ? -- View this message in context: http://activemq.2283324.n4.nabble.com/paranoid-check-and-verify-checksum-configuration-for-levelDB-tp4686923p4686956.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

sync option in replicated leveldb configuration

I want to understand the "sync" option for leveldb replication. Default is quorum_mem. Does it mean if I set this value to local_mem : The producer who sending the message will get acknowledgement after storing in local memory(synchronously) and after this only the master broker will send this

ActiveMQ replicated leveldb update ordering with zookeeper.

Hi, 1. Updates from master to slaves are sequential or parallel ? If sequential , does master randomly choose a slave each time or is there some order in which message will go (like master->slave1 and than master->slave2). 2. How zk communicate with each broker and in what interval ? As mention

paranoid check and verify checksum configuration for levelDB

Hi, I have gone through http://activemq.apache.org/leveldb-store.html. What is paranoid check and difference between paranoid check and verify checksum ? What is the overhead of enabling these configuration ? Thanks, Steven -- View this message in context: http://activemq.2283324.n4.nabble.

Re: ActiveMQ pooled Connection Factory for multiple durable subscribers

FYI: This is how my configuration looks like: ${mybroker.url} and my listener is using it as:

ActiveMQ pooled Connection Factory for multiple durable subscribers

Hi ActiveMQ Gods, I am trying to implement a scenario where I have to create multiple durable subscribers in the same application. I want to use spring default messages listener container with ActiveMQ pooled connection factory where "maxConnection" specified to the required number of connections.

Re: Multiple persistence adapters using levelDB

Sorry for the late reply, I think a little confusion here.. I am going to use levelDB only (No kahaDB). But my question is : Is there any support in levelDB so that I can create multiple persistence adapters ? For example: one persistence directory for topic "A" and one for topic "B" and rest

Re: Many connections from the same client

Please respond... -- View this message in context: http://activemq.2283324.n4.nabble.com/Many-connections-from-the-same-client-tp4675316p4675462.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Jconsole Topic and Queue

Hi I am, able to reproduce the behaviour.. I am creating a destination using wildcards (abcd.>) This destination is coming as without yellow sign always and it only has consumer attribute... I also have an observation... as s

Re: Many connections from the same client

No. there is no firewall -- View this message in context: http://activemq.2283324.n4.nabble.com/Many-connections-from-the-same-client-tp4675316p4675436.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Wildcards in ActiveMQ

Hi I am using AmqV5.8 I am trying to create a topic with name "a.*" but when I see in jconsole it shows it as "a.*" Why ? Another thing is What is the difference between wildcards (*) and (>) ? Thanks -- View this message in context: http://activemq.2283324.n4.nabble.com/Wildcards-in-Activ

Re: Many connections from the same client

Please respond...!! -- View this message in context: http://activemq.2283324.n4.nabble.com/Many-connections-from-the-same-client-tp4675316p4675351.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Many connections from the same client

Hey, I am using Default messages listener container (DMLC) for my consumer. and using pooled connection factory to create connection. But I am seeing my client is creating more than 100 connections at a time. Not able to understand why this is happening... I also checked the logs and found this m

Multiple persistence adapters using levelDB

Hey, Can I use multiple persistence adapters using level-DB similar to multikahadb. In multikahaDB we can create separate persistence adapters for a topic. Is there any way to do this in level DB ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Multiple-persistence-a

Re: Subscribe to multiple topics

Hi, Can anybody from ActiveMQ developers clear this?? Waiting for response Thanks, Steven -- View this message in context: http://activemq.2283324.n4.nabble.com/Subscribe-to-multiple-topics-tp4674684p4674988.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Subscribe to multiple topics

Hi, Why nobody from activemq is responding here. If activemq does not provide a way for subscribers to subscribe to multiple topics, it would be good idea to have it. If you say composite destinations work for subscribers also. Please provide a link to an example which demonstrate *how to subscribe

Use composite destination for consumer using spring jms

Hi, Is there way to use composite destinations to subscribe to multiple topics using spring jms? I am able to use send messages to multiple topics using spring jms. Can anybody confirm if it is possible to use composite destinations to subscribe to multiple topics using spring jms or is there any

Re: Subscribe to multiple topics

Can anybody tell how to use composite destinations for subscriber using spring jms? If it is not possible then is using multiple DMLC only way to subscribe to multiple topics? Will using multiple DMLC overload the application? I am really stuck here. Thanks, Steven -- View this message in con

Re: Subscribe to multiple topics

The link you provided gives a 404 error. When I use testTopic with producer it sends messages on both topics but when I use this with a consumer, it consumes messages from only one topic. I am using spring's DefaultMessageListenerContainer to listen for messages and jmsTemplate to send messa

Re: Plugins do not get initialized for failover broker

I also have similar requirement where I wrote a java class to monitor my broker and some other stuff. I want to run it with broker (other than plugin way) How should I do it ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Plugins-do-not-get-initialized-for-failover-brok

Re: Subscribe to multiple topics

Hi, 1. I can't use wild cards because my topics doesn't follow any specific pattern like topic.A, topic.B. They can be anything. There is another problem with this approach. Say I use a wildcard topic.* to receive from topic.A and topic.B only. But if someone publishes on topic.X I will receive tho

Subscribe to multiple topics

Hi, I have a requirement where I want to *subscribe to multiple activemq topics. What is the best way to do this?* I have tried using multiple DMLC but I get following error: org.springframework.jms.listener.DefaultMessageListenerContainer#refreshConnectionUntilSuccessful 875 WARN] - Could not ref

Re: Logging a message for Multi kahaDB

I also have the same requirement. Is there a way to log for each message, which store file it goes into ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Logging-a-message-for-Multi-kahaDB-tp4674011p4674208.html Sent from the ActiveMQ - User mailing list archive at Nabbl

Re: addConnection vs addSession

Thanks. Yes, I saw that plugin. But i am still curious -- when should anybody ever use addSession()? How is it different from addConnection(). -Steve -- View this message in context: http://activemq.2283324.n4.nabble.com/addConnection-vs-addSession-tp4673828p4673884.html Sent from the ActiveM

addConnection vs addSession

Hi ActiveMQ team, Could somebody please explain the difference between addConnection and addSession in the broker plugins. I want to intercept the first call from client to broker and use that for some handshake and authentication. I am wondering what I could possibly use. What's the difference b

Re: ExceptionListener not getting fired on the client side when using JmsTemplate

Hi Christian, Did you get a chance to look at this? Could you please help? Also, is there any way in ActiveMQ to detect connection breakages with broker. That is, whenever the broker goes down, I would like to perform some task on the client side immediately and I need to detect this reliably. I

Re: ExceptionListener not getting fired on the client side when using JmsTemplate

Thanks Christian. Yes, I do see the exception in my logs which I had already mentioned in my first post in this thread. I wanted to handle all exceptions in a generic way in ExceptionListener instead of handling async and sync exceptions differently. Is there any support in ActiveMQ to get callback

Re: ExceptionListener not getting fired on the client side when using JmsTemplate

This issue seems to be happening even if I use the raw ActiveMQ API instead of using the Spring's JmsTemplate. If I just set ExceptionListener on the ActiveMQ connection or connectionfactory, it is not getting invoked for exceptions as part of ActiveMQConnection.start(). It looks to me from the co

ExceptionListener not getting fired on the client side when using JmsTemplate

Hi, I have a custom plugin on the broker side which throws an exception in some cases from addConnection. I would like to handle this exception on the client side. My client uses JmsTemplate for sending messages. I am using ActiveMQConnectionFactory.setExceptionListener to set a listener but this

Re: ExceptionListener not getting fired on the client side when using JmsTemplate

This is what I am doing: public class ActiveMQAuthConnectionFactory extends org.apache.activemq.ActiveMQConnectionFactory { private static class AMQExceptionListener implements ExceptionListener { @Override public void onException(JMSException exception) {

Re: Jconsole Topic and Queue

Yellow box thing is fine but for some topics attributes, operation and consumer are there but for some topic only consumers are there. Why this behavior is different for some of the topics ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Jconsole-Topic-and-Queue-tp467279

Pattern in Jconsole

Hey, I am seeing this uncommon behaviour in Jconsole, Some of the topics are without yellow sign( doesnot have attributes and oprations) and some are with that sign( So have attributes and operations). Screen shot is provided below:

Re: Jconsole Topic and Queue

hey, I have also seen the same pattern, not with the queues and topics, but with other Mbeans. see below snapshot: -- View this message in context: http://activemq.2283324.n4.nabble.com/Jconsole-Topic-and-Queue-tp4672799p46731

Re: Jconsole Topic and Queue

I don't know why nobody is responding here. Waiting... -- View this message in context: http://activemq.2283324.n4.nabble.com/Jconsole-Topic-and-Queue-tp4672799p4673182.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Jconsole Topic and Queue

Hey, My work is stucked here. Can someone from ActiveMQ dev team will help me ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Jconsole-Topic-and-Queue-tp4672799p4673155.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Jconsole Topic and Queue

Hey, Waiting for a response... -- View this message in context: http://activemq.2283324.n4.nabble.com/Jconsole-Topic-and-Queue-tp4672799p4673139.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Jconsole Topic and Queue

Hey, Sorry for the delay. Please find "jconsole.png" and "jconsole1.png" screenshots. "jconsole.png": Here as we can see some topics like "seed.intrestShortFall" "seed.newPnlSpn" etc are not starting with yellow sign while others are. "jconsole1.png": Here when i clicked those mbeans to get the

Re: Use case of http transport connector

Ping. Help please! -- View this message in context: http://activemq.2283324.n4.nabble.com/Use-case-of-http-transport-connector-tp4672325p4672859.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Jconsole Topic and Queue

Hi, I am using ActiveMQ 5.8.0. I am monitoring my broker using JConsole. I am seeing some uncommon behavior in jconsole in MBeans Mbeans-->org.apache.activemq-->Broker-->StevenBroker-->Topic--> " Here some of the topics are with yellow sign at the starting and some are not" and all the queues here

Re: Use case of http transport connector

Can someone tell me here where is XML coming here in between HTTP and openwire. It will be a very helpful for my project. -- View this message in context: http://activemq.2283324.n4.nabble.com/Use-case-of-http-transport-connector-tp4672325p4672725.html Sent from the ActiveMQ - User mailing list

Re: Use case of http transport connector

Thanks a lot for these replies. >> The binary open wire format is translated into text encoded Http posts. Sorry, I am slightly confused. You mentioned message is first coverted to openwire binary format and then to text messages to that it can be sent over HTTP. Where is XML coming here? Is it t

Re: Use case of http transport connector

Hey, Can someone answer my queries, it will be a big help. Please someone explain me about openwire and http protocol communication in ActiveMQ. Thanks, Steven -- View this message in context: http://activemq.2283324.n4.nabble.com/Use-case-of-http-transport-connector-tp4672325p4672633.html

Re: Use case of http transport connector

In addition to below post I also want to add some queries while using http transport. 1. The HTTP transport is used to tunnel over HTTP(hypertext transfer protocol) using XML payloads. http transport uses openwire, which operates in binary format while http protocol don't understand binary data. S

Use case of http transport connector

Hi, I am currently running my broker using TCP transport connector. I am trying to use http transport connector for my broker, it is working properly, Currently I am running it for local java producer and consumer. I am not able to figure out when and in what cases we should use http transport con

Use case of http transport connector

Hi, I am currently running my broker with TCP transport connectors. I have also tried using http transport connector for java producers and consumers, it is working fine. But didn't get any useful scenario to use http transport connector, Can someone give me some use cases where it is useful and m

Re: Statistics Plugin for ActiveMQ broker

Hey Christian, I have some questions regarding StatisticsBroker -- 1. We are calculating subscriber stats in the class, Why not publisher Stats ? 2. Can you please tell me the overhead for collecting stats, would it have big impact on performance of ActiveMQ. 3. Is StatisticsBroker class thread s

Re: Query about ActiveMQ connection id and client id format

Hi ActiveMQ team, Could somebody please help me here? Thanks for your support! -- View this message in context: http://activemq.2283324.n4.nabble.com/Query-about-ActiveMQ-connection-id-and-client-id-format-tp4671843p4671878.html Sent from the ActiveMQ - User mailing list archive at Nabble.com

Re: NIO transport performance for ActiveMQ

Hi, I would also like to see if there are any performance/throughput benchmarks available especially comparing ActiveMQ TCP vs ActiveMQ NIO performance. I would presume ActiveMQ developers may have done some benchmarks -- it would be really useful if you could share the results. I understand these

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

Statistics Plugin for ActiveMQ broker

Hi, I am trying to use statistical Plugin for ActiveMQ broker to get the broker stats into the log file. But I am not able to find any access methods or APIs by which I can log these stats. I have checked org.apache.activemq.plugin.StatisticsBroker for this but it is use to send these stats to the

Statistics Plugin for ActiveMQ broker

Hi, I am trying to use statistical Plugin for ActiveMQ broker to get the broker stats into the log file. But I am not able to find any access methods or APIs by which I can log these stats. I have checked org.apache.activemq.plugin.StatisticsBroker for this but it is use to send these stats to the

Re: NIO transport performance for ActiveMQ

Hey ceposta, Why nio reduces number of threads for large number of connections and not for small number, I think major advantage of nio transport is that it does not create one thread per connection as TCP does. So i think even if there are 5 clients it should reduce number of threads. Another thi

Re: NIO transport performance for ActiveMQ

Hey john, I think configurations are fine, not sure why threads are not reducing. Even I am using the same configuration but not saw any improvement in throughput. Can Someone from developers team help me with this. Thanks, Steven -- View this message in context: http://activemq.2283324.n4.n