Re: "allowLinkStealing" as a client configuration

I also faced this issue. I am using ActiveMQv5.14. Steps to reproduce: * Connect a durable consumer with some client-id say CLIENT1 * Start another durable consumer with same client-id (CLIENT1) * Stop the first consumer. We expected that second consumer should get connected automatically bu

Disk space filled up on destroying a topic

I tried to destroy a topic with durable subscriber. Persistent message for this topic jumped from 1.1G to 11G suddenly. My question here is when I have specified limit of 8G on persistence then how does it filled till 11G. -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f23418

Exception occurred while processing a command: javax.jms.JMSException: Unmatched acknowledge

Hi, I am getting following warning from ActiveMQ logs. Can you please help me understand what could have caused this and what is the resolution for this. I am using ActiveMQ5.14.4. [org.apache.activemq.transport.stomp.ProtocolConverter#handleException 283 WARN] - Exception occurred while pr

Exception occurred while processing a command: javax.jms.JMSException: Unmatched acknowledge

Hi, I am getting following warning from ActiveMQ logs. Can you please help me understand what could have caused this and what is the resolution for this. I am using ActiveMQ5.14.4. [org.apache.activemq.transport.stomp.ProtocolConverter#handleException 283 WARN] - Exception occurred while proc

Connection reset by peer warning without useful info.

failed: java.io.IOException: Connection reset by peer* Is there a way to add other information in this error log, like client id, connection id, destination name. This can help in identifying which client connection had some problem. --bansalp -- View this message in context: http://activemq

Large difference for (dequeue + inflight) and dispath counter for queue.

I am seeing following values via jmx Enqueue 24791 Dequeue 24861 Dispath 321058 Inflight 15 These values are for a queue with concurrent consumer. Here Dispath count is way greater than enqueue as well as dequeue count. What could be reason for this? I am using ActiveMQ 5.11.1. -

ActiveMQ TotalConsumerCount gives incorrect value.

this Advisory topic but ConsumerCount is just 5. Can somebody help with why these counters are behaving strangely. P.S. I have disabled advisory. --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-TotalConsumerCount-gives-incorrect-value-tp4694255.html

Re: Clarification regarding broker statistics in jconsole

I am also facing problem with these counter. I can see following values TotalConsumerCount = 1185 TopicSubscriberCount = 736 TotalDurableConsumerCount = 55 QueueSubscriberCount = 799 InactiveDurableTopicSubscribers = 18 TemporaryQueueSubscribers = 0 TemporaryTopicSubscribers = 0 736 + 55 + 799

ActiveMQ and Selector

queue. Shouldn't other messages be allowed to go through? --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-and-Selector-tp4693442.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ broker is stopping after it is unable to destroy inactive durable subscriber.

Hi We are facing this problem again. In our setup we run activemq primary and failover broker, previously this issue happened with primary broker and failover took over properly. Today this same issue happen again with failover broker. Can somebody help here on why is this happening. -- View

Re: ActiveMQ broker is stopping after it is unable to destroy inactive durable subscriber.

ping. -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-broker-is-stopping-after-it-is-unable-to-destroy-inactive-durable-subscriber-tp4691703p4691755.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ broker is stopping after it is unable to destroy inactive durable subscriber.

Hi, I am getting following error and unable to figure out why is this happening. Can anyone please help? I am using ActiveMQ5.10. --bansalp [20150217 13:43:39.366 EST (ActiveMQ Durable Subscriber Cleanup Timer) org.apache.activemq.broker.region.TopicRegion#doCleanup 92 INFO] - Destroying

Using audit log with Activemq 5.10.0

log ### log4j.additivity.org.apache.activemq.audit=false log4j.logger.org.apache.activemq.audit=INFO, audit --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com/Using-audit-log-with-Activemq-5-10-0-tp4691239.html Sent from the ActiveMQ - User mailing list

Information about messages replayed from a Virtual Topic to a Consumer Queue?

Hi, I am trying to use Virtual Topic, but I noticed that messages forwarded to Consumer Queues are not added to dispatch counter of Virtual Topic. So if Topic VirtualTopic.A produces 100 messages and there are two subscribers SubA and SUBB and a consumer queue Consumer.consA.VirtualTopic.A. Then

Re: Send large message using STOMP producer to ActiveMQ broker.

ping!!! -- View this message in context: http://activemq.2283324.n4.nabble.com/Send-large-message-using-STOMP-producer-to-ActiveMQ-broker-tp4690095p4690454.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Query related to activemq-data directory

(failover) running(independent) (on network) using same network drive, so in this case what would be this temp directory? Where would it be created? Will there be any issue if this is same for all three brokers? --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com

Re: Stats for Virtual Topic

What I mean is there is no indicator if I change defaults. All I can do is remember all topics which I have configure as virtual along with their consumer queue. -- View this message in context: http://activemq.2283324.n4.nabble.com/Stats-for-Virtual-Topic-tp4690237p4690309.html Sent from the A

Re: Stats for Virtual Topic

In Jconsole, there is nothing which says anything about virtual destination. It will all topics and queues as normal only. There is no distinguishing factor. -- View this message in context: http://activemq.2283324.n4.nabble.com/Stats-for-Virtual-Topic-tp4690237p4690287.html Sent from the Activ

Re: Stats for selector

Can this be done from java code. I am extending BrokerPluginSupport to log certain stats related to broker and per destination stats. -- View this message in context: http://activemq.2283324.n4.nabble.com/Stats-for-selector-tp4690236p4690264.html Sent from the ActiveMQ - User mailing list arch

Re: Stats for Virtual Topic

Stats like - List of topics which are virtual. - which all queue are consumer queue for each virtual topic. - Message size and count related stats for consumer queue. - Any other stats that is exposed. -- View this message in context: http://activemq.2283324.n4.nabble.com/Stats-for-Virtual-To

Re: Send large message using STOMP producer to ActiveMQ broker.

[20150122 13:06:44.729 IST (ActiveMQ Transport: tcp:///ip:41961@61613) org.apache.activemq.transport.stomp.ProtocolConverter#handleException 280 WARN] - Exception occurred processing: null ^@: org.apache.activemq.transport.stomp.ProtocolException: The maximum data length was exceeded [20150122 1

Re: Send large message using STOMP producer to ActiveMQ broker.

I added following config and tried to send a messaage of 150 MB, it failed with following message Failed to send the message on '/queue/testDSize.0' (error: *** Net::STOMP::Client::IO::send_data(): cannot syswrite(): Broken pipe); will try to failover and resend [20150122 16:05:26.335 XYZ::Net::

Re: SelectorAware feature of Virtual Topic

ping -- View this message in context: http://activemq.2283324.n4.nabble.com/SelectorAware-feature-of-Virtual-Topic-tp4690112p4690238.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Stats for Virtual Topic

I have started using virtual topic in myActiveMQ setup and I was wondering if there are any stats available for virtual topic which I can log. --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com/Stats-for-Virtual-Topic-tp4690237.html Sent from the ActiveMQ - User

Stats for selector

Hi I am using ActiveMQ 5.10.0 and some of consumer in my setup are using selector. Are there statistics present for selector which I can log? --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com/Stats-for-selector-tp4690236.html Sent from the ActiveMQ - User

SelectorAware feature of Virtual Topic

Hi, I am using VirtualTopic. I have a use case where I need to have a selector on Consumer queue. As all message sent to topic are forwarded to queue and as not all messages will get consumed from queue because of selector criteria, queue will fill up. Is there a way to avoid that? Can selectorAw

Re: What all jars are required to run ActiveMQ client and what all jars are included in ActiveMq-all jar

Thanks this solved my problem. -- View this message in context: http://activemq.2283324.n4.nabble.com/What-all-jars-are-required-to-run-ActiveMQ-client-and-what-all-jars-are-included-in-ActiveMq-all-jar-tp4689651p4690111.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: What all jars are required to run ActiveMQ client and what all jars are included in ActiveMq-all jar

Thanks this solved my problem. -- View this message in context: http://activemq.2283324.n4.nabble.com/What-all-jars-are-required-to-run-ActiveMQ-client-and-what-all-jars-are-included-in-ActiveMq-all-jar-tp4689651p4690110.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: What all jars are required to run ActiveMQ client and what all jars are included in ActiveMq-all jar

I am unable to figure out whether clients need activemq-openwire-legacy jar or not. Could you please help? -- View this message in context: http://activemq.2283324.n4.nabble.com/What-all-jars-are-required-to-run-ActiveMQ-client-and-what-all-jars-are-included-in-ActiveMq-all-jar-tp4689651p46900

Send large message using STOMP producer to ActiveMQ broker.

Hi I need to send large message (>100 MB) using stomp producer. Is there a way to do this without fragmenting messages. Currently am able to send messages with size < 100 MB only. Thanks, Pradeep -- View this message in context: http://activemq.2283324.n4.nabble.com/Send-large-message-usin

Re: What all jars are required to run ActiveMQ client and what all jars are included in ActiveMq-all jar

Reason I want is because I want to use only those jars which arre absolutely necessary for clients, like activenq-broker.jar activemq-kahadb.jar and all are not required for clients. I am able to run both topics and queue consumer producer (with possible combination of durable nondurable persisten

Re: What all jars are required to run ActiveMQ client and what all jars are included in ActiveMq-all jar

I have no experience with Maven, but if I setup a maven project and include activemq-client jar then after successful run is there a way to see which all jar have been downloaded by maven ? -- View this message in context: http://activemq.2283324.n4.nabble.com/What-all-jars-are-required-to-ru

What all jars are required to run ActiveMQ client and what all jars are included in ActiveMq-all jar

Hi, ActiveMQ comes with lots of JAR. I want to know what all jars are included in activemq-all-5.10.0.jar. What all jars are required/necessary to run an activemq client (producer/consumer)? Thanks -- View this message in context: http://activemq.2283324.n4.nabble.com/What-all-jars-are-requi

Re: Using Same persistent store for storing message of virtual topic and its consumer queue.

Thanks for the quick reply. -- View this message in context: http://activemq.2283324.n4.nabble.com/Using-Same-persistent-store-for-storing-message-of-virtual-topic-and-its-consumer-queue-tp4689648p4689650.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Using Same persistent store for storing message of virtual topic and its consumer queue.

Hi, I am using Multi level Kahadb. Will there be any problem like duplicate message to a client if I use same store for virtual topic and its consumer queue? Thanks, Pradeep -- View this message in context: http://activemq.2283324.n4.nabble.com/Using-Same-persistent-store-for-storing-message

Selector and Virtual Topic

from queue slow? --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com/Selector-and-Virtual-Topic-tp4689544.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Persistent message and selectors

r criteria get stored? *Queue:* Producer is sending persistent message to a queue "B" and consumer is consuming using selector on queue "B". Now will all message send on "B" get stored in persistent store or only message which matches selector criteria get stored?

Will using virtual topic effect my current setup of ActiveMQ?

topic act normal for its subscriber, will there by any effect on its normal subscriber? 3. If I delete Consumer queues for virtual topic will there be any effect? Thanks, --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com/Will-using-virtual-topic-effect-my-current

Load balancing on a topic

Hi, My use case is I have a producer producing on topicA and there are 10 consumer on it. I want 5 of them get message normally and for remaining 5 only one of them get this message. Is there a way to achieve this functionality without making any broker side change. Can this be achieved using sel

Re: CurrentConnectionsCount seems to give incorrect value.

If these were to be all the connection ever made then lsof won't show these connection + there is one counter for that TotalConnectionsCount and its value is way higher than value returned by 2nd or 3rd command as it do count for all the connections ever made to broker. -- View this message in

CurrentConnectionsCount seems to give incorrect value.

Hi, There is a difference of some 40 odd connection between value provided by current connections count and what I get by using lsof command and by counting individual connection count from activemq admin command. 1. CurrentConnectionsCount: activemq-admin query --view CurrentConnectionsCount --

Re: ActiveMQ exception : "Failed to browse Topic"

I am facing similar issue with ActiveMQ 5.10. My question at Stackoverflow . Can somebody help me here? It seems to be a old bug which is supposed to get fix as part of this

Re: Get Number of connection from all host to my activemq broker.

Thanks Tim, This is really resourceful, I will try this. Thanks, --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com/Get-Number-of-connection-from-all-host-to-my-activemq-broker-tp4687405p4687459.html Sent from the ActiveMQ - User mailing list archive at

Re: Get Number of connection from all host to my activemq broker.

Can you please guide me on how can this be achieved using JMX api. (for now lets forget whether values are right or wrong). Thanks, --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com/Get-Number-of-connection-from-all-host-to-my-activemq-broker-tp4687405p4687430

Re: Get Number of connection from all host to my activemq broker.

I can get currentConnection count using activemq-admin query --view CurrentConnectionsCount jmxurl... But I want number of client from each host as well. Thanks, --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com/Get-Number-of-connection-from-all-host-to-my

Get Number of connection from all host to my activemq broker.

*activemq-admin*. Thanks, --bansalp -- View this message in context: http://activemq.2283324.n4.nabble.com/Get-Number-of-connection-from-all-host-to-my-activemq-broker-tp4687405.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Is there a way to get kahadb size using activemq-admin command line tool?

Putting answer from stackoverflow community (Erik Williams) as it might be of some help for someone in future. activemq-admin query --view StorePercentUsage,StoreLimit --jmxurl service:jmx:rmi:///jndi/rmi://hostname:port/jmxrmi --jmxuser user --jmxpassword password Thanks, Pradeep -- View th

Re: Is there a way to get kahadb size using activemq-admin command line tool?

I have checked using jconsole that it do expose some bean saying storepercentage usage in percent. Can I access that using *activemq-admin query --view* command. In java code I am getting that using * BrokerService brokerService = getBrokerService(); SystemUsage systemUsage = brokerService.getSy

Re: Is there a way to get kahadb size using activemq-admin command line tool?

Thanks for the information. What am trying to do here is to get this value via a perl script, so is there a way to access this value (using jmx) in perl script? -- View this message in context: http://activemq.2283324.n4.nabble.com/Is-there-a-way-to-get-kahadb-size-using-activemq-admin-comma

Re: Is there a way to get kahadb size using activemq-admin command line tool?

ping -- View this message in context: http://activemq.2283324.n4.nabble.com/Is-there-a-way-to-get-kahadb-size-using-activemq-admin-command-line-tool-tp4687052p4687160.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Is there a way to get kahadb size using activemq-admin command line tool?

Did anyone got a chance to see this? -- View this message in context: http://activemq.2283324.n4.nabble.com/Is-there-a-way-to-get-kahadb-size-using-activemq-admin-command-line-tool-tp4687052p4687079.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Is there a way to get kahadb size using activemq-admin command line tool?

Hi, I am using ActiveMQ 5.10. I want to get kahadb size using activemq-admin tool, is there a way to do it? Thanks, Pradeep -- View this message in context: http://activemq.2283324.n4.nabble.com/Is-there-a-way-to-get-kahadb-size-using-activemq-admin-command-line-tool-tp4687052.html Sent from

ActiveMQ admin command result for connection count is not matching with results from lsof

Hi, I am getting in-consistency in TotalConnectionsCount obtained using *"activemq-admin query --jmxurl service:jmx:rmi:///jndi/rmi://mqbrokerdev:9006/jmxrmi --view TotalConnectionsCount"* and lsof -p |wc -l . Am I doing some wrong comparison? Can somebody please explain? Thanks, Pradeep

Re: Unable to stop producer

Hi, I am not expecting my producer to exist after it looses connection from broker. I want my client to stop when I want them to stop, but with producer its not happening. I had to do a kill -9 pid to stop the process (kill pid is not working). Am unable to understand this behaviour of producer.

Re: Unable to stop producer

I have tried with failover broker as well ('failover(tcp://host1:61616,tcp://host2:61616)'), but still same problem. What could be reason for this. -- View this message in context: http://activemq.2283324.n4.nabble.com/Unable-to-stop-producer-tp4686340p4686346.html Sent from the ActiveMQ - Use

Unable to stop producer

Hi, I have activemq producer which keeps on producing message over a test queue. It is using failover mechanism but my uri contain only one broker address (tcp://host:61616). I am getting logs similar to this in my log files and when am trying to stop this producer its not getting stopped. *[201

Re: Question on TransportListener?

Is functionality similar to TransportListener available for stomp(perl, python) clients as well? -- View this message in context: http://activemq.2283324.n4.nabble.com/Question-on-TransportListener-tp4686170p4686251.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Question on TransportListener?

Hi am unable to reproduce a security exception? Can you please help me with this? -- View this message in context: http://activemq.2283324.n4.nabble.com/Question-on-TransportListener-tp4686170p4686199.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Question on TransportListener?

Hi, Thank You for clearing this out. You have mentioned that onException will get triggered in case of security exception, but onException takes IOException object as argument and IOException is not super class to either SecurityException or its parent class heirarchy, *So how can it get triggered

Question on TransportListener?

Hi, I am trying to use TransportListener and have couple of questions. I am using failover uri mechanism. 1. When does onException is called? 2. When does onCommand is called? 3. How to know whether primary broker has stopped or failover (or connection with them has some problem) which causes c

Re: How to notify Clients if ActiveMQ broker is down?

I am trying to use TransportListener. When will onException() method will be called ? Thanks, -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-notify-Clients-if-ActiveMQ-broker-is-down-tp4685662p4686152.html Sent from the ActiveMQ - User mailing list archive at N

Re: Notification of connection down between broker and client?

Hi, Thanks for reply. Actually I want automated functionality, that is, whenever broker connection is down my client get notified. Actually I have ActiveMQ as one of the component in my system, So I just want my client to know that whether problem was connection between activemq and client or s

Re: Notification of connection down between broker and client?

Is TransportListener is best way to do it? How to know of broker (primary or failover if implementing TransportListener) Thanks -- View this message in context: http://activemq.2283324.n4.nabble.com/Notification-of-connection-down-between-broker-and-client-tp4686035p4686064.html Sent from the

Re: Notification of connection down between broker and client?

Hi, Thanks for reply. Actually I want automated functionality, that is, whenever broker connection is down my client get notified. Actually I have ActiveMQ as one of the component in my system, So I just want my client to know that whether problem was connection between activemq and client or so

Notification of connection down between broker and client?

AMQGods Please help, I have a system which is using failover uri mechanism with master-slave architecture (when primary runs, failover waits on lock and when failover run primary wait on lock on kahadb). I need my clients to know when there is a problem with connection to broker. Whenever primar

Re: Who will receive messages first virtual topic subscriber or logical queue consumer?

Thanks Andreas So normal acknowledgement that works with persistent messages in case of topics with durable subscriber will not be there in case of virtual topic. Or will it be there and have some other behavior? Any idea on this ? Thanks, Pradeep -- View this message in context: http://acti

Who will receive messages first virtual topic subscriber or logical queue consumer?

Hi, I am trying to use virtual topic and am unable to find answer to this question, Can anybody help? *Question*: I am sending to topic "VirtualTopic.Test" and have a logical Queue "Consumer.A.VirtualTopic.Test". I have a subscriber (A) to topic and a consumer (B) to physical queue corresponding

Re: What to use Composite topic or Virtual topic?

Hi Petter, Thanks for stackoverflow link, you have not mentioned that virtual topic should be preffered way but you haven't mentioned why. Are there any performance difference? I need to decide on one of these with a proper answer so that I need not switch in future because of some hidden differe

What to use Composite topic or Virtual topic?

Hi, I have a use-case in which message published on a topic "BAR" needs to be replayed onto a queue "Foo". I explored web and found out I can use both Composite topic and virtual topic? But which one to use and why? I really need a answer? Please help me out on this? Thanks -- View this mes

What to use to replay messages in ActiveMQ and Why?

My use case needs me to replay messages sent on one destination to another (one or more). There can be four possible combinations : Topic -> Topic (CompositeTopic) Topic -> Queue (CompositeTopic, VirtualTopic) Queue -> Topic (CompositeQueue, MirroredQueue) Queue -> Queue (CompositeQueue) Are ther

What all problems with broker or network can be detected using Transport Listener?

Hi, What all problems with broker or network can be detected using Transport Listener? I am using failover uri with master/slave architecture. I want my clients to get notify if there is any problem with connection from client to broker. Though as soon as there will be problem with primary, failo

Re: How to notify Clients if ActiveMQ broker is down?

Is TransportListener best way to do this? Is there any better method. (Its a master slave architecture, so if primary broker goes down then client automatically connects to failover broker, but I still want clients to know that broker was down) -- View this message in context: http://activemq

Re: Virtual Destination vs Composite Destination?

Do anyone got a chance to look into it Can someone help? -- View this message in context: http://activemq.2283324.n4.nabble.com/Virtual-Destination-vs-Composite-Destination-tp4685626p4685690.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Virtual Topic, Composite Queue, Composite Topic forward characteristics?

Hi I was trying to evaluate these features and am stuck on how they forward messages. >From this and this http://activemq.apache.org/schema/core/activemq-core-5.10.0-schema.html#compositeQueue> . I kno

Re: How to notify Clients if ActiveMQ broker is down?

Can you point me to some of the options? -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-notify-Clients-if-ActiveMQ-broker-is-down-tp4685662p4685668.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: How to notify Clients if ActiveMQ broker is down?

I just want a way so that client can know that broker is down. Problem I am trying to solve is using activemq, there are two other components, so if there is some failure than It can be because of one of the component failing. So I need a mechanism to know that whether its broker which fails or s

How to notify Clients if ActiveMQ broker is down?

Hi, I want clients to get notification whenever my activemq broker is down for any reason. How can this be done? Is there any callback mechanism? -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-notify-Clients-if-ActiveMQ-broker-is-down-tp4685662.html Sent from th

Virtual Destination vs Composite Destination?

Hi, My use case is I have a publisher publishing on a topic and some consumer subscribing to it. Lets say there are 5 consumers. I want 3 consumer to get message as it is and for rest two I want only one of them gets (as if they have subscribed to a queue). One way is I can use VirtualDestination

Re: How acknowledgement for persistent message works with Virtual Topics?

Did you get time to see this? -- View this message in context: http://activemq.2283324.n4.nabble.com/How-acknowledgement-for-persistent-message-works-with-Virtual-Topics-tp4685359p4685437.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Message Header Size for JMS producer in ActiveMq v5.10

I have tried to print trcae but that also wasn't 1028 bytes so how can I know about this overhead? -- View this message in context: http://activemq.2283324.n4.nabble.com/Message-Header-Size-for-JMS-producer-in-ActiveMq-v5-10-tp4685256p4685408.html Sent from the ActiveMQ - User mailing list

Re: Message Header Size for JMS producer in ActiveMq v5.10

Can someone reply to this? -- View this message in context: http://activemq.2283324.n4.nabble.com/Message-Header-Size-for-JMS-producer-in-ActiveMq-v5-10-tp4685256p4685362.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

How acknowledgement for persistent message works with Virtual Topics?

If am not wrong When producer sends a persistent message on a topic then it first store message in persistent store (let kahadb) and then send an acknowledgment to producer. So how will it work in case of Virtual Topic with a logical queue because message will be stored for queue as well in kahad

Re: Persistence Message send on Virtual Destination persistence Store

gt; > Otherwise, the way I’m reading this.. I think you are asking to stop > message from going to the Consumer.B.VirtaulTopic.A queue. To do that, > just delete the queue. The presence of the queue acts as the subscription. > > On Sep 4, 2014, at 1:04 AM, bansalp <[hidden email]

Persistence Message send on Virtual Destination persistence Store

How acknowledgment and persistence works with virtual destination. If I have a virtualTopic "VirtualTopic.A" and a consumer queue on this topic "Consumer.B.VirtualTopic.A", if there is a durable consumer subscribed to this VirtualTopic then all messages are stored for Queue "Consumer.B.VirtualTopic

Message Header Size for JMS producer in ActiveMq v5.10

I was trying to use Message Size related stats provided in ActiveMQ v5.10 and found that header size is 1028 bytes (send message of different sizes and size returned by API is 1028 bytes more). I am not able to understand why size is this. Is it prefixed? Is there anyway to see what constitute he

Message Header Size

Hi, I was trying to use Message Size related stats provided in ActiveMQ v5.10 and found that header size is 1028 bytes (send message of different sizes and size returned by API is 1028 bytes more). I am not able to understand why size is this. Is it prefixed? Is there anyway to see what constitu

ActiveMQ 5.10 Prodcuer Flow Control with Persistent Topics

Hi, I am trying to test producer flow control with persistent as well as non-persistent topics. I have disabled producer flow control and want to see whether producer flow control will kick in when system usage limits are reached. But even when persistent store is used 100% then also producer is