ActiveMQ not redelivering message

i start a broker , producer and consumer (its a queue ). we are using producers and consumers with spring configuration and spring integration. After i crash the broker and start it again, the broker must send some of the messages again since it would have not got the acks of the already sent m

exception when sender not able to send message

When a sender is not able to send a message to the broker, will an exception be generated ? What is that exception and can we catch it? We experience a scenario where the broker might be overloaded and may not get a message from the sender -- View this message in context: http://old.nabble.com/

Re: regarding ActiveMQ MemoryPersistence Adapter

in that case, why we have both inflightTransactions.remove(txid); preparedTransactions.remove(txid); in the rollBack() method.. are the elements in inflight Transactions and prepared Transactions completely different ? Thanks, Radha -- View this message in context: http://old.nabble.com/

ActiveMQ persistence store option

We are in dilemma in which persistence option to use for activeMQ. we tested both local disk and NFs version 4 . The NFSv4 was very slow when compared to the speed of local disk. But we will be more comfortable with a master-slave topology. Can any one suggest what else can we think so ? Can lus

Re: regarding ActiveMQ MemoryPersistence Adapter

sorry, mistake in last line.. if the method body is commented ? Thanks, Radha -- View this message in context: http://old.nabble.com/regarding-ActiveMQ-MemoryPersistence-Adapter-tp29103813p29103918.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

regarding ActiveMQ MemoryPersistence Adapter

The MemoryTransactionStore contains a rollback method that is called when the broker is crashed or shutting down. The rollback method then removes the transactionIds in the two concurrent HashMaps. Actually why is it removing the transactions ? i tried commenting those lines and i found no prob

Re: activeMQ with spring integration

hi, durable topics in activeMQ with spring integration is working perfectly with kahaDB and Memorypersistence adapter but not with AMQ persistence adapter. it shows the error in the previous message. it is bug with AMQ message store i think. Thanks, Radha -- View this message in context: htt

Re: relay in activeMQ

Hi, the publisher will create a topic on brokerA and the subscribers will do that on brokerB. how can i connect the se two brokers such that the subscribers get a message. that must be by using some kind of relay. is that same as writing the networkConnector tag in activemq.xml -- View this m

relay in activeMQ

Hi, we have a use case. there are two activeMQ brokers , brokerA and broker B. a publisher connects to brokerA and 5 subscribers connect to brokerB. we want the messages to be received by all the 5 subscribers. can we achieve this in activeMQ. can you tell what confoig change should i make. i

activeMQ with spring integration

Hi, we tired spring integration with activeMQ 5.3.0. we have 5 topics . 1 publisher and each topic has one subscriber. The publisher sends each message to one topic and that was done with the help of a router/ Now, we start the five subscribers and the publisher. the subscribers receive the mes

Re: activeMQ thread pool

hi, now we have a queue that has 3 producers to it and 8 consumers to it. ( a multi consumer queue). The rate at which we expect messages to come to the queue is 600 persistent messages per second. So what do you think will be the correct. having a single queue and 8 consumers to it (or) havin

activeMQ thread pool

Hi, By default activeMQ uses a thread per destination, is this destination topic/queue or includes the clients also ie, if we have three publishers sending messages to a topic and eight subscribers listening to it. How many threads are there in the broker for that topic. ( 1 or (3+8+1) ) --

Re: systemUsage in activeMQ.xml

Thanks, and one doubt, our machine has 8gb ram. its a 32 bit machine and we are not able to give more than 2700 MB as the max heap size for the activeMQ broker. suppose i give 2700 MB as -Xmx in the active.sh file and 3000 MB as the memoryUsage in the activemq.xml file, then which one will it t

systemUsage in activeMQ.xml

Hi, we are planning to shift our jms provider to activeMQ from our next product release. our first work involving activeMQ is to send 100 persistent messages each of size 2.5 KB per second, on a JMS Topic. We plan to use AMQ PersistenceAdapter for that. Now, we have some doubts i

Re: activeMQ webconsole

ya a help in the webconsole would be perfect. Actually we send messages from 1 publisher to 1 consumer across a JMS TOPIC. The client acknowledges those using AUTO_ACKNOWLEDGE but still Dispatcher count is always equal to the number of enqueued messages. we are dequeuing it the moment it is enq

activeMQ webconsole

in the webconsole page, in the tab for topic subscribers can any one tell us what exactly is 1. pending queue size 2. Dispatched queue size 3.dispatcher counter 4.enqueue counter 5. dequeue counter is the description given in http://old.nabble.com/default-file--store-location-td21906622.ht

Re: Failover transport options

Hi,, we used them only as the reference.. we gave maxReconnectAttempts as 500. still it is closing the connection after 10 seconds.. this is our url failover://(tcp:/10.1.37.155:61616)?maxReconnectAttempts=500. Also what significance does maxReconnectionDelay have since we have initialReco

Failover transport options

We have a broker running as a stand alone We have a producer and consumer connected to it.. When we crash the broker, the consumer keeps reconecting for 10 seconds after which it closes. Is there any way to increase that 10 seconds -- View this message in context: http://old.nabble.com/Failov

AMQ persistent adapter

Hi, I have two brokers connected to a network failover:(tcp://a:61616,tcp://b:61616) the persistent store in both is AMQPersistentAdapter and we are using ActiveMQ 5.3.0 and we send persistent messages Now, we send messages to broker A (tcp://a:61616) and after sometime it crashes. What will

Re: activeMQ broker for our useCases

Should we have separate message brokers for persistent and non persistent messages or a same broker will do for both ? -- View this message in context: http://old.nabble.com/activeMQ-broker-for-our-useCases-tp28841199p28887005.html Sent from the ActiveMQ - User mailing list archive at Nabble.co

activeMQ broker for our useCases

We want to have a messaing system, which has the following needs . persistent messages at about 300 / sec and non persistent messages at about 2000 / sec. The broker must run for 30-40 days without any hiccups and no message loss must be there. in the tests we conducted,

network of brokers

when using a network of brokers , the forwarding bridge is one way channel between. suppose we have activeMQ brokers, A and B as a network URL is static(tcp://A:61616,tcp://B:61616). and we start A first followed by B. A instantiates a connection to B. Am i correct ? or B intiates a connecti

AMQpersistence store and network connectors

Hi, We have two activeMQ brokers, and these two are connected as a network of connectors with the following conf in activemq.xml the persistent store in both the brokers are AMQ Persistence Store . We are using activeMQ 5.3.0 and the messages we s

AMQ Persistence Store explanation

We are experimenting with AMQ persistent storage using activeMQ5.3.0 we have few doubts regarding the options with the AMQ persistence store maxFileLength is the max size of each data log. but we are not clear about indexBinSize, indexKeySize, indexPageSize. what is a bin in this context.

MemoryPersistenceAdapter

in activemq.xml config file we give as , where exactly does the persistent messages get stored. Can you give us a link where we can understand more about the MemoryPersistenceAdapter -- View this message in context: http://old.nabble.com/MemoryPersistenceAdapter-tp28801100p288

queues and topics behaving in cluster of activeMQ's

We have a activeMQ cluster of three activeMQ brokers . say host1, host2, host3. We have 2 producers and one consumer. the use case is 2 producers write to the same queue and the consumer takes it from that queue. the URL i give to the 3 clients is public static final String ACTIVE_MQ_URL =

ActiveMQ Durable Topics / Persistent Messages

Hi, In addition, as every message can potentially have many consumers, a message cannot be deleted from the store until it has been delivered to every interested THis is the line given in chapter 4 of ActiveMQ in Action book for topic. Lets assume that , we have 4 subscribers listening to a