Fixed compilation errors

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

4 files changed, 52 insertions, 56 deletions

diff --git a/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java b/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java
index 714601032a..f3ef74a2e9 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java
@@ -1,5 +1,6 @@
 package org.apache.qpid.nclient.impl;
 
+import java.util.HashMap;
 import java.util.Map;
 
 import org.apache.qpidity.api.Message;
@@ -12,6 +13,8 @@ import org.apache.qpidity.*;
 public class ClientSession implements org.apache.qpid.nclient.Session
 {
 
+	Map<String,MessagePartListener> messagListeners = new HashMap<String,MessagePartListener>();    
+	
     //------------------------------------------------------
     //                 Session housekeeping methods
     //------------------------------------------------------
@@ -68,11 +71,6 @@ public class ClientSession implements org.apache.qpid.nclient.Session
         //To change body of implemented methods use File | Settings | File Templates.
     }
 
-    public void setMessageListener(String destination, MessagePartListener listener)
-    {
-        //To change body of implemented methods use File | Settings | File Templates.
-    }
-
     public void messageAcknowledge(Range... range) throws QpidException
     {
         //To change body of implemented methods use File | Settings | File Templates.
@@ -147,4 +145,9 @@ public class ClientSession implements org.apache.qpid.nclient.Session
     {
         //To change body of implemented methods use File | Settings | File Templates.
     }
+    
+    public void setMessageListener(String destination,MessagePartListener listener)
+    {
+    	messagListeners.put(destination, listener);
+    }
 }
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSessionDelegate.java b/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSessionDelegate.java
index 855fd1187f..aee0e874af 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSessionDelegate.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSessionDelegate.java
@@ -1,12 +1,53 @@
 package org.apache.qpid.nclient.impl;
 
+import org.apache.qpid.nclient.MessagePartListener;
 import org.apache.qpidity.CommonSessionDelegate;
 import org.apache.qpidity.ExchangeQueryOk;
+import org.apache.qpidity.Header;
+import org.apache.qpidity.MessageTransfer;
+import org.apache.qpidity.Option;
+import org.apache.qpidity.QpidException;
 import org.apache.qpidity.Session;
 
 
 public class ClientSessionDelegate extends CommonSessionDelegate
 {
+	
+	/*@Override public void messageTransfer(Session context, MessageTransfer struct)
+    {
+        MessagePartListener 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
+    {
+        MessagePartListener l = context.messagListeners.get(destination);
+        l.data(src);
+    }
+
+    public void endData(Session context,String destination) throws QpidException
+    {
+        MessagePartListener l = context.messagListeners.get(destination);
+        l.endData();
+    }
+
+    public void messageHeaders(Session context,String destination,Header... headers) throws QpidException
+    {
+        MessagePartListener l = context.messagListeners.get(destination);
+        l.endData();
+    }*/
+
 
     // --------------------------------------------
     //   Exchange related functionality
diff --git a/java/common/src/main/java/org/apache/qpidity/CommonSessionDelegate.java b/java/common/src/main/java/org/apache/qpidity/CommonSessionDelegate.java
index 7ae9a99fd2..cd9d31b1c2 100644
--- a/java/common/src/main/java/org/apache/qpidity/CommonSessionDelegate.java
+++ b/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/java/common/src/main/java/org/apache/qpidity/Session.java b/java/common/src/main/java/org/apache/qpidity/Session.java
index 32fa5f55b3..666d6463c0 100644
--- a/java/common/src/main/java/org/apache/qpidity/Session.java
+++ b/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);
-    }
+    }   
 
 }