Request-Response in ActiveMQ

Hi, I want to implement request-response using JMS. I found two ways of doing it: 1. Using selectors 2. Filter duplicate messages in producer application itself. Which method is recommended by ActiveMQ vendors ? What is the performance overhead on broker in case of selectors , because I think

Re: Request-Response in ActiveMQ

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

InterruptedException with ActiveMQ broker

Hi, I am seeing this exception (stack trace below). Curious what might be causing the interruption, and what this error means ? Stack Trace: - [ 2013-12-24 04:01:21,157 [InactivityMonitor Async Task:

Re: InterruptedException with embedded 5.5.0 broker

I have also seen the same issue today. Can someone from ActiveMQ dev team will let us know , Why this is happening ? Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/InterruptedException-with-embedded-5-5-0-broker-tp3487950p4675846.html Sent from the

large number of connections from the same client

Hi, I am seeing large number of connections ( more than 100) from the same client to ActiveMQ broker. I am not able to understand the reason behind this. Will someone from ActiveMQ dev team help me out here ( what might cause a client to have so many connections) ?? I am seeing this log

Hung ActiveMQ broker and processes are blocking

JStack.txt http://activemq.2283324.n4.nabble.com/file/n4675874/JStack.txt Hi, I am using ActiveMQv5.8. Yesterday I saw some weird issue happening with broker where: ActiveMQ broker running on cluster machine was in hung state and not responding to the client request. It was blocking processes.

ActiveMQ broker usages.

Hey, I am using ActiveMQ v5.8. I am seeing very high broker usages on the host ( since 250 clients are connecting to the broker ), So Can you just give me a brief idea about configurations should I enable for ActiveMQ broker to reducer broker usages ? Thanks, Anuj -- View this message in

Re: Hung ActiveMQ broker and processes are blocking

Please respond... -- View this message in context: http://activemq.2283324.n4.nabble.com/Hung-ActiveMQ-broker-and-processes-are-blocking-tp4675874p4675928.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ broker usages.

I cannot use more than one broker, currently only one broker is used. -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-broker-usages-tp4675922p4675929.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Difference between wireFormat.maxInactivityDuration and IdleTimeout of pooled connection Factory

Hey, I ma getting confused between 'IdleTimeout' of pooledConnectionFactory and maxInactivityDuration. *IdleTimeout *: For a Connection that is in the pool but has no current users the idle timeout determines how long the Connection can live before it is eligible for removal from the pool.

Re: Request-Response in ActiveMQ

Using Synchronous communication what is the overhead on broker using selectors ? Please respond. Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/Request-Response-in-ActiveMQ-tp4675769p4676033.html Sent from the ActiveMQ - User mailing list archive at

Re: Hung ActiveMQ broker and processes are blocking

I checked the usage and also increased the heap size for my broker. But will you please let me know about enabling permgen space garbage collection. How to do it and are there any side effects after this ? Thanks, Anuj -- View this message in context:

Re: Hung ActiveMQ broker and processes are blocking

One more thing. While my broker was hung, my total used heap is exceeded max heap size. I don;t understand why ? I calculated heap using JMAP -heap PID command. where: used heap size = used (PS Old Generation) + used(Eden Space) how can this value be more than maxHeapSpace ? Thanks, Anuj

Used Heap size is more than max heap

Hi, I have seen one weird situation, where my broker was under load and it was hung, So when I checked the heap configurations using jmap -heap PID *Used heap is found to be more than max heap size How is it possible ?* I am calculating *used_heap = used (Eden space) + used (PS old generation)

reason: javax.jms.InvalidClientIDException : Client already connected from

Hi, I am using ActiveMQ v5.8 and seeing the below error continuously in broker log file: [20140108 06:30:01.038 EST (ActiveMQ Transport: tcp:///*.*.*.*:45678@61616) org.apache.activemq.broker.TransportConnection#processAddConnection 772 WARN] - Failed to add Connection

Re: What is the effect of dedicatedTaskRunner Attribute?

If I disable dedicatedTaskRunner: 1. Does it means there will not be one thread per connection or Does it means there will not be one thread per queue/topic ?? 2. What is the size of thread pool if I don't use dedicatedTaskRunner ? Thanks, Anuj -- View this message in context:

Re: Re: What is the effect of dedicatedTaskRunner Attribute?

I didn't get it. By default DedicatedTaskRunner is enabled (TRUE). So does it mean there is only one thread to execute all the tasks ? That sounds wrong to me. It should me something like execute all the tasks of a queue or client ? Please clearify more. Thanks, Anuj -- View this message

ActiveMQ InactivityMonitor for STOMP

Hi, I am understanding the usages of ActiveMQ InactivityMonitor. I have some questions regarding this. I have gone through http://activemq.apache.org/activemq-inactivitymonitor.html 1. Does Inactivity monitor is also works for STOMP (python/perl) clients ? If yes than what is the difference

ActiveMQ admin command

Hi, I am running activemq-admin query command to check broker related things. I want to know that by running this command : 1. Does broker send the complete Mbean data and filtering is done after that ? OR 2. Broker only send data which is requested by the command ? Like: If

dedicatedTaskRunner threads reductions

Hi, Reference: If we disable dedicatedTaskRunner, we can use ActiveMQ internal thread pool to control message dispatching. Using a thread pool can restrict the number of threads required by ActiveMQ and hence reduce memory usage. Question: I disable dedicatedTaskRunner, Will there not be one

Re: what is the relationship between indexbinsize indexpagesize

Such questions generally not create any attention. But I also like to know exact same thing. If someone from ActiveMQ development can reply here... -- View this message in context:

Re: ActiveMQ admin command

Hey, Little bit confused here. Please help !! -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-admin-command-tp4676307p4676566.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ admin command

I have checked the source code but still it is not clear to me that where is the filtering happening. I am using these 3 command: -- activemq-admin query --view *InactiveDurableTopicSubscribers *--jmxurl service:jmx:rmi:///jndi/rmi://amqbroker:8887/jmxrmi --jmxuser guest --jmxpassword activem

Current Connection Count for ActiveMQ broker

Hi, I want to know current connection count for ActiveMQ broker. I am using below APIs for this: --- BrokerService brokerService = getBrokerService(); connectors = brokerService.getTransportConnectors(); for (int i = 0 ; i 3; i++) {

Re: Current Connection Count for ActiveMQ broker

Hi, I think here you mean embedded broker by broker in the same java process as clients ? I have access to the broker's API. But I am *not using *embedded broker. I am using broker in a different java process and clients are connecting from other places. But still this API is showing the

Re: ActiveMQ admin command

Hi, According to my understanding: When I run *activemq-admin query --view InactiveDurableTopicSubscribers --jmxurl service:jmx:rmi:///jndi/rmi://amqbroker:8887/jmxrmi --jmxuser guest --jmxpassword activemq * where queryAddObjects will be null but queryViews will not be null. So *List

Re: Current Connection Count for ActiveMQ broker

I think little bit confusion here; let me elaborate: I am running ActiveMQ broker as a separate java process. And clients are connecting from different hosts and client have different java process and connecting to the broker using transport connectors (TCP). I am using this code in my own

Re: Current Connection Count for ActiveMQ broker

Hey, I don't know how to use JMX for broker. Is there any APIs of JMX I should use ? Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/Current-Connection-Count-for-ActiveMQ-broker-tp4676635p4676741.html Sent from the ActiveMQ - User mailing list archive at

Re: Current Connection Count for ActiveMQ broker

Ohh. I explored a little bit and got to know this. Does your mean by saying JMX is: *BrokerViewMBean brokerView = (BrokerViewMBean) getBrokerService().getManagementContext().newProxyInstance(brokerName, BrokerViewMBean.class, true);* and I can get transport connector by:

Re: Current Connection Count for ActiveMQ broker

Ohh. I explored a little bit and got to know this. IS your mean by saying JMX is: *BrokerViewMBean brokerView = (BrokerViewMBean) getBrokerService().getManagementContext().newProxyInstance(brokerName, BrokerViewMBean.class, true);* and I can get transport connector by:

Re: Current Connection Count for ActiveMQ broker

I am not able to understand. Will you please tell me how to get connections from JMX ? Or what is wrong with my approach (It is working fine even if I am not using embedded broker) Thanks, Anuj -- View this message in context:

Re: Current Connection Count for ActiveMQ broker

I have a simple requirement where I want to log current number of connections established to the ActiveMQ broker. -- View this message in context: http://activemq.2283324.n4.nabble.com/Current-Connection-Count-for-ActiveMQ-broker-tp4676635p4676752.html Sent from the ActiveMQ - User mailing

Re: Current Connection Count for ActiveMQ broker

Thanks you for the explaination -- View this message in context: http://activemq.2283324.n4.nabble.com/Current-Connection-Count-for-ActiveMQ-broker-tp4676635p4676764.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

OptimizedDispatch and DedicatedTaskrunner

As specified here http://activemq.2283324.n4.nabble.com/Large-number-of-queues-HowTo-td2364929.html we should use *optimizedDispatch=true and org.apache.activemq.UseDedicatedTaskRunner=false *together. But If I only use org.apache.activemq.UseDedicatedTaskRunner=false and keep optimizedDispatch

Re: Current Connection Count for ActiveMQ broker

Hi, I am trying to do periodic logging of ActiveMQ stats using plugin. I will log all the stats per minutes. Stats includes: enqueue count, dequeue count, dispatch count, connection count, Producer/consumer count, Durable subscriber count and Dynamic Destination producer count etc. The way I

KahaDb cleanUp interval

Hi, By Default KahaDb cleanupInterval is 30 seconds. I think this is very small duration for cleanup. For broker with heavy load this interval is very small. So I want to increase this value to 60 seconds. What is the impect on the broker by increasing this value to 60 seconds ? Thansk, Anuj

Re: KahaDb cleanUp interval

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

Re: Current Connection Count for ActiveMQ broker

Please respond -- View this message in context: http://activemq.2283324.n4.nabble.com/Current-Connection-Count-for-ActiveMQ-broker-tp4676635p4677144.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Current Connection Count for ActiveMQ broker

Thanks for the suggestions. I cannot go ahead with the other approaches you specified because of some reasons. So I just want to ask one more thing: If I am using plugin to get all the stats. than is there any other way to get stats without creating *ManagementContext* and *BrokerViewMBean*. I

Held Messages in ActiveMQ broker

Hey I am seeing this value as negative for my broker : RegionBroker regionBroker = (RegionBroker) brokerService.getRegionBroker(); DestinationStatistics brokerStats = regionBroker.getDestinationStatistics(); *brokerStats.getMessages().getCount() * It should return number of

Re: KahaDb cleanUp interval

Ping !! What is the impact of increasing this value to 60 sec. ? -- View this message in context: http://activemq.2283324.n4.nabble.com/KahaDb-cleanUp-interval-tp4676946p4677373.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Held Messages in ActiveMQ broker

please respond !! -- View this message in context: http://activemq.2283324.n4.nabble.com/Held-Messages-in-ActiveMQ-broker-tp4677298p4677374.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Re: What is the effect of dedicatedTaskRunner Attribute?

Guys please respond !! Give me some idea about dedicated task runner. I am now totally confused between *dedicated task runner Pooled task runner *and o*ptimizedisaptch * By making * org.apache.activemq.UseDedicatedTaskRunner=false * is it by default enable pooledtaskrunner or it's just

Re: OptimizedDispatch and DedicatedTaskrunner

Hey, So If I use optimize dispatch there will not be one thread per queue for message dispatching; than how does the message dispatch processing will happen. (I am using dedicated task runner which is by default ) AND I am little bit confused here. I have my thread trace here which is pasted

Re: Re: What is the effect of dedicatedTaskRunner Attribute?

Hey, So If I use this configuration : *optimizedDispatch=true and org.apache.activemq.UseDedicatedTaskRunner=true * It means the sending thread will do dispatch, (There will not be a separate thread for dispatch) and it will not use ActiveMQ thread pool (since I have enabled dedicated task

Re: KahaDb cleanUp interval

Hello ?? -- View this message in context: http://activemq.2283324.n4.nabble.com/KahaDb-cleanUp-interval-tp4676946p4677852.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Disable advisory for ActiveMQ broker

Hi, I am trying to disable advisory for broker using advisorySupport=false in broker configuration. 1. Is there any side effect of disabling advisories for broker ? 2. Even after disabling advisories there is advisory for temp topic/queue

Re: Disable advisory for ActiveMQ broker

I saw the page you specified but not found any information for topic://ActiveMQ.Advisory.TempQueue_Advisory.TempTopic. What is the relation between temp destinations and advisories ? Thanks, Anuj -- View this message in context:

Re: Disable advisory for ActiveMQ broker

Okay.. So I need to do :* advisorySupport=false * as well as *tcp://localhost:61616?jms.watchTopicAdvisories=false* to get rid of advisories completely. Just one thing that if i use above configuration, is there any side effect/ impact on other things of broker ? (I am basically doing it to

Re: Re: What is the effect of dedicatedTaskRunner Attribute?

Hey, I am using ActiveMQ v5.8. AND I was surprised to see that *default value of dedicatedTaskrunner is false which means ActiveMQ uses thread pool by default.* which contradict the statement given by ActiveMQ vendors

Re: Re: What is the effect of dedicatedTaskRunner Attribute?

I explored a little bit about it and found that in v5.6 this change was done.. https://issues.apache.org/jira/browse/AMQ-3667 Again coming back to the issue, I am now using pooled connection factory for my broker and seeing that this task thread is continuously getting created and destroyed. For

Re: Re: What is the effect of dedicatedTaskRunner Attribute?

Can you please respond to my second question that why thread pool is not keeping the threads? Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/What-is-the-effect-of-dedicatedTaskRunner-Attribute-tp2363191p4677932.html Sent from the ActiveMQ - User mailing

Negative Enqueue Counter

Hi, I am using Amqv5.8. I was checking counters for a topic and found the negative value of enqueue counter. Can enqueue counter be negative ? What is the significance of negative value ? Screenshot attached below: http://activemq.2283324.n4.nabble.com/file/n4678294/negative_counter.png --

Re: Re: What is the effect of dedicatedTaskRunner Attribute?

I do not see a reason why you would want idle threads to be kept for a longer period, especially if there are several TaskRunnerFactory instances in use - this would simply leave idle threads in memory I was thinking about load on the broker to create and destroy threads continuously. Lots of

Re: Disable advisory for ActiveMQ broker

Hi, I tried setting connection URI in broker config as: * amq:transportConnectors amq:transportConnector name=amqBrokerTcpTransport uri=tcp://0.0.0.0:61616?jms.watchTopicAdvisories=false / /amq:transportConnectors * but still it is

Inflight Count for topics not correct.

Hi, ActiveMQ version : 5.8 Problem: Inflight count is not going down for topics once consumer is disconnected. Test Scenario: When there is a producer and a consumer connected to the broker but consumer is little bit slow, there will be inflight messages in the broker which are not yet

ActiveMQ Perl Consumer error: cannot sysread(): EOF

Hi, I am using use Net::STOMP::Client module for my perl consumer. I am talking about the case when there is a producer on the topic/queue on which this consumer is connecting, so I keeps receiving the frames. I debug and checked the frames are like: *Net::STOMP::Client::Frame=HASH(0x3ec26f0)*

Re: ActiveMQ Perl Consumer error: cannot sysread(): EOF

In addition to the above post if I use sleep_time of 5 seconds I am not getting any exceptions. It is working fine. As I increase the value of sleep_time, more I am getting the exceptions. In case of sleep_time = 30, I am getting lots of exceptions, only around once in 4 or 5 time it gets

Re: Inflight Count for topics not correct.

Yes, I am looking at topic itself. TopicSubscriber ? I didn't understand, I think there nothing like inflightCount for topic subscribers. When subscriber is there, it keeps on acknowledging the messages sent from broker. But as soon as subscriber goes down, the messages which are not yet

ActiveMQ perl consumer ideal timeout

Hi, I am using Net::STOMP:CLIENT perl module and trying to connect my consumer to the broker. When Consumer remains ideal for 15 seconds, broker disconnects my consumer. Why so ? Is there an idealtime after which I need to send messages from my perl client to keep the connection alive. I am

Re: ActiveMQ perl consumer ideal timeout

I was checking more and found out some source code: here org/apache/activemq/transport/stomp: * public static final long RECEIVE_TIMEOUT = 1; and stompSocket.setSoTimeout((int)timeOut); * What is this timeout, Does it mean broker will close the connection after 1ms if it does not

Re: Inflight Count for topics not correct.

Please respond !! -- View this message in context: http://activemq.2283324.n4.nabble.com/Inflight-Count-for-topics-not-correct-tp4678407p4678583.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Dynamic destination producers for STOMP

Hi, I am using ActiveMQ v5.8. I am using STOMP 1.1 for my python and perl clients. 1. When I connect my python or perl producer to ActiveMQ broker, it is always considered as dynamic producer, why so ? 2. When I create python or perl *consumer*, it also creates a dynamic producer ? I am not

How to restrict a client to connect to broker

Hi, Using ActiveMQ v.5.8 I want to know that is there a way to restrict a perticular client to connect to the broker ? I am using my own plugin where I override addConnection function, if something I can do here to restrict that client to connect ? Thanks, Anuj -- View this message in

ActiveMQ consumer not getting removed

Hi, I am using ActiveMQ v5.8. When a consumer try to connect to the broker with the client id which is already used previously. broker throws InvalidClientID exception. Client is using spring DMLC and it will keep on retrying indefinitely to connect again even after receiving the exceptions. I

Re: ActiveMQ consumer not getting removed

Please respond !! -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-consumer-not-getting-removed-tp4678812p4678829.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Purged queue does not delete message on it

Hi, I am using amqV5.8. What is the exact meaning of queue purging for ActiveMQ. According to documentation purge a queue menas delete all the messages on it But when I purge a queue and check Jconsole, it delete all the pending messages and consider them as dequeued. *Before purging:

Re: Purged queue does not delete message on it

That was helpful. One more thing: Is there a way to kill or remove connection of a consumer/producer connecting to a topic/queue from jconsole ? (For example we can destroy durable subscription. ) Thanks, Anuj -- View this message in context:

Persistent Message deleted after queue purged

Hi, Version: 5.8 If I am sending persistent messages on a queue and no consumer is running, broker will store all those msgs in kahadb. Now if I purge the queue, borker will delete all the messages on that queue ? Will it also delete messages from kahaDB ? Thanks, Anuj -- View this message

Slow consumer message purging

Hi, ActiveMQ version: 5.8 I am talking about the case of slow consumer (consumer is not able to consume those msgs). when prefetch limit is exceeded this thing happens. In this case: In case of topics (both durable and non durable subscription) Do we have any strategy where we can purge or

Queue Subscriber Mbeans

Hi, using : ActiveMQ 5.8 I am looking into jconsole for a queue subscribers. Can you please tell me difference between following terms: *1. MessageCountAwaitingAcknowledge 2. PendingQueueSize 3. MaximumPendingMessageLimit 4. PrefetchSize* -- View this message in context:

PageFile is not loaded when recreating queue

Hi using Activemq v5.8 We create a queue, delete it through the jconsole, and attempt to recreate it, receiving the error below on the client. But when filteredKahaDB perDestination is disabled, queues can be deleted and recreated without issues. I have already gone through

Re: PageFile is not loaded when recreating queue

This is issue is not only with queues but also with topics. -- View this message in context: http://activemq.2283324.n4.nabble.com/PageFile-is-not-loaded-when-recreating-queue-tp4679066p4679067.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ admin command to delete and create queue/topic

Hi, As of now we can purge messages in a queue using ActiveMQ admin command. We can create and destroy any topic/queue from Jconsole, it will be really helpful if we can have admin command for creation and deletion or queues/topics. Thanks, Anuj -- View this message in context:

Re: PageFile is not loaded when recreating queue

It was weird. This time it worked, i don;t know how, but I have same conclusion: Since clients are connected so, they will recreate the queue after deletion. But Sometimes new queue will apear without this symbol of yellow color as shown in below image, only in this case communication is broker

Re: Queue Subscriber Mbeans

Can anyone explain this ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Queue-Subscriber-Mbeans-tp4679026p4679166.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ admin command to delete and create queue/topic

Any comments ? -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-admin-command-to-delete-and-create-queue-topic-tp4679072p4679165.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Purged queue does not delete message on it

any comments ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Issue-with-queue-purging-tp4678945p4679167.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Slow consumer message purging

any comments ? Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/Slow-consumer-message-purging-tp4679024p4679168.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ consumer not getting removed

Hey, I saw some configurations in ActiveMQConnectionFactory and FailoverTransport like initialReconnectDelay backOffMultiplier maxReconnectAttempts useExponentialBackOff. If we cannot stop client in above case than atleast we can create delay after each reconnect. I found that if a client is

Re: ActiveMQ consumer not getting removed

Please respond !! -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-consumer-not-getting-removed-tp4678812p4679193.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ consumer not getting removed

Hello ? Please respond !! -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-consumer-not-getting-removed-tp4678812p4679254.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: PageFile is not loaded when recreating queue

Guys this behavior is weird !! Please take a look. -- View this message in context: http://activemq.2283324.n4.nabble.com/PageFile-is-not-loaded-when-recreating-queue-tp4679066p4679255.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Multiple persistence adapters using levelDB

Hey, In KahaDB, we can have different persistent adapters and different directories for each destination. Can we do something like that using levelDB ? I am not at all want to use kahaDB. Only using levelDB can I create separate directories to store messages for each destination. Thanks, Anuj

Re: Multiple persistence adapters using levelDB

FYI: I am talking about this configuration: amq:persistenceAdapter amq:mKahaDB directory=/u/khandela/activemq/kahadb/ journalMaxFileLength=64mb amq:filteredPersistenceAdapters amq:filteredKahaDB queue=dest1.

Re: Multiple persistence adapters using levelDB

Please respond guys ? Also one more thing: Are you guys planning to make levelDB by default in future versions or you will keep support for both kahaDB and levelDB. Thanks, Anuj -- View this message in context:

Re: Multiple persistence adapters using levelDB

waiting for someone to respond -- View this message in context: http://activemq.2283324.n4.nabble.com/Multiple-persistence-adapters-using-levelDB-tp4675278p4679489.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

LevelDB: Multiple Persistent Adapters

Hi, Is there a support on levelDB to provide multiple persistent adapters ? In kahaDb we have can have multiple kahaDB instance for each destinations. With the Mulitple KahaDB persistence adapter, destination partitioning across journals is possible. Is there some feature in levelDB for

Re: LevelDB in ActiveMQ 5.9.0

leveDB also does not support multiple kahaDB instance (persistent adapters) similar to kahaDB. With the Mulitple KahaDB persistence adapter, destination partitioning across journals is possible. but there is no support in levelDB for this. Please correct me if I am wrong !! Thanks, Anuj

ActiveMQ with JAVA 8

Hi, Since Java8 has been released. We should have ActiveMQ compiled with Java8. Is there any plan on this ? Did ActiveMQ gods started to compile broker with it or run test against it ? Thanks, Anuj -- View this message in context:

Re: ActiveMQ with JAVA 8

Anybody get a chance to look at this ? -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-with-JAVA-8-tp4679842p4680102.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ with JAVA 8

But when can we expect AcitveMQ built with java8. Is there a plan to do it in ActiveMQ5.10 ? or later ? -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-with-JAVA-8-tp4679842p4680143.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Slow Consumers in ActiveMQ 5.9

Hi, I was going through https://issues.apache.org/jira/browse/AMQ-4621 *(AbortSlowAckConsumerStrategy )* If I specify this strategy to abort slow consumers in my xml configuration, does it also changes the way we consider a consumer slow. Previously we consider a consumer as slow based on the

Default behavior to handle Slow consumer

Hi, Using AcitveMQ v5.8 How ActiveMQ broker handles slow consumer if I don't specify any slow consumer strategy(normal default configuration). I am not using any slow consumer strategy in my configuration. producer flow control is also disabled. What will be the way to handle slow consumer in

spring 4.0 with ActiveMQ

Hi, Is there any plan to release *ActiveMQ * with *spring-4.0.* Will it be coming in* ActiveMQ 5.10 *? Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/spring-4-0-with-ActiveMQ-tp4680166.html Sent from the ActiveMQ - User mailing list archive at

Re: Default behavior to handle Slow consumer

Thanks for the reply but I am asking that what will broker do in case if broker sees a slow consumer. According to http://activemq.apache.org/slow-consumer-handling.html it will slow down the producer. Will broker slow down the producer even if I have disabled producer flow control ? Please

Slave broker detection

Hi, I am using master-slave topology for ActiveMQ brokers. I have two brokers in my set up one is master and other as salve. By looking at logs and kahaDB I can see that which broker is master and which is slave. But is there any API or command to know that which broker is master (somewhere in

Non persistent Messages Not getting expired even after expiration time exceeded

Hi, Version : ActiveMQv5.8 Problem: Non persistent Message sent to a topic (which has a inactive durable subscriber) are not getting expired even after expiration time is exceeded. Details: In my setup I have a topic which has inactive durable subscriber. When I send a message to that topic

Re: Non persistent Messages Not getting expired even after expiration time exceeded

Did anyone get a chance to look at this. -- View this message in context: http://activemq.2283324.n4.nabble.com/Non-persistent-Messages-Not-getting-expired-even-after-expiration-time-exceeded-tp4680428p4680451.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Non persistent Messages Not getting expired even after expiration time exceeded

It's Non persistent message. Non persistent message is sent from the producer but since it is send to the topic which has inactive durable subscriber, this message will be stored in non-persistent message store activemq-data/broker/tmpstorage/. Thanks, Anuj -- View this message in context:

  1   2   3   >