You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2007/09/21 04:41:41 UTC
svn commit: r577963 - in
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/interop:
./ BasicInteropTest.java
Author: rajith
Date: Thu Sep 20 19:41:41 2007
New Revision: 577963
URL: http://svn.apache.org/viewvc?rev=577963&view=rev
Log:
added isolated test cases for interop with c++ broker
Added:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/interop/
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/interop/BasicInteropTest.java
Added: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/interop/BasicInteropTest.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/interop/BasicInteropTest.java?rev=577963&view=auto
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/interop/BasicInteropTest.java (added)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/interop/BasicInteropTest.java Thu Sep 20 19:41:41 2007
@@ -0,0 +1,126 @@
+package org.apache.qpidity.nclient.interop;
+
+import org.apache.qpidity.QpidException;
+import org.apache.qpidity.api.Message;
+import org.apache.qpidity.nclient.Client;
+import org.apache.qpidity.nclient.Connection;
+import org.apache.qpidity.nclient.ExceptionListener;
+import org.apache.qpidity.nclient.Session;
+import org.apache.qpidity.nclient.util.MessageListener;
+import org.apache.qpidity.nclient.util.MessagePartListenerAdapter;
+import org.apache.qpidity.transport.DeliveryProperties;
+import org.apache.qpidity.transport.ExchangeQueryResult;
+import org.apache.qpidity.transport.Future;
+import org.apache.qpidity.transport.RangeSet;
+
+public class BasicInteropTest implements ExceptionListener
+{
+
+ private Session session;
+ private Connection conn;
+ private String host;
+
+ public BasicInteropTest(String host)
+ {
+ this.host = host;
+ }
+
+ public void testCreateConnection(){
+ System.out.println("------- Creating connection--------");
+ conn = Client.createConnection();
+ try{
+ conn.connect(host, 5672, "test", "guest", "guest");
+ }catch(Exception e){
+ System.out.println("------- Error Creating connection--------");
+ e.printStackTrace();
+ System.exit(1);
+ }
+ System.out.println("------- Connection created Suscessfully --------");
+ }
+
+ public void testCreateSession(){
+ System.out.println("------- Creating session --------");
+ session = conn.createSession(0);
+ System.out.println("------- Session created sucessfully --------");
+ }
+
+ public void testExchange(){
+ System.out.println("------- Creating an exchange --------");
+ session.exchangeDeclare("test", "amq.direct", "", null);
+ session.sync();
+ System.out.println("------- Exchange created --------");
+ }
+
+ public void testQueue(){
+ System.out.println("------- Creating a queue --------");
+ session.queueDeclare("testQueue", "", null);
+ session.sync();
+ System.out.println("------- Queue created --------");
+
+ System.out.println("------- Binding a queue --------");
+ session.queueBind("testQueue", "test", "testKey", null);
+ session.sync();
+ System.out.println("------- Queue bound --------");
+ }
+
+ public void testSendMessage(){
+ System.out.println("------- Sending a message --------");
+ session.messageTransfer("test", Session.TRANSFER_CONFIRM_MODE_REQUIRED, Session.TRANSFER_ACQUIRE_MODE_PRE_ACQUIRE);
+ session.header(new DeliveryProperties().setRoutingKey("testKey"));
+ session.data("TestMessage");
+ session.endData();
+ session.sync();
+ System.out.println("------- Message sent --------");
+ }
+
+ public void testSubscribe(){
+ System.out.println("------- Sending a subscribe --------");
+ session.messageSubscribe("testQueue", "myDest",
+ Session.TRANSFER_CONFIRM_MODE_REQUIRED,
+ Session.TRANSFER_ACQUIRE_MODE_PRE_ACQUIRE,
+ new MessagePartListenerAdapter(new MessageListener(){
+
+ public void onMessage(Message message)
+ {
+ System.out.println("--------Message Received--------");
+ System.out.println(message.toString());
+ System.out.println("--------/Message Received--------");
+ RangeSet ack = new RangeSet();
+ ack.add(message.getMessageTransferId(),message.getMessageTransferId());
+ session.messageAcknowledge(ack);
+ }
+
+ }),
+ null);
+
+ System.out.println("------- Setting Credit mode --------");
+ session.messageFlowMode("myDest", Session.MESSAGE_FLOW_MODE_WINDOW);
+ System.out.println("------- Setting Credit --------");
+ session.messageFlow("myDest", Session.MESSAGE_FLOW_UNIT_MESSAGE, 1);
+ }
+
+ public void onException(QpidException e)
+ {
+ System.out.println("------- Broker Notified an error --------");
+ System.out.println("------- " + e.getErrorCode() + " --------");
+ System.out.println("------- " + e.getMessage() + " --------");
+ System.out.println("------- /Broker Notified an error --------");
+ }
+
+ public static void main(String[] args)
+ {
+ String host = "0.0.0.0";
+ if (args.length>0)
+ {
+ host = args[0];
+ }
+
+ BasicInteropTest t = new BasicInteropTest(host);
+ t.testCreateConnection();
+ t.testCreateSession();
+ t.testExchange();
+ t.testQueue();
+ t.testSubscribe();
+ t.testSendMessage();
+ }
+}