Re: Concurrent message processing

Use more than one Session - or put the messages in a BlockingQueue and use a thread pool to process them concurrently Rob Davies Sent from my iPhone On 28 May 2009, at 05:38, Deepak Agrawal wrote: I am using activeMQ 5.1 and I want my consumer to process my message asynchronously. Whene

Concurrent message processing

I am using activeMQ 5.1 and I want my consumer to process my message asynchronously. Whenever any message comes to the consumer the processing of message in onMessage method includes connectivity with database and processing database query. So here if there is any block of code which requires more

JMS over HTTP

Current our software runs on ActiveMQ 4.1 and uses JMS API, sending serialized objects over the wire. We use openwire, open select ports in firewalls, etc. A user may want to keep firewall closed. Can we switch to HTTP/HTTPS, tunnel, keep firewall closed, and not change any of our code? Thanky

Another question about multiple message for one selector??

I have another problem using ActiveMQ. the situation is that J2EE applicatioin sends message to ActiveMQ queue, when I sent it, there is a property set, such as terminal = 2. so when I run Java Client to receive message, if the Java Client is terminal 2, it will only receive message for itself.

Problem With Producer Flow Control?

I am running some exception tests against AMQ 5.2 that force producer flow-control to occur and have a question regarding sessions and flow control. Here's my set up. Te test app, which is using an 'embedded' broker, has an object (Ob1) that implements MessageListener. Ob1 creates two AMQ conne

limiting memory usage of ActiveMQ

Hi, I would like to know how to configure memory usage limit for ActiveMQ when not using persistence.[what kind of configuration is required?] I tried various configurations but it didn't work. 1. Also, I am seeing lots of cache memory being created when we start ActiveMQ. How do I k

Re: Producer Acknowledge in NMS ?

Timothy Bish wrote: > > On Wed, 2009-05-27 at 08:06 -0700, mvhoof wrote: >> >> >> Timothy Bish wrote: >> > >> > On Wed, 2009-05-27 at 03:20 -0700, mvhoof wrote: >> >> Hi, >> >> >> >> I have a requirement to built a message queue Consumer/producer which >> >> works >> >> on flaky connections

Re: Producer Acknowledge in NMS ?

On Wed, 2009-05-27 at 08:06 -0700, mvhoof wrote: > > > Timothy Bish wrote: > > > > On Wed, 2009-05-27 at 03:20 -0700, mvhoof wrote: > >> Hi, > >> > >> I have a requirement to built a message queue Consumer/producer which > >> works > >> on flaky connections. Now this consumer/producer could be

Re: Producer Acknowledge in NMS ?

Timothy Bish wrote: > > On Wed, 2009-05-27 at 03:20 -0700, mvhoof wrote: >> Hi, >> >> I have a requirement to built a message queue Consumer/producer which >> works >> on flaky connections. Now this consumer/producer could be rebooted at all >> times (we have no control over this). So my chall

Re: Now another problem appears

I tried to use receive(500) to receive message, it looks work correctly. if I use receiveNoWait, sometime works, sometimes not. What I want to know is that there is a way to configure ActiveMQ to resolve this problem? thanks Gary Tully wrote: > > If you are using consumer.receive(), add a smal

Re: ActiveMQ-CPP Version 3.0 RC2 Released

On Wed, 2009-05-27 at 02:16 -0700, Sodan wrote: > Hi there > > Does 3.0 have support for utf8 string ? > > So we can > string s = map->getString("somestring"); > > and s will contain the utf8 string. > > thanx, > Søren > The client will send ASCII strings and receive ASCII strings and preserv

Re: Producer Acknowledge in NMS ?

On Wed, 2009-05-27 at 03:20 -0700, mvhoof wrote: > Hi, > > I have a requirement to built a message queue Consumer/producer which works > on flaky connections. Now this consumer/producer could be rebooted at all > times (we have no control over this). So my challenge is this: > > > Simply sending

Re: Now another problem appears

Thanks, Well, I used queueReceiver.receiveNoWait() method to receive message, but this method had not this issue when I used IBM MQ as MQM. I cannot use message listener here because it's client trigger the receiving message behaviour. Gary Tully wrote: > > If you are using consumer.receive(),

Re: Now another problem appears

If you are using consumer.receive(), add a small timeout to give the broker a chance to see your subscription, like receive(500). The MDB probably uses a message listener, you could use that approach in your java client also. 2009/5/26 Websphere and ActiveMQ > > Right now I can receive message

Producer Acknowledge in NMS ?

Hi, I have a requirement to built a message queue Consumer/producer which works on flaky connections. Now this consumer/producer could be rebooted at all times (we have no control over this). So my challenge is this: Simply sending the Message using a MessageProducer, i know when a message is a

Re: ActiveMQ-CPP Version 3.0 RC2 Released

Hi there Does 3.0 have support for utf8 string ? So we can string s = map->getString("somestring"); and s will contain the utf8 string. thanx, Søren -- View this message in context: http://www.nabble.com/ActiveMQ-CPP-Version-3.0-RC2-Released-tp23728342p23738877.html Sent from the ActiveMQ -

Re: C# / .net - getting started

Hi, I encountered simular issues when getting started with ActiveMQ.NMS.. However, if you search a bit, there is some good info about it on the web. I would recommend RE.mark's blog which has some very good and very hands on articles on how to work with NMS. http://remark.wordpress.com/articles