Eessh... bordering on spam...
ok... got the selector pulling selected messages by:
producer -> m.setIntProperty("Id", 444444444);
consumer -> MessageConsumer acker = (MessageConsumer)
session.createConsumer(ack,"Id=444444444");
-----Original Message-----
From: [email protected]
Sent: Thursday, April 26, 2012 5:17pm
To: [email protected]
Subject: Re: Duplating Messages
Just some more detailed info (tried messageID as this is being returned by the
logs). Any help greatly appreciated..
LOG:
main 2012-04-26 18:13:09,728 DEBUG [apache.qpid.transport.Connection] SEND:
[conn:10ea9ba] ch=0 id=9 MessageSubscribe(queue=test_queue, destination=2,
acceptMode=EXPLICIT, acquireMode=NOT_ACQUIRED, resumeTtl=0,
arguments={x-filter-jms-selector=messageId=8165b87f-8e8e-3e97-991f-51b5e45fefab})
IoReceiver - localhost/127.0.0.1:5672 2012-04-26 18:13:09,758 DEBUG
[apache.qpid.transport.Session] ID: [0] 4
IoReceiver - localhost/127.0.0.1:5672 2012-04-26 18:13:09,758 DEBUG
[apache.qpid.client.AMQSession]
Message[org.apache.qpid.client.message.UnprocessedMessage_0_10@b1cd0] received
in session
IoReceiver - localhost/127.0.0.1:5672 2012-04-26 18:13:09,760 DEBUG
[apache.qpid.transport.Connection] RECV: [conn:10ea9ba] ch=0
MessageTransfer(destination=1, acceptMode=EXPLICIT, acquireMode=NOT_ACQUIRED)
MessageProperties(contentLength=435,
messageId=8165b87f-8e8e-3e97-991f-51b5e45fefab, contentType=amqp/map,
userId=[B@190a0d6, applicationHeaders={price=0.99, name=Widget, Id=444444444})
DeliveryProperties(priority=MEDIUM, deliveryMode=PERSISTENT,
timestamp=1335469525112, exchange=, routingKey=test_queue)
-----Original Message-----
From: [email protected]
Sent: Thursday, April 26, 2012 4:56pm
To: [email protected]
Subject: Re: Duplating Messages
hey.. me again ;)
not sure if I'm doing this right... creating a consumer with JMSMessageID as a
selector but it's not returning the message even though this message does exist
(checked 5 times ;).
code:
MessageConsumer acker = (MessageConsumer)
session.createConsumer(ack,"JMSMessageID=8165b87f-8e8e-3e97-991f-51b5e45fefab");
MapMessage m = (MapMessage)acker.receive();
LOG:
main 2012-04-26 17:51:23,901 DEBUG [apache.qpid.filter.JMSSelectorFilter]
Created JMSSelectorFilter with
selector:JMSMessageID=8165b87f-8e8e-3e97-991f-51b5e45fefab
-----Original Message-----
From: "Gordon Sim" <[email protected]>
Sent: Thursday, April 26, 2012 3:02pm
To: [email protected]
Subject: Re: Duplating Messages
On 04/26/2012 07:59 PM, [email protected] wrote:
> going for the straight forward approach of creating a new connection to
> select and ack the message using ... JMSMessageID I guess?... will try it
> out...
This has the advantage of being easily transferable to 1.0 if/when needed.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
