summaryrefslogtreecommitdiff
path: root/java/common
diff options
context:
space:
mode:
Diffstat (limited to 'java/common')
-rw-r--r--java/common/src/main/java/org/apache/qpidity/Session.java101
1 files changed, 48 insertions, 53 deletions
diff --git a/java/common/src/main/java/org/apache/qpidity/Session.java b/java/common/src/main/java/org/apache/qpidity/Session.java
index 48860309a0..32fa5f55b3 100644
--- a/java/common/src/main/java/org/apache/qpidity/Session.java
+++ b/java/common/src/main/java/org/apache/qpidity/Session.java
@@ -69,60 +69,55 @@ public class Session extends Invoker
// -----------------------------------------
// Messaging Methods
// ------------------------------------------
- public void messageTransfer(String destination, Message msg) throws QpidException
- {
-
- }
-
- public void data(byte[] src) throws QpidException
- {
- // TODO Auto-generated method stub
-
- }
-
- public void endData() throws QpidException
- {
- // TODO Auto-generated method stub
-
- }
-
- public void messageHeaders(Header... headers) throws QpidException
- {
- // TODO Auto-generated method stub
-
- }
-
- public void messageTransfer(String destination,Option... options) throws QpidException
- {
- // TODO Auto-generated method stub
-
- }
-
- public void messageAcknowledge() throws QpidException
- {
- // TODO Auto-generated method stub
- }
-
- public boolean messageAcquire() throws QpidException
- {
- // TODO Auto-generated method stub
- return false;
- }
-
- public void messageReject() throws QpidException
- {
- // TODO Auto-generated method stub
-
- }
-
- public void messageRelease() throws QpidException
- {
- // TODO Auto-generated method stub
- }
+ public void messageTransfer(String destination, Message msg, Option ... _options) throws QpidException
+ {
- public void addMessageListener(String destination,StreamingMessageListener listener)
+ }
+
+ public void data(byte[] src) throws QpidException
+ {
+ // TODO Auto-generated method stub
+ }
+
+ public void endData() throws QpidException
+ {
+ // TODO Auto-generated method stub
+ }
+
+ public void messageHeaders(Header... headers) throws QpidException
+ {
+ // TODO Auto-generated method stub
+ }
+
+ public void messageTransfer(String destination,Option... options) throws QpidException
+ {
+ // TODO Auto-generated method stub
+ }
+
+ public void messageAcknowledge() throws QpidException
+ {
+ // TODO Auto-generated method stub
+ }
+
+ public boolean messageAcquire() throws QpidException
+ {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ public void messageReject() throws QpidException
+ {
+ // TODO Auto-generated method stub
+ }
+
+ public void messageRelease() throws QpidException
+ {
+ // TODO Auto-generated method stub
+ }
+
+ public void setMessageListener(String destination,StreamingMessageListener listener)
{
messagListeners.put(destination, listener);
- }
-
+ }
+
}