diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2007-08-08 17:49:47 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2007-08-08 17:49:47 +0000 |
| commit | e06c777404e9dc5906f77cf2054ec578c789dd78 (patch) | |
| tree | 45946dd57086068ad395063d4e966acdf25e0b1f /qpid/java/common | |
| parent | 5838439eb64e0d812744405a5a2b172e52ab9f61 (diff) | |
| download | qpid-python-e06c777404e9dc5906f77cf2054ec578c789dd78.tar.gz | |
changed the API based on the discussions with rafi and arnaud. also fixed the compilation errors
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@563959 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common')
3 files changed, 5 insertions, 8 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/ProtocolHeader.java b/qpid/java/common/src/main/java/org/apache/qpidity/ProtocolHeader.java index 5e397ae574..4e654f706b 100644 --- a/qpid/java/common/src/main/java/org/apache/qpidity/ProtocolHeader.java +++ b/qpid/java/common/src/main/java/org/apache/qpidity/ProtocolHeader.java @@ -66,8 +66,8 @@ class ProtocolHeader buf.put(AMQP); buf.put((byte) 1); buf.put((byte) 1); - buf.put((byte) 0); - buf.put((byte) 10); + buf.put( major); + buf.put(minor); buf.flip(); return buf; } diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/Session.java b/qpid/java/common/src/main/java/org/apache/qpidity/Session.java index 228c4cf495..067fc8c83c 100644 --- a/qpid/java/common/src/main/java/org/apache/qpidity/Session.java +++ b/qpid/java/common/src/main/java/org/apache/qpidity/Session.java @@ -21,11 +21,8 @@ package org.apache.qpidity; import java.nio.ByteBuffer; - import java.util.HashMap; import java.util.Map; - -import org.apache.qpidity.api.Message; /** * Session * @@ -160,7 +157,7 @@ public class Session extends Invoker channel.data(bytes); } - public void end() + public void endData() { channel.end(); } diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/ToyClient.java b/qpid/java/common/src/main/java/org/apache/qpidity/ToyClient.java index 2e27dc8574..4ec838bc35 100644 --- a/qpid/java/common/src/main/java/org/apache/qpidity/ToyClient.java +++ b/qpid/java/common/src/main/java/org/apache/qpidity/ToyClient.java @@ -79,11 +79,11 @@ class ToyClient extends SessionDelegate ssn.headers(new DeliveryProperties(), new MessageProperties()); ssn.data("this is the data"); - ssn.end(); + ssn.endData(); ssn.messageTransfer("fdsa", (short) 0, (short) 1); ssn.data("this should be rejected"); - ssn.end(); + ssn.endData(); ssn.sync(); } |