qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From raj...@apache.org
Subject [1/5] qpid-proton git commit: Changes to test programs.
Date Mon, 05 Oct 2015 16:46:47 GMT
Repository: qpid-proton
Updated Branches:
  refs/heads/rajith-codec 8ff9063d6 -> 12ff4f5cb


Changes to test programs.


Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/e7d9c597
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/e7d9c597
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/e7d9c597

Branch: refs/heads/rajith-codec
Commit: e7d9c5975e4aefeae76140df05460c5fc3aa31b2
Parents: 8ff9063
Author: Rajith Attapattu <rajith@apache.org>
Authored: Sun Oct 4 18:11:16 2015 -0400
Committer: Rajith Attapattu <rajith@apache.org>
Committed: Sun Oct 4 18:11:16 2015 -0400

----------------------------------------------------------------------
 .../java/org/apache/qpid/proton/TestReceiver.java    | 15 ++++-----------
 .../main/java/org/apache/qpid/proton/TestSender.java |  2 +-
 2 files changed, 5 insertions(+), 12 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e7d9c597/proton-j/src/main/java/org/apache/qpid/proton/TestReceiver.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/TestReceiver.java b/proton-j/src/main/java/org/apache/qpid/proton/TestReceiver.java
index 7e2b778..4143caf 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/TestReceiver.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/TestReceiver.java
@@ -1,13 +1,7 @@
 package org.apache.qpid.proton;
 import java.io.IOException;
 
-import org.apache.qpid.proton.Proton;
-import org.apache.qpid.proton.amqp.UnsignedByte;
-import org.apache.qpid.proton.amqp.UnsignedInteger;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.proton.amqp.UnsignedShort;
-import org.apache.qpid.proton.amqp.messaging.AmqpValue;
-import org.apache.qpid.proton.message.Message;
+import org.apache.qpid.proton.message2.Message;
 import org.apache.qpid.proton.messenger.Messenger;
 
 
@@ -15,13 +9,12 @@ public class TestReceiver
 {
     public static void main(String[] args) throws IOException
     {
-        System.out.println("UnsignedInteger.MAX_VALUE : " + UnsignedInteger.MAX_VALUE);
-        System.out.println("UnsignedShort.MAX_VALUE : " + UnsignedShort.MAX_VALUE);
-        System.out.println("UnsignedShort.-1 : " + UnsignedShort.valueOf((short)-1));
         Messenger messenger = Proton.messenger();
         messenger.start();
         messenger.subscribe("amqp://~localhost:5672");
-        messenger.recv();        
+        messenger.recv(); 
+        Message m = messenger.get();
+        System.out.println("Received " + m);
     }
 
 }

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e7d9c597/proton-j/src/main/java/org/apache/qpid/proton/TestSender.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/TestSender.java b/proton-j/src/main/java/org/apache/qpid/proton/TestSender.java
index be14c88..f522aa8 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/TestSender.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/TestSender.java
@@ -7,7 +7,7 @@ import org.apache.qpid.proton.messenger.Messenger;
 
 public class TestSender
 {
-    public static void main(String[] args) throws IOException
+    public static void main(String[] args) throws IOException, InterruptedException
     {
         Messenger messenger = Proton.messenger();
         messenger.start();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message