1 files changed, 0 insertions, 79 deletions
diff --git a/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java b/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java
deleted file mode 100644
index e57dd08448..0000000000
--- a/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java
+++ /dev/null
@@ -1,79 +0,0 @@
-package org.apache.qpidity.nclient.impl;
-
-import java.nio.ByteBuffer;
-
-import org.apache.qpidity.ErrorCode;
-
-import org.apache.qpidity.nclient.MessagePartListener;
-
-import org.apache.qpidity.QpidException;
-import org.apache.qpidity.transport.Data;
-import org.apache.qpidity.transport.Header;
-import org.apache.qpidity.transport.MessageReject;
-import org.apache.qpidity.transport.MessageTransfer;
-import org.apache.qpidity.transport.Range;
-import org.apache.qpidity.transport.Session;
-import org.apache.qpidity.transport.SessionDetached;
-import org.apache.qpidity.transport.SessionDelegate;
-
-
-public class ClientSessionDelegate extends SessionDelegate
-{    
-    private MessageTransfer _currentTransfer;
-    private MessagePartListener _currentMessageListener;
-    
-    @Override public void sessionDetached(Session ssn, SessionDetached dtc)
-    {
-        ((ClientSession)ssn).notifyException(new QpidException("", ErrorCode.get(dtc.getCode().getValue()),null));
-    }
-    
-    //  --------------------------------------------
-    //   Message methods
-    // --------------------------------------------
-    @Override public void data(Session ssn, Data data)
-    {
-        for (ByteBuffer b : data.getFragments())
-        {    
-            _currentMessageListener.data(b);
-        }
-        if (data.isLast())
-        {
-            _currentMessageListener.messageReceived();
-        }
-        
-    }
-
-    @Override public void header(Session ssn, Header header)
-    {
-        _currentMessageListener.messageHeader(header);
-        if( header.hasNoPayload())
-        {
-           _currentMessageListener.data(ByteBuffer.allocate(0));
-           _currentMessageListener.messageReceived();
-        }
-    }
-
-
-    @Override public void messageTransfer(Session session, MessageTransfer currentTransfer)
-    {
-        _currentTransfer = currentTransfer;
-        _currentMessageListener = ((ClientSession)session).getMessageListeners().get(currentTransfer.getDestination());
-        _currentMessageListener.messageTransfer(currentTransfer.getId());
-    }
-    
-    @Override public void messageReject(Session session, MessageReject struct) 
-    {
-        for (Range range : struct.getTransfers())
-        {
-            for (long l = range.getLower(); l <= range.getUpper(); l++)
-            {
-                System.out.println("message rejected: " +
-                        session.getCommand((int) l));
-            }
-        }
-        ((ClientSession)session).setRejectedMessages(struct.getTransfers());
-        ((ClientSession)session).notifyException(new QpidException("Message Rejected",ErrorCode.MESSAGE_REJECTED,null));
-        session.processed(struct);
-    }
-
-}