Author: rajith
Date: Tue Jul 31 08:10:37 2007
New Revision: 561356
URL: http://svn.apache.org/viewvc?view=rev&rev=561356
Log:
changes to message methods
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java?view=diff&rev=561356&r1=561355&r2=561356
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
Tue Jul 31 08:10:37 2007
@@ -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 @@
*
* @return This receiver set of options.
*/
+
public Set<Option> getOptions();
/**
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java?view=diff&rev=561356&r1=561355&r2=561356
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
Tue Jul 31 08:10:37 2007
@@ -23,6 +23,7 @@
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 @@
* -------------------------------------
*/
- /**
- * 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.
