1 files changed, 23 insertions, 0 deletions
diff --git a/java/newclient/src/main/java/org/apache/qpid/nclient/amqp/AMQPCallBack.java b/java/newclient/src/main/java/org/apache/qpid/nclient/amqp/AMQPCallBack.java
new file mode 100644
index 0000000000..49575be8d2
--- /dev/null
+++ b/java/newclient/src/main/java/org/apache/qpid/nclient/amqp/AMQPCallBack.java
@@ -0,0 +1,23 @@
+package org.apache.qpid.nclient.amqp;
+
+import org.apache.qpid.AMQException;
+import org.apache.qpid.framing.AMQMethodBody;
+
+public abstract class AMQPCallBack 
+{
+	private boolean _isComplete = false;
+	
+	public abstract void brokerResponded(AMQMethodBody body);
+	
+	public abstract void brokerRespondedWithError(AMQException e);
+	
+	public void setIsComplete(boolean isComplete)
+	{
+		_isComplete = isComplete;
+	}
+	
+	public boolean isComplete()
+	{
+		return _isComplete;		
+	}
+}