Fixed compilation errors

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@562479 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 3 insertions, 51 deletions

diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/CommonSessionDelegate.java b/qpid/java/common/src/main/java/org/apache/qpidity/CommonSessionDelegate.java
index 7ae9a99fd2..cd9d31b1c2 100644
--- a/qpid/java/common/src/main/java/org/apache/qpidity/CommonSessionDelegate.java
+++ b/qpid/java/common/src/main/java/org/apache/qpidity/CommonSessionDelegate.java
@@ -20,9 +20,6 @@
  */
 package org.apache.qpidity;
 
-import org.apache.qpidity.api.StreamingMessageListener;
-
-
 /**
  * CommonSessionDelegate
  */
@@ -44,41 +41,5 @@ public class CommonSessionDelegate extends Delegate<Session>
 
     @Override public void sessionSuspend(Session session, SessionSuspend struct) {}
 
-    @Override public void sessionDetached(Session session, SessionDetached struct) {}
-
-    @Override public void messageTransfer(Session context, MessageTransfer struct)
-    {
-        StreamingMessageListener l = context.messagListeners.get(struct.getDestination());
-        l.messageTransfer(struct.getDestination(),new Option[0]);
-    }
-
-    // ---------------------------------------------------------------
-    //  Non generated methods - but would like if they are also generated.
-    //  These methods should be called from Body and Header Handlers.
-    //  If these methods are generated as part of the delegate then
-    //  I can call these methods from the BodyHandler and HeaderHandler
-    //  in a generic way
-
-    //  I have used destination to indicate my intent of receiving
-    //  some form of correlation to know which consumer this data belongs to.
-    //  It can be anything as long as I can make the right correlation
-    // ----------------------------------------------------------------
-    public void data(Session context,String destination,byte[] src) throws QpidException
-    {
-        StreamingMessageListener l = context.messagListeners.get(destination);
-        l.data(src);
-    }
-
-    public void endData(Session context,String destination) throws QpidException
-    {
-        StreamingMessageListener l = context.messagListeners.get(destination);
-        l.endData();
-    }
-
-    public void messageHeaders(Session context,String destination,Header... headers) throws QpidException
-    {
-        StreamingMessageListener l = context.messagListeners.get(destination);
-        l.endData();
-    }
-
+    @Override public void sessionDetached(Session session, SessionDetached struct) {}    
 }
diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/Session.java b/qpid/java/common/src/main/java/org/apache/qpidity/Session.java
index 32fa5f55b3..666d6463c0 100644
--- a/qpid/java/common/src/main/java/org/apache/qpidity/Session.java
+++ b/qpid/java/common/src/main/java/org/apache/qpidity/Session.java
@@ -24,8 +24,6 @@ import java.util.HashMap;
 import java.util.Map;
 
 import org.apache.qpidity.api.Message;
-import org.apache.qpidity.api.StreamingMessageListener;
-
 /**
  * Session
  *
@@ -39,9 +37,7 @@ public class Session extends Invoker
     Channel channel;
     private int command_id = 0;
     // XXX
-    final Map<Integer,Handler<Struct>> handlers = new HashMap<Integer,Handler<Struct>>();
-    
-    Map<String,StreamingMessageListener> messagListeners = new HashMap<String,StreamingMessageListener>();    
+    final Map<Integer,Handler<Struct>> handlers = new HashMap<Integer,Handler<Struct>>();   
 
     public void attach(Channel channel)
     {
@@ -113,11 +109,6 @@ public class Session extends Invoker
     public void messageRelease() throws QpidException
     {
         // TODO Auto-generated method stub
-    }
-
-    public void setMessageListener(String destination,StreamingMessageListener listener)
-    {
-    	messagListeners.put(destination, listener);
-    }
+    }   
 
 }