diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2007-10-17 00:15:14 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2007-10-17 00:15:14 +0000 |
| commit | c8fd885b74791ba1349de8cfc8e7c3f9222eef7e (patch) | |
| tree | 5ca92e1d06b0783a4fbb98a87c491ab114a71bce | |
| parent | b4d6577049bd648fd1407c0283a63d66b5d6bbdf (diff) | |
| download | qpid-python-c8fd885b74791ba1349de8cfc8e7c3f9222eef7e.tar.gz | |
Isolated test case to show the selector problem
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@585295 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpidity/nclient/JMSTestCase.java | 42 |
1 files changed, 28 insertions, 14 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpidity/nclient/JMSTestCase.java b/qpid/java/client/src/main/java/org/apache/qpidity/nclient/JMSTestCase.java index 42dad7329e..3c13327b52 100644 --- a/qpid/java/client/src/main/java/org/apache/qpidity/nclient/JMSTestCase.java +++ b/qpid/java/client/src/main/java/org/apache/qpidity/nclient/JMSTestCase.java @@ -1,30 +1,44 @@ package org.apache.qpidity.nclient; -import org.apache.qpidity.njms.ConnectionFactoryImpl; -import org.apache.qpidity.njms.TopicImpl; +import org.apache.qpid.client.AMQConnection; +import org.apache.qpid.client.AMQTopic; +import org.apache.qpid.framing.AMQShortString; public class JMSTestCase { + public static void main(String[] args) { + try { - javax.jms.Connection con = (new ConnectionFactoryImpl("localhost",5672, "test", "guest","guest")).createConnection(); + javax.jms.Connection con = new AMQConnection("qpid:password=guest;username=guest;client_id=clientid;virtualhost=test@tcp:127.0.0.1:5672"); con.start(); - + javax.jms.Session ssn = con.createSession(false, 1); - - javax.jms.Destination dest = new TopicImpl("myTopic"); + + javax.jms.Destination dest = new AMQTopic(new AMQShortString("amq.topic"),"myTopic"); javax.jms.MessageProducer prod = ssn.createProducer(dest); - javax.jms.MessageConsumer cons = ssn.createConsumer(dest); - - javax.jms.BytesMessage msg = ssn.createBytesMessage(); - msg.writeInt(123); + javax.jms.MessageConsumer cons = ssn.createConsumer(dest,"targetMessage = TRUE"); + + javax.jms.TextMessage msg = ssn.createTextMessage(); + msg.setText("This is a test message"); + msg.setBooleanProperty("targetMessage", false); prod.send(msg); - - javax.jms.BytesMessage m = (javax.jms.BytesMessage)cons.receive(); - System.out.println("Data : " + m.readInt()); - + + msg.setBooleanProperty("targetMessage", true); + prod.send(msg); + + javax.jms.TextMessage m = (javax.jms.TextMessage)cons.receiveNoWait(); + + if (m == null) + { + System.out.println("message is null"); + } + else + { + System.out.println("message is not null"); + } } catch(Exception e) { |