1 files changed, 50 insertions, 0 deletions
diff --git a/java/newclient/src/main/java/org/apache/qpid/nclient/impl/AMQPCallbackHelper.java b/java/newclient/src/main/java/org/apache/qpid/nclient/impl/AMQPCallbackHelper.java
new file mode 100644
index 0000000000..54ea9ac01b
--- /dev/null
+++ b/java/newclient/src/main/java/org/apache/qpid/nclient/impl/AMQPCallbackHelper.java
@@ -0,0 +1,50 @@
+package org.apache.qpid.nclient.impl;
+
+import org.apache.log4j.Logger;
+import org.apache.qpid.AMQException;
+import org.apache.qpid.framing.AMQMethodBody;
+import org.apache.qpid.nclient.amqp.AMQPCallBack;
+
+public class AMQPCallbackHelper extends AMQPCallBack
+{
+	private static final Logger _logger = Logger.getLogger(AMQPCallbackHelper.class);
+	
+	private AMQMethodBody _body;
+	private Exception _e;
+	private boolean _isError;
+	
+	@Override
+	public void brokerResponded(AMQMethodBody body)
+	{
+		_body = body;
+		_logger.debug("[Broker has responded " + body);
+		_isError = false;
+		this.setIsComplete(true);
+	}
+
+	@Override
+	public void brokerRespondedWithError(AMQException e)
+	{
+		_e = e;
+		_logger.debug("[Broker has responded with an error" + e.getMessage(),e);
+	   _isError = true;	
+	   this.setIsComplete(true);
+	}
+
+	public AMQMethodBody getMethodBody()
+	{
+		return _body;
+	}
+
+	public Exception getException()
+	{
+		return _e;
+	}
+	
+	public boolean isError()
+	{
+		return _isError;
+	}
+	
+
+}