1 files changed, 5 insertions, 22 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/nclient/MessagePartListener.java b/qpid/java/client/src/main/java/org/apache/qpid/nclient/MessagePartListener.java
index 2fdc74fc09..6f07dcb469 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/nclient/MessagePartListener.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/nclient/MessagePartListener.java
@@ -20,6 +20,7 @@ package org.apache.qpid.nclient;
 import java.nio.ByteBuffer;
 
 import org.apache.qpid.transport.Header;
+import org.apache.qpid.transport.MessageTransfer;
 
 /**
  * Assembles message parts.
@@ -33,31 +34,13 @@ import org.apache.qpid.transport.Header;
  * are transferred.
  */
 public interface MessagePartListener
-{    
-    /**
-     * Indicates the Message transfer has started.
-     * 
-     * @param transferId The message transfer ID. 
-     */
-    public void messageTransfer(int transferId);
-    
-    /**
-     * Add the following a header to the message being received.
-     *
-     * @param header Either <code>DeliveryProperties</code> or <code>ApplicationProperties</code>
-     */
-    public void messageHeader(Header header);
+{
 
     /**
-     * Add the following byte array to the content of the message being received
+     * Inform the listener of the message transfer
      *
-     * @param src Data to be added or streamed.
-     */
-    public void data(ByteBuffer src);
-
-    /**
-     * Indicates that the message has been fully received. 
+     * @param xfr the message transfer object
      */
-    public void messageReceived();
+    public void messageTransfer(MessageTransfer xfr);
 
 }