Re: LevelDB message store for durable subscriber

Hi, Any updates here. Please respond. Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/LevelDB-message-store-for-durable-subscriber-tp4686920p4686955.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

LevelDB message store for durable subscriber

Hi, As mentioned in the advantages of leveldb that "A send to a composite destination only stores the message on disk once." Is this behavior is same for durable subscribers. For ex. If 5 durable subscribers are there on a topic and a persistence messages is sent on it. This message is stored 5 t

Re: How to create multiple subscribers and producers in a application

> I don’t recommend using the same pool for consumers (especially if you use local or XA transactions). The > benefit is pretty minimal, and it can cause issues once you start scaling. So should I use different pooled Connection factory for each listener in my application ? OR should I not at al

Re: javax.jms.InvalidClientIDException for durable subscription on broker restart

Hi, I also have a similar requirement where I want to have multiple durable subscribers and publishers in the same client application connecting to the broker.(broker version 5.10) What should be the correct way to configure the above mentioned case? As Anuj mentioned in last update: 1) I use

Re: How to create multiple subscribers and producers in a application

Hi, And how should I use pooledConnection factory. Should I use different pooled ConenctionFactory for each listener and producer or should I use only one pooled connection factory with maxConnection to required number. I can a see a similar thread http://activemq.2283324.n4.nabble.com/javax-j

How to create multiple subscribers and producers in a application

Hi, I want to create 7 producers and 5 durable consumers in my application connecting to the same broker. I want to use spring Default message listener container to create consumers and JMStemplate to create producers. While reading I am confused about how connection factories should be used. I w

spring 4.0 with ActiveMQ

Hi, Which version of spring does ActiveMQ 5.8 uses ? Spring 4.0 is in the market. When will ActiveMQ be updated to use latest version ? -- View this message in context: http://activemq.2283324.n4.nabble.com/spring-4-0-with-ActiveMQ-tp4680159.html Sent from the ActiveMQ - User mailing list ar

Re: Performance using multikahaDB

We use one destination per store. Why will it span other stores ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Performance-using-multikahaDB-tp4675277p4675870.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Size Limitation for tx.**tmp file

Yes, temp store limit could be used. Thanks for the reply. I will log the JIRA request. -- View this message in context: http://activemq.2283324.n4.nabble.com/Size-Limitation-for-tx-tmp-file-tp4675739p4675772.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Size Limitation for tx.**tmp file

Hi Garry, But there should be a upper limit on the file size because it may be possible that a producer is sending messages using transaction and not able to commit it ( may be because of some issue or may be some code glitches or may be sending stuck in an infinite loop etc.) then it might fill t

Size Limitation for tx.**tmp file

Hi, As discussed http://activemq.2283324.n4.nabble.com/jira-Created-AMQ-4267-Huge-tx-tmp-file-in-the-kahadb-directory-td4662065.html#a4675449 This tmp files gets created when a transaction size has more than 10 MB of messages and got deleted as soon as I commit or rollback the transaction. Is th

Re: Why does connection id use broker host in case of STOMP clients?

Hi ActiveMQ Gods, Could you please share your insights on this? Thanks. -- View this message in context: http://activemq.2283324.n4.nabble.com/Why-does-connection-id-use-broker-host-in-case-of-STOMP-clients-tp4675610p4675684.html Sent from the ActiveMQ - User mailing list archive at Nabble.co

Re: Query about ActiveMQ connection id and client id format

Hi ActiveMQ Gods, Could you please share your insights on this? Thanks. -- View this message in context: http://activemq.2283324.n4.nabble.com/Query-about-ActiveMQ-connection-id-and-client-id-format-tp4671843p4675683.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Query about ActiveMQ connection id and client id format

One more query in addition to the queries in previous posts - My understanding is that client id and durable subscriber name should be specified in order for durable subscription protocol to work fine across broker restart from one host to another. Does the persistent publishing feature also depend

Re: Query about ActiveMQ connection id and client id format

Thanks you very much, Gary. I will specify client id and durable subscriber name explicitly so that broker host is not used in client id. I am working on a setup where a broker will run on the cloud and change location from one host to another on restart. When this happens, the connection id, cli

Re: Why does connection id use broker host in case of STOMP clients?

Could somebody from the ActiveMQ team please respond to these queries: What is the client id and connection id used for? How different is this from durable subscriber id? We are working on a setup where a broker will run on the cloud and change location from one host to another on restart. When th

Re: Query about ActiveMQ connection id and client id format

Could you please help me understand what a connection id and client id is used for in ActiveMQ? Why have two different ids? Are they used for different purposes? I think what Steve was asking here is that the connection id for jms client has client host in it but connection id for stomp client ha

Why does connection id use broker host in case of STOMP clients?

Hi ActiveMQ team, I noticed that ActiveMQ connectionId is constructed based on client host in case of JMS client but uses broker host in case of STOMP clients. Could you please let me know why is this difference in implementation? What is the client id and connection id used for? How different is

Re: Restrict some destinations to get created

I am trying to do this by writing my own plugin and overriding the add_destination() function.. I am throwing exception ( InvalidDestinationException ) here for destinations I want to restrict. And In Jconsole I can see those destinations are not getting created. So is this a fine way to do this

Dynamic producers in jConsole

Hey, When i create a producer, most of the times it goes to dynamic producer bean. What is dynamic producer? In some of the case it comes under topic/ queue bean but most of the times it comes under dynamic producer bean only.. What is dynamic producer ? How it is different from normal produce

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-tp4675316p4675435.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Restrict some destinations to get created

Hi, I have a requirement where I want to restrict a client to create a topic of particular name. I mean as soon as a client is subscribe to a topic, it will automatically created. I want my client not to create topics the way they want. I want to put restriction on topic creation for example I wa

Performance using multikahaDB

Hi, I am using multikahadb persistence adapter. I am creating separate adapter for some destinations ( say for 10) So is there any performance overhead with more number of kahadb adapters ? What should be the ideal number of persistence adapters to avoid any performance issue ? -- View this

Convert Text message to Map message in ActiveMQ

Hi, I have usecase where I am sending a text message from STOMP producer in json format and I am processing that message in a java consumer. I want that message to be converted to a Map message. Is there a way in which ActiveMQ can do this transformation (text message to map message) for me? Plea

Re: Transactions in Stomp

Thank you for this explanation -- View this message in context: http://activemq.2283324.n4.nabble.com/Transactions-in-Stomp-tp4675080p4675214.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Transactions in Stomp

Yes, that is fine. But my question is " Why there is NO message redelivery in case of STOMP transactions (like JMS transactions have) ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Transactions-in-Stomp-tp4675080p4675211.html Sent from the ActiveMQ - User mailing li

Re: Transactions in Stomp

Thanks, I am just little bit confused in case of CLIENT_ACK mode in STOMP transaction. At consumer side, When consumer is running and throwing exception while processing the message (consumer doesn't stop, it keeps on running), there is no redelivery of message. Even if i uses transactions the

Re: Transactions in Stomp

and what happens in case of NACK ( the first question) ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Transactions-in-Stomp-tp4675080p4675103.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Transactions in Stomp

In addition to the last question.. As specified on the page http://activemq.apache.org/how-do-i-unack-the-message-with-stomp.html -How to receive the message in transactions using CLIENT_ACK connection.begin("tx3"); frame = connection.receive(); System.out.println(fram

Transactions in Stomp

Hi, I am trying to use transactions in Stomp (Python & perl). I have already gone through http://activemq.apache.org/how-do-i-unack-the-message-with-stomp.html As specified in the page that there is no redelivery in case of stomp. But what happens if a consumers receives a message and send NACK t

Re: Does KahaDB stores Unacknowledged messages. ?

To be specific in last post., Not messages !! I am talking about acknowledgement received by broker after successful consumption. -- View this message in context: http://activemq.2283324.n4.nabble.com/Does-KahaDB-stores-Unacknowledged-messages-tp4674991p4675034.html Sent from the ActiveMQ - U

Re: Does KahaDB stores Unacknowledged messages. ?

And what about acknowledgements ? I mean whatever acks are coming to broker, are those acks kept in DB only ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Does-KahaDB-stores-Unacknowledged-messages-tp4674991p4675033.html Sent from the ActiveMQ - User mailing list arc

Re: Transactions to receive batch messages using spring

I was exploring this thing and found a way to achieve the above requirement. -- BatchMessageListenerContainer But I am not able to understand how to use this in spring ? Can someone help me here ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Transactions-to-recei

Does KahaDB stores Unacknowledged messages. ?

Hey, I am using ClLIENT_ACK mode for my consumer. And explicitly acknowledging the message. I just want to know that before acknowledging the messages where are those messages kept ? I mean to say, if I got some exception while processing the message and not able to acknowledge the message, where

Spring's CachingConnectionFactory vs ActiveMQ's PooledConnectionFactory

Hi, I'm new to JMS, can somebody please tell me differences between the Spring's CachingConnectionFactory vs ActiveMQ's PooledConnectionFactory? Which is suited for which use case? Benefits ? Drawbacks. Many thanks in advance! Thanks, Sophia -- View this message in context: http://activemq.22

Re: Transactions to receive batch messages using spring

Yes, there is no documentation provided by ActiveMQ, to use batch message receiving.. Please help !! -- View this message in context: http://activemq.2283324.n4.nabble.com/Transactions-to-receive-batch-messages-using-spring-tp4674908p4674933.html Sent from the ActiveMQ - User mailing list archi

Re: Transactions in ActiveMQ

Ping !! Please respond.. -- View this message in context: http://activemq.2283324.n4.nabble.com/Transactions-in-ActiveMQ-tp4674759p4674932.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Transactions in ActiveMQ

I have tried using CLIENT_ACK on consumer side in my test applications using spring. here is what I have changes in config file: My observations are below: When consumer throws exception in "on_message()" those messages are considered as inflight count. After that if I stop the consumer

Re: Transactions to receive batch messages using spring

I also have similar requirement to commit the session after receiving some bunch of message(using spring only), what should I do ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Transactions-to-receive-batch-messages-using-spring-tp4674908p4674909.html Sent from the Act

Re: Transactions in ActiveMQ

So does it mean that I cannot get redelivery of messages by using CLIENT_ACK ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Transactions-in-ActiveMQ-tp4674759p4674907.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Activemq generic jms pooledConnectionFactory

Does ActiveMQ PooledConnectionfactory have any advantage over generic jms-pool https://github.com/apache/activemq/blob/trunk/activemq-jms-pool/src/main/java/org/apache/activemq/jms/pool/PooledConnectionFactory.java

Re: Transactions in ActiveMQ

Please help me out here... I am not able to proceed further in my work without these explanations. -- View this message in context: http://activemq.2283324.n4.nabble.com/Transactions-in-ActiveMQ-tp4674759p4674864.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Batch message sending with JmsTransactionManager of Spring?

Ping !! Waiting for someone to respond... -- View this message in context: http://activemq.2283324.n4.nabble.com/Batch-message-sending-with-JmsTransactionManager-of-Spring-tp4291842p4674863.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Batch message sending with JmsTransactionManager of Spring?

I also want to know.. using spring how can i send a batch of messages and commit after it while using transaction ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Batch-message-sending-with-JmsTransactionManager-of-Spring-tp4291842p4674824.html Sent from the ActiveMQ -

Re: Transactions in ActiveMQ

Thanks for your response, Will you please let me know something about my first post regarding Client Acknowledgement Vs Transactions ? --> "I have a requirement where I am confused between transactions and Explicit acknowledgement. The requirement is: When a consumer receives a message it do some p

Re: Transactions in ActiveMQ

In addition to above reference.. When we use Client Ack mode, We specify it while creating the sessions. So to use Client Ack, do we need to specify this on both producer and consumer side ? if yes, how differently it works for producer and consumer ? -- View this message in context: http://a

Re: Transactions in ActiveMQ

Thanks for your response gary. I have a requirement where I am confused between transactions and Explicit acknowledgement. The requirement is: When a consumer receives a message it do some processing with the message before acknowledging the message. And while processing the message it could get s

Transactions in ActiveMQ

Hey, I want to read about ActiveMQ transactions in detail, I have already googled it but found not much other than http://activemq.apache.org/should-i-use-transactions.html http://activemq.apache.org/how-do-transactions-work.html So if there is some blog or any thing is there, please help me. I

Re: Plugins do not get initialized for failover broker

Hey, I have gone through https://issues.apache.org/jira/browse/AMQ-4867 So it says if I want to monitor my failover broker I need to start in a separate way(not the plugin way) So Can you tell where I could start this monitoring thing in configuration file ? I mean to say.. where could I use my be

Re: Logging a message for Multi kahaDB

I tried enabling DEBUG level logging but it is not logging for destinations in persistence store. I want to log for messages, which persistence store they are going into. -- View this message in context: http://activemq.2283324.n4.nabble.com/Logging-a-message-for-Multi-kahaDB-tp4674011p4674524.

Re: Logging a message for Multi kahaDB

waiting for a response... -- View this message in context: http://activemq.2283324.n4.nabble.com/Logging-a-message-for-Multi-kahaDB-tp4674011p4674317.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Plugins do not get initialized for failover broker

Hi, I am using ActiveMQv5.8. I want to initialize the plugins in the failover broker. The problem is that the plugin is not initialized until the failover broker takes over and becomes primary. Can some configuration be added to make this work ? Thanks, Sophia -- View this message in context

Re: Logging a message for Multi kahaDB

Hey, can someone help me here.. I want to log the store file where a message is going in case of Multi kahaDB -- View this message in context: http://activemq.2283324.n4.nabble.com/Logging-a-message-for-Multi-kahaDB-tp4674011p4674168.html Sent from the ActiveMQ - User mailing list archive at Na

Message send to DLQ

Hey, Please correct me if I am wrong... When a message is expired, it is sent to the DLQ by default. And before sending it to DLQ, it's expiration time is set to '0' which means message never expires and also it is converted to a persistence message, even if it is non persistence. Thank You, S

Re: Logging a message for Multi kahaDB

Hey, Sorry about not writing the clear question. Yes !! For each message that comes in to the broker, I want to log which store file it goes in to ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Logging-a-message-for-Multi-kahaDB-tp4674011p4674065.html Sent from th

Logging a message for Multi kahaDB

Hi, I am using multi kahaDb in my broker. I am filtering kahadb files for some destinations and rest other are going to the default folder. I want to log for each message that in which Kahadb folder it is going. Is there a way to log this information ? Thanks, Sophia -- View this message in

Re: Message Expiration thorugh broker

Thank you Gary :) -- View this message in context: http://activemq.2283324.n4.nabble.com/Message-Expiration-thorugh-broker-tp4672873p4674010.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Message Expiration thorugh broker

Sorry for the late reply... Actually I don't want to use TimeStampPlugin because it also set JMS Client's timestamp on the message with a broker timestamp according to the broker's clock. I don't want to disturb the time stamp which is set by the producers. So I thought that I can write my own pl

Re: Changes to user name and password in ConnectionInfo not working

Thanks Christian. I tried that but that didnt work as well. Perhaps, the state of the connection is lost and I have to create producer/consumer again. On a related note: The weird thing is the user name and pass word is changed in ConnectionInfo/ActiveMQConnection (I confirmed this by logging) b

Changes to user name and password in ConnectionInfo not working

Hi there, I am seeing a strange issue. I am using a TransportListener to detect transport interrupted events and when this happens, I am changing the user name and password in ActiveMQConnectionFactory as well as in the ActiveMQConnection.getConnectionInfo() objects (using setUserName and setPassw

memory limit of broker reached. (Fast producer)

Hi, I am using ActiveMQ v5.8. I am trying to exhaust my broker memory usage which are specified here--

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: Discarded messages and Expired messages.

So if discardingDLQBrokerPlugin discard the message before sending to DLQ,. I have also seen the same functionality by--> So what is the difference between both of them ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Disc

Re: Discarded messages and Expired messages.

Thanks for the reply, So as the page that you mentioned says "discardingDLQBrokerPlugin" allows the configuration of queues and topics to drop messages that have been sent to the DLQ. But when I see the source code of this plugin it looks like it discard message before sending to DLQ. As soon as

Re: Message Expiration thorugh broker

Thanks for the reply, Time Stamp plugin can be used but it is creating some other problem for my broker, So is there another way to delete such messages. Can I use http://activemq.apache.org/delete-inactive-destinations.html ? -- View this message in context: http://activemq.2283324.n4.nabbl

Re: Discarded messages and Expired messages.

Waiting for someone from activeMQ dev to reply... -- View this message in context: http://activemq.2283324.n4.nabble.com/Discarded-messages-and-Expired-messages-tp4673025p4673049.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Discarded messages and Expired messages.

Hi, I have questions regarding Discarded messages. 1. I am getting little confused about discarded messages. I searched for discarded message and got to know that -- In case of slow consumer when we are using pending message limit strategy, old messages are discarded as new messages come in. So

Message Expiration thorugh broker

Hi, Is it possible to set message expiration time for broker. Producer can specify time to live for a message and after that time it will expire. But if a producer does not specify expiration time, then all unconsumed messages will always be there in kahadb. Is there a way by which broker can exp