Acknowledgement to JMS Topic on activemq

2013-12-17 Thread Sri
I am consuming message from a topic and wanted send it to SOLR server as a batch for a commit as committing on SOLR is expensive operation. How ever I wanted to keep the message on the topic till the commit operation completes successfully. I want to send successful acknowledgement in that case ot

ActiveMQ 5.9.0 : using levelDb, where is the "tmp_storage" ?

2013-12-17 Thread gregpich
Hi I used ActiveMQ 5.7.0 with KahaDb, and I knew that the temp storage for non persistent messages when memory is full was in ./data/queue_name. But, since I have used ActiveMQ 5.9.0 with levelDb, I can't find where these temp datas are stored. Is the same place as the persistent messages ? Coul

Re: Get Count of messages in the queue using NMS

2013-12-17 Thread Timothy Bish
On 12/17/2013 03:58 AM, skvsree wrote: Hi, I am trying to get the number of messages left in the queue, but I find it very tricky. Below is the code I am using, but the still the count is wrong. long qdepth = 0; var browser = _session.CreateBrowser(_queue);

Producer blocking on transacted message

2013-12-17 Thread Lucas Dias
Dear fellows, I am trying to produce messages in batch (using transactions) on a producer. I've set the ActiveMQSession as a non transacted Session (Session.Non_transacted) and attempted to commit on every group of 50 messages. However, considering a few situations we usually face here (package b

Get Count of messages in the queue using NMS

2013-12-17 Thread skvsree
Hi, I am trying to get the number of messages left in the queue, but I find it very tricky. Below is the code I am using, but the still the count is wrong. long qdepth = 0; var browser = _session.CreateBrowser(_queue); var messagesInQ = browser.Ge

Re: Request for clarification: strictOrderDispatch="true" vs Exclusive Consumers - for queues

2013-12-17 Thread Gary Tully
strictOrderDispatch does not wait for acks. Given 2 consumers(c), normal dispatch would round robin to each consumer, m0 to c0, m1 to c1, m2 to c0 etc. With strictOrderDispatch, m0-N (where N = c0's prefetch Value) will go to c0, then c1 will get any remaining messages up to its prefetch, etc. So

Re: Query about ActiveMQ connection id and client id format

2013-12-17 Thread Gary Tully
stomp is converted/transformed into jms on the broker, hence the use of the brokerhost. But this is the default value for a clientid if none is specified, it can be speciied in a stomp header called client-id On 17 December 2013 07:15, Sophia Wright wrote: > Could you please help me understand wh

terminate client and not receive last will from ActiveMQ

2013-12-17 Thread xiaohlang
hi, When i terminate a paho client from Activemq broker , reconnect client and not receive last will message. I have met this question in AMQ5.8 and submmit a "bug" in jira , no response later .Now I test in AMQ5.9 and same thing happened. In AMQ 5.9 resolved issues i didnot found "last will"