Hi Rob,
We are using the Java Broker. Version 0.20.
Right now we are running stock configuration (test).
I have a Java class that is popping items onto the queue, and then pulling
them all off until none are left.
I'm using a QueueProducer, and initializing it with:
Destination dest = null;
try {
dest = new AMQAnyDestination("ADDR:" + queue + "; {
create:always }");
} catch (URISyntaxException ex) {
logger.error("URI Syntax Exception: " + ex.getMessage());
}
MessageProducer messageProducer = null;
try {
messageProducer = _session.createProducer(dest);
logger.info("Successfully created Producer: " + dest.toString()
+ ".");
} catch (JMSException ex) {
logger.error("JMS Exception: " + ex.getMessage());
}
return new QueueProducer(_session, messageProducer );
I then pull them all off by creating a QueueConsumer, until
receive(timeout) returns null and output each message.
If I put in the queue:
apple
banana
cherry
durian
I get out:
cherry
banana
apple
durian
-----------
when I put in:
apple
apple
apple
apple
I get out:
apple
Ed
On Thu, Jun 13, 2013 at 3:42 AM, Rob Godfrey <rob.j.godf...@gmail.com>wrote:
> No - that wouldn't be the expected behaviour of queues... can you give a
> little more information about your test scenario... which broker are you
> using (Java or C++)?, how did you set up the queue? how are you verifying
> that only one message is actually on the queue?
>
> There are queue types (such as LVQs) which replace older versions of the
> "same" message with newer ones... or there are ways of sending messages
> which cause the messages to be discarded if no-one is listening to pick
> them up. Without a few more details it's a bit difficult to explain
> exactly what it is that you are seeing,
>
> Cheers,
> Rob
>
> PS I see you tried to ask this question on the #qpid IRC channel yesterday
> and didn't get any response... apologies - a lot of us are based in Europe
> and so don't necessarily pick up stuff on there overnight.
>
>
> On 13 June 2013 04:13, Ed Bragg <ebr...@t-sciences.com> wrote:
>
> > If I put the same TextMessage in a queue more than once, say 10 times, I
> > always end up with just one item in the queue.
> >
> > ie. {"query":"apple"}
> >
> > Is this expected behavior for AMQP and Queues?
> >
> > Regards,
> > Ed Bragg
> >
> >
> > --
> > ---
> > Ed Bragg
> > iHarvest Product Manager
> > Principle Software Engineer
> > Thermopylae Sciences + Technology
> > e-mail: ebr...@t-sciences.com
> > cell: (540) 272-1866
> > office: (703) 740-8768
> > ---
> >
>
--
---
Ed Bragg
iHarvest Product Manager
Principle Software Engineer
Thermopylae Sciences + Technology
e-mail: ebr...@t-sciences.com
cell: (540) 272-1866
office: (703) 740-8768
---
