Messageconsumer is associated with your Session, so.. the behavior you were
getting is correct. (I mean.. it was correct that you got an error :-) )
anyway... By the time I was coming to write a post I saw your message.
I was going to post the testcase that I got, and didn't get any failure. Just
for reference now (as you got your problem solved), I will paste the testcase
here:
Cheers,
Clebert
| public void testSelectiveOnServerId() throws Exception
| {
| Connection conn = cf.createConnection();
| conn.start();
|
| Session session = conn.createSession(false,
Session.AUTO_ACKNOWLEDGE);
| MessageProducer prod = session.createProducer(queue);
| prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
|
| int
serverId=((ConnectionState)(((ClientConnectionDelegate)((JBossConnection)conn).getDelegate()).getState())).getServerID();
|
| String selector = "serverID = " + serverId;
| MessageConsumer serverConsumer = session.createConsumer(queue,
selector);
| conn.start();
|
| Message redMessage = session.createMessage();
| redMessage.setStringProperty("color", "red");
|
| Message blueMessage = session.createMessage();
| blueMessage.setStringProperty("color", "blue");
| blueMessage.setIntProperty("serverID",serverId);
|
| prod.send(redMessage);
| prod.send(blueMessage);
|
| Message rec = serverConsumer.receive(3000);
| assertNotNull(rec);
| assertNull(serverConsumer.receive(1000));
| assertEquals(blueMessage.getJMSMessageID(), rec.getJMSMessageID());
| assertEquals("blue", rec.getStringProperty("color"));
|
|
| serverConsumer.close();
|
| session.close();
| }
|
|
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=3975867#3975867
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=3975867
_______________________________________________
jboss-user mailing list
[email protected]
https://lists.jboss.org/mailman/listinfo/jboss-user
