From a24e1a318cb6b8dc137149ce9342b8ed37a7e6bd Mon Sep 17 00:00:00 2001
From: Rajith Muditha Attapattu <rajith@apache.org>
Date: Tue, 31 Jul 2007 15:10:37 +0000
Subject: changes to message methods

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@561356 13f79535-47bb-0310-9956-ffa450edef68
---
 .../apache/qpid/nclient/api/MessageReceiver.java   |  7 ++++---
 .../java/org/apache/qpid/nclient/api/Session.java  | 22 ++++++++++++++++++----
 2 files changed, 22 insertions(+), 7 deletions(-)

(limited to 'qpid/java')

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.
-- 
cgit v1.2.1