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 2015/08/27 03:11:04 UTC
qpid-proton git commit: Fixed some compile errors and added temporary
examples for testing.
Repository: qpid-proton
Updated Branches:
refs/heads/rajith-codec a25590550 -> a43be6a41
Fixed some compile errors and added temporary examples for testing.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/a43be6a4
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/a43be6a4
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/a43be6a4
Branch: refs/heads/rajith-codec
Commit: a43be6a41f43cd00a152246269071dc8873dc6d0
Parents: a255905
Author: Rajith Attapattu <ra...@apache.org>
Authored: Wed Aug 26 21:10:23 2015 -0400
Committer: Rajith Attapattu <ra...@apache.org>
Committed: Wed Aug 26 21:10:23 2015 -0400
----------------------------------------------------------------------
.../org/apache/qpid/proton/TestReceiver.java | 27 ++++++++++++++++++++
.../java/org/apache/qpid/proton/TestSender.java | 23 +++++++++++++++++
.../apache/qpid/proton/transport2/Attach.java | 4 +--
.../org/apache/qpid/proton/transport2/Open.java | 6 ++---
.../apache/qpid/proton/transport2/Source.java | 2 +-
5 files changed, 56 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a43be6a4/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
new file mode 100644
index 0000000..7e2b778
--- /dev/null
+++ b/proton-j/src/main/java/org/apache/qpid/proton/TestReceiver.java
@@ -0,0 +1,27 @@
+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.messenger.Messenger;
+
+
+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();
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a43be6a4/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
new file mode 100644
index 0000000..be14c88
--- /dev/null
+++ b/proton-j/src/main/java/org/apache/qpid/proton/TestSender.java
@@ -0,0 +1,23 @@
+package org.apache.qpid.proton;
+import java.io.IOException;
+
+import org.apache.qpid.proton.message2.AmqpValue;
+import org.apache.qpid.proton.message2.Message;
+import org.apache.qpid.proton.messenger.Messenger;
+
+public class TestSender
+{
+ public static void main(String[] args) throws IOException
+ {
+ Messenger messenger = Proton.messenger();
+ messenger.start();
+ for (int i=0; i < 1; i++)
+ {
+ Message m = Proton.message2();
+ m.setAddress("amqp://localhost:5672");
+ m.setBody(new AmqpValue("Msg" + i));
+ messenger.put(m);
+ }
+ messenger.send();
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a43be6a4/proton-j/src/main/java/org/apache/qpid/proton/transport2/Attach.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport2/Attach.java b/proton-j/src/main/java/org/apache/qpid/proton/transport2/Attach.java
index 6066c27..e3b82da 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport2/Attach.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport2/Attach.java
@@ -301,9 +301,9 @@ public final class Attach implements Encodable, Performative
attach.setSource((Source) l.get(5));
case 9:
attach.setRcvSettleMode(l.get(4) == null ? ReceiverSettleMode.FIRST
- : ReceiverSettleMode.values()[(byte) l.get(4)]);
+ : ReceiverSettleMode.values()[(Byte) l.get(4)]);
case 10:
- attach.setSndSettleMode(l.get(3) == null ? SenderSettleMode.MIXED : SenderSettleMode.values()[(byte) l
+ attach.setSndSettleMode(l.get(3) == null ? SenderSettleMode.MIXED : SenderSettleMode.values()[(Byte) l
.get(3)]);
case 11:
attach.setRole(Boolean.TRUE.equals(l.get(2)) ? Role.RECEIVER : Role.SENDER);
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a43be6a4/proton-j/src/main/java/org/apache/qpid/proton/transport2/Open.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport2/Open.java b/proton-j/src/main/java/org/apache/qpid/proton/transport2/Open.java
index 1ebfe56..9a1de2a 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport2/Open.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport2/Open.java
@@ -239,11 +239,11 @@ public final class Open implements Encodable, Performative
open.setOutgoingLocales((String) val4);
}
case 5:
- open.setIdleTimeOut(l.get(4) == null ? 0 : (long) l.get(4));
+ open.setIdleTimeOut(l.get(4) == null ? 0 : (Long) l.get(4));
case 6:
- open.setChannelMax(l.get(3) == null ? 65535 : (short) l.get(3));
+ open.setChannelMax(l.get(3) == null ? 65535 : (Short)l.get(3));
case 7:
- open.setMaxFrameSize(l.get(2) == null ? Integer.MAX_VALUE : (int) l.get(2));
+ open.setMaxFrameSize(l.get(2) == null ? Integer.MAX_VALUE : (Integer) l.get(2));
case 8:
open.setHostname((String) l.get(1));
case 9:
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/a43be6a4/proton-j/src/main/java/org/apache/qpid/proton/transport2/Source.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/transport2/Source.java b/proton-j/src/main/java/org/apache/qpid/proton/transport2/Source.java
index 4424dee..8e8ebbd 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/transport2/Source.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/transport2/Source.java
@@ -158,7 +158,7 @@ public final class Source extends Terminus implements Encodable
Boolean dynamic = (Boolean) l.get(4);
source.setDynamic(dynamic == null ? false : dynamic);
case 7:
- source.setTimeout(l.get(3) == null ? 0 : (int) l.get(3));
+ source.setTimeout(l.get(3) == null ? 0 : (Integer) l.get(3));
case 8:
source.setExpiryPolicy(l.get(2) == null ? TerminusExpiryPolicy.SESSION_END : TerminusExpiryPolicy
.getEnum((String) l.get(2)));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org