Look a the source of the examples, there is a trivial producer and
consumer that you can play with and inspect or use in place of your
producer with your existing consumers.

Compare and contrast the code to what you are doing.

doc: http://activemq.apache.org/examples.html

source: 
http://svn.apache.org/viewvc/activemq/trunk/assembly/src/release/example/src/
see  Consumer|ProducerTool.java

Alternatively, look at some of the many tests in the activemq-core module


On 3 November 2011 13:30, PinkyNoBrain <spam_...@live.co.uk> wrote:
> I previously posted this question on StackOverflow and was advised to raise
> it here after no obvious solutions where found.
>
> I am relatively new to JMS and have encountered a weird problem implementing
> my first real application so please excuse me if this turns out to be a
> rookie implementation/configuration mistake. I'm desporate for any help or
> advice.
>
> Background: I use AtiveMQ (java) as the message broker with non-transacted,
> non-persitent queues.
>
> The Design: I have a straight forward producer/consumer system based around
> a single queue, a producer program with a number of producer threads and s
> seporate consumer program with an number of consumer threads. Selectors are
> used to filter which messages a node recieves.
>
> The Problem: The producers succesfully places their items on to the queue (i
> have verified they are there using the web interface) however the consumers
> remain blocked and do not read them. Only when i close the JMS connection in
> the producer do the consumers jump into life and consume the messages as
> expected.
>
> This bevaior seems very weird to me, surely you shouldnt have to completely
> hang up the producer connection for the consumers to be able to read from
> the queue. I must have made a mistake somewhere(possibly with sessions) but
> the at the moment the number of things that could be wrong is to large and i
> have no idea what would cause this behaviour.
>
> Any hints as to a solution, the cause of the problem or just how to continue
> debugging would be greatly appreciated.
>
> Thanks for your time,
>
> P.S If you requrie any additional information i am happy to provide it
>
>
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/JMS-Messages-not-consumed-till-producer-connection-close-tp3985842p3985842.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>



-- 
http://fusesource.com
http://blog.garytully.com

Reply via email to