diff options
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java | 7 | ||||
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java | 22 |
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. |