ANN: Habari Client for ActiveMQ 3.5 - Delphi and Free Pascal STOMP client

2013-08-07 Thread Michael Justin
August 6, 2013 – Habarisoft is pleased to announce version 3.5 of Habari Client for ActiveMQ. Home page: http://www.habarisoft.com/habari_activemq.html Regards -- Michael Justin habarisoft - Enterprise Messaging Software for Delphi http://www.habarisoft.com/

Re: ActiveMQ MessageListener can't differentiate between command and text message

2013-08-07 Thread Christian Posta
Don't need to use nio:// on the client side. Your best bet is to create unit test that can reproduce it. Start here: http://svn.apache.org/viewvc/activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/ExclusiveConsumerTest.java?view=markup and here: http://svn.apache.org/viewvc/ac

Re: ActiveMQ MessageListener can't differentiate between command and text message

2013-08-07 Thread sumit.wattal
This is how I create my message consumer ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(); activeMQConnectionFactory.setBrokerURL("nio://localhost:61619")); final Connection connection = activeMQConnectionFactory.createConnection() ; final Session session = c

Re: ActiveMQ MessageListener can't differentiate between command and text message

2013-08-07 Thread Christian Posta
Show how you create your consumer. Your consumer shouldn't receive these messages unless you're subscribed to advisory topics. On Wed, Aug 7, 2013 at 2:08 PM, sumit.wattal wrote: > Hi, > > I have started to migrate from activemq 5.6 single broker to activemq 5.8 > network of brokers. The new sol

ActiveMQ MessageListener can't differentiate between command and text message

2013-08-07 Thread sumit.wattal
Hi, I have started to migrate from activemq 5.6 single broker to activemq 5.8 network of brokers. The new solution has one broker pumping data to a distributed queue that resides on another broker which has a message listener set up as under. I had an existing code which basically sets a message l

PooledConnectionFactory with JmsTemplate issue

2013-08-07 Thread asookazian
I'm getting the following exception using PoolableConnectionFactory with JmsTemplate: Caused by: javax.jms.JMSException: Cannot send message to queue://Subscriber.global.Prm.Intuit.globalvirtual.dev.payments.data.RiskNotification.Virtual with invalid (null) producer state This same class/method w

Re: Activemq webconsole for multiple brocker

2013-08-07 Thread Christian Posta
Check out hawtio. This will eventually be the webconsole in ActiveMQ 5.9.0. On Wed, Aug 7, 2013 at 2:28 PM, Chirag Pujara wrote: > Hi, > > Is it possible to monitor multiple brockers from single webconsole. I am > not running brockes in master/slave mode. > > If no is there any other soletion th

Activemq webconsole for multiple brocker

2013-08-07 Thread Chirag Pujara
Hi, Is it possible to monitor multiple brockers from single webconsole. I am not running brockes in master/slave mode. If no is there any other soletion that I can use? thanks, chirag

Re: STOMP heart beat 'tolerance'

2013-08-07 Thread Paul Gale
AMQ-4674 has been created On Wed, Aug 7, 2013 at 4:24 PM, Christian Posta wrote: > Good question. > Doesn't look like ActiveMQ 5.x has a grace period for the heart-beat. > Apollo has 1.5x grace period. Can you open a JIRA and we can get that into

Re: STOMP heart beat 'tolerance'

2013-08-07 Thread Christian Posta
Good question. Doesn't look like ActiveMQ 5.x has a grace period for the heart-beat. Apollo has 1.5x grace period. Can you open a JIRA and we can get that into ActiveMQ 5.x as well? On Wed, Aug 7, 2013 at 12:50 PM, Paul Gale wrote: > Hi, > > Regarding the configuration of heart beating the STOM

STOMP heart beat 'tolerance'

2013-08-07 Thread Paul Gale
Hi, Regarding the configuration of heart beating the STOMP protocol spec states: "- because of timing inaccuracies, the receiver SHOULD be tolerant and take into account an error margin" How 'tolerant' does ActiveMQ determine it will be when calculating its 'error margin' regarding the arriv

Re: Stop and resume message consuming

2013-08-07 Thread retok
Thanks for your reply. I have tried to set prefetch to 0. But this does not work for async sessions. I have to set it to a minimum of 1 because I would like to use the MessageListener concept and do not want to construct a sync session where I have to call receive() myself. Now, the effect of this