2 files changed, 120 insertions, 0 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
new file mode 100644
index 0000000000..1da8e7673c
--- /dev/null
+++ b/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java
@@ -0,0 +1,64 @@
+package org.apache.qpid.nclient.impl;
+
+import org.apache.qpid.nclient.api.Message;
+import org.apache.qpid.nclient.api.MessageReceiver;
+import org.apache.qpid.nclient.api.MessageSender;
+import org.apache.qpidity.Header;
+import org.apache.qpidity.Option;
+import org.apache.qpidity.QpidException;
+import org.apache.qpidity.Session;
+
+public class ClientSession extends Session implements org.apache.qpid.nclient.api.Session
+{	
+	/**
+	 * ---------------------------------------------------
+	 * Message methods
+	 * ---------------------------------------------------
+	 */
+	public MessageSender createSender(String queueName) throws QpidException
+	{
+		return null;
+	}
+
+	public MessageReceiver createReceiver(String queueName, Option... options) throws QpidException
+	{
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	public void setTransacted() throws QpidException, IllegalStateException
+	{
+		// TODO Auto-generated method stub
+		
+	}
+
+	public void messageBody(byte[] src) throws QpidException
+	{
+		// TODO Auto-generated method stub
+		
+	}
+
+	public void messageClose() throws QpidException
+	{
+		// TODO Auto-generated method stub
+		
+	}
+
+	public void messageHeaders(Header... headers) throws QpidException
+	{
+		// TODO Auto-generated method stub
+		
+	}
+
+	public void messageTransfer(String destination, Message msg) throws QpidException
+	{
+		// TODO Auto-generated method stub
+		
+	}
+
+	public void messageTransfer(Option... options) throws QpidException
+	{
+		// TODO Auto-generated method stub
+		
+	}	
+}
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/impl/SessionDelegate.java b/java/client/src/main/java/org/apache/qpid/nclient/impl/SessionDelegate.java
new file mode 100644
index 0000000000..ad4f6ce117
--- /dev/null
+++ b/java/client/src/main/java/org/apache/qpid/nclient/impl/SessionDelegate.java
@@ -0,0 +1,56 @@
+package org.apache.qpid.nclient.impl;
+
+import org.apache.qpidity.CommonSessionDelegate;
+import org.apache.qpidity.Delegate;
+import org.apache.qpidity.ExchangeDeclare;
+import org.apache.qpidity.ExchangeDelete;
+import org.apache.qpidity.ExchangeQuery;
+import org.apache.qpidity.ExchangeQueryOk;
+import org.apache.qpidity.QueueBind;
+import org.apache.qpidity.QueueDeclare;
+import org.apache.qpidity.QueueDeclareOk;
+import org.apache.qpidity.QueueDelete;
+import org.apache.qpidity.QueueDeleteOk;
+import org.apache.qpidity.QueuePurge;
+import org.apache.qpidity.QueuePurgeOk;
+import org.apache.qpidity.QueueUnbind;
+import org.apache.qpidity.Session;
+
+
+public class SessionDelegate extends CommonSessionDelegate
+{
+
+	/**
+	 * --------------------------------------------
+	 * Exchange related functionality
+	 * --------------------------------------------
+	 */
+    public void exchangeDeclare(Session session, ExchangeDeclare struct) {}
+  
+    public void exchangeDelete(Session session, ExchangeDelete struct) {}
+    
+    public void exchangeQuery(Session session, ExchangeQuery struct) {}
+    
+    public void exchangeQueryOk(Session session, ExchangeQueryOk struct) {}
+
+	/**
+	 * --------------------------------------------
+	 * Queue related functionality
+	 * --------------------------------------------
+	 */    
+    public void queueDeclare(Session session, QueueDeclare struct) {}
+    
+    public void queueDeclareOk(Session session, QueueDeclareOk struct) {}
+    
+    public void queueBind(Session session, QueueBind struct) {}
+    
+    public void queueUnbind(Session session, QueueUnbind struct) {}
+    
+    public void queuePurge(Session session, QueuePurge struct) {}
+    
+    public void queuePurgeOk(Session session, QueuePurgeOk struct) {}
+    
+    public void queueDelete(Session session, QueueDelete struct) {}
+    
+    public void queueDeleteOk(Session session, QueueDeleteOk struct) {}
+}