Re: ActiveMQ causes producer to hang when no consumer on topic after a few minutes.

Hi Bruce, How can I configure the broker to simply drop messages when they expire rather than sending them to the DLQ? Is there a "BitBucketDeadLetterStrategy" or something? -D bsnyder wrote: > > On Wed, Aug 20, 2008 at 2:49 PM, Ryan Moquin <[EMAIL PROTECTED]> > wrote: >> I don't think

High-speed topic publishing & consumption

Hi, I'm using ActiveMQ 5.1 to publish from a single fast producer to four consumers. All messages are non-durable and contain ephemeral data so I have the message time to live set to one second. My goal is to be able to publish as fast as possible and have any messages that don't make it

TCP transport connection recovery.

Howdy, I had a question about tcp transportConnectors and the TransportListener interface. My understanding is that a tcp connection from client to the broker will periodically attempt to reconnect if the broker goes down and no other connectors are available via failover/static. I have two

Re: (hopefully) simple JMS question

> > bsnyder wrote: >> >> On Thu, Aug 7, 2008 at 12:41 PM, David Crisp <[EMAIL PROTECTED]> >> wrote: >>> >>> Hi, >>> I have a quick question regarding the JMS spec and I was hoping to >>> solicit >>> feedback from our mer

(hopefully) simple JMS question

Hi, I have a quick question regarding the JMS spec and I was hoping to solicit feedback from our merry band of domain experts. Given that Sessions are not thread-safe, if I'm creating a little client-side API that gets hit by a myriad of threads and do not want to synchronize the API

Re: ActiveMQ 5.1.0

I was using gnu tar. -D. bsnyder wrote: > > On Thu, Jul 17, 2008 at 2:34 PM, David Crisp <[EMAIL PROTECTED]> > wrote: >> >> Hi Bruce, >> >> I just pulled it down off a couple of the mirrors with identical results. >> (I didn't keep t

Re: ActiveMQ 5.1.0

I was using gnu tar. -D. bsnyder wrote: > > On Thu, Jul 17, 2008 at 2:34 PM, David Crisp <[EMAIL PROTECTED]> > wrote: >> >> Hi Bruce, >> >> I just pulled it down off a couple of the mirrors with identical results. >> (I didn't keep t

Re: ActiveMQ 5.1.0

Hi Bruce, I just pulled it down off a couple of the mirrors with identical results. (I didn't keep track of which ones, unfortunately). File name was "apache-activemq-5.1.0-bin.tar.gz". Regards, D. bsnyder wrote: > > On Thu, Jul 17, 2008 at 1:36 PM, David Crisp <[E

ActiveMQ 5.1.0

Hi, I just downloaded ActiveMQ 5.1.0 and the distribution doesn't contain any of the stuff I'm expecting. IE: no bin/activemq or conf/activemq.xml or the like... just a big tarball of compiled java classes. There's a run.jar with a manifest, but executing it with "java -jar" yields a grip

Re: Broker detection of poison messages

Hi Mike, I've seen nothing like this in the docs. How about explicitly acknowledging receipt of the message before processing the message content? If you run out of heap while processing the message, it won't be redelivered. -D Michael Woodson wrote: > > I'm working on a consumer that m

Re: Does multicast transport exist?

Hi Shimik, I'm looking for the same info, although I'm currently on 4.1.2. When I did a code dive, I noticed that there are multicast connectors (transport & network) although they appear to be unreliable. My attempts to use it have been unsuccessful so far. Good luck, D. Shimik wrote: >

Using a topic for RPC-style requests

Hi, Our application sends RPC-like requests over the bus to a set of remote instances. We create a temporary queue and embed it in the outgoing request using Message.setReplyTo(tempQ). Is there a way to accomplish this using topics & selectors? Has anyone played with this and if so, how did

Multicast for discovery.

Hi, I'm seeing some weird behavior when using multicast discovery. When I use "multicast://default" it works fine but if I specify my own class D address, it fails. IE: "multicast://224.1.2.1:61616". Does anyone know what the default value is? It's not clear to me why it's failing and I

Question on multicast transport

Hi, I have an application that performs a large amount of ephemeral state distribution. State is transmitted from ~20 publishers to a group of four caches via a non-durable topic. State is queried using an RPC-style mechanism by publishing to a non-durable queue and having the responding c