changes to message methods

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@561356 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 22 insertions, 7 deletions

diff --git a/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java b/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
index be5c9298ae..3d58e551cd 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
@@ -18,11 +18,11 @@
  */
 package org.apache.qpid.nclient.api;
 
-import org.apache.qpidity.QpidException;
-import org.apache.qpidity.Option;
-
 import java.util.Set;
 
+import org.apache.qpidity.Option;
+import org.apache.qpidity.QpidException;
+
 /**
  * Used to receive messages from a queue
  */
@@ -33,6 +33,7 @@ public interface MessageReceiver extends Resource
      *
      * @return This receiver set of options.
      */
+	
     public Set<Option> getOptions();
 
     /**
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java b/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
index 33568cb6a8..954ed1dbd1 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
@@ -23,6 +23,7 @@ import java.util.UUID;
 
 import org.apache.qpidity.QpidException;
 import org.apache.qpidity.Option;
+import org.apache.qpidity.Header;
 
 /**
  * A session is associated with a connection.
@@ -74,15 +75,28 @@ public interface Session
      * -------------------------------------
      */
 
-    /**
-     * Create a message sender for sending messages to queue queueName.
+	/**
+     * Transfer the given message.
      *
      * @param queueName The queue this sender is sending messages.
      * @return A sender for queue queueName
      * @throws QpidException If the session fails to create the sended due to some error
      */
-    public MessageSender createSender(String queueName) throws QpidException;
-    //Todo: Do we need to define more specific exception like queue name not valid?
+    public void messageTransfer(String destination,Message msg)throws QpidException; 
+    
+    public void messageTransfer(Option... options)throws QpidException; 
+    
+    /**
+     * Transfer the given message.
+     *
+     * @param 
+     * @throws QpidException If the session fails to create the sended due to some error
+     */
+    public void messageHeaders(Header ... headers)throws QpidException; 
+    		     
+    public void messageBody(byte[] src)throws QpidException; 
+    		     
+    public void messageClose()throws QpidException; 
 
     /**
      * Create a message receiver for receiving messages from queue queueName.