1 files changed, 78 insertions, 0 deletions
diff --git a/java/newclient/src/main/java/org/apache/qpid/nclient/amqp/event/AMQPMethodEvent.java b/java/newclient/src/main/java/org/apache/qpid/nclient/amqp/event/AMQPMethodEvent.java
new file mode 100644
index 0000000000..c6641890e0
--- /dev/null
+++ b/java/newclient/src/main/java/org/apache/qpid/nclient/amqp/event/AMQPMethodEvent.java
@@ -0,0 +1,78 @@
+package org.apache.qpid.nclient.amqp.event;
+
+import org.apache.qpid.framing.AMQMethodBody;
+
+/**
+ * This class is exactly the same as the AMQMethod event.
+ * Except I renamed requestId to corelationId, so I could use it both ways.
+ * 
+ * I didn't want to modify anything in common so that there is no
+ * impact on the existing code.
+ *
+ */
+public class AMQPMethodEvent<M extends AMQMethodBody>
+{
+
+    private final M _method;
+
+    private final int _channelId;
+
+    /**
+     * This is the rquest id from the broker when it sent me a request
+     * when I respond I remember this id and copy this to the outgoing
+     * response. 
+     */
+    private final long _correlationId;
+
+    /**
+     * I could use _correlationId, bcos when I send a request
+     * this field is blank and is only used internally. But I 
+     * used a seperate field to make it more clear.
+     */
+    private long _localCorrletionId = 0;
+
+    public AMQPMethodEvent(int channelId, M method, long correlationId, long localCorrletionId)
+    {
+	_channelId = channelId;
+	_method = method;
+	_correlationId = correlationId;
+	_localCorrletionId = localCorrletionId;
+    }
+
+    public AMQPMethodEvent(int channelId, M method, long correlationId)
+    {
+	_channelId = channelId;
+	_method = method;
+	_correlationId = correlationId;
+    }
+
+    public M getMethod()
+    {
+	return _method;
+    }
+
+    public int getChannelId()
+    {
+	return _channelId;
+    }
+
+    public long getCorrelationId()
+    {
+	return _correlationId;
+    }
+
+    public long getLocalCorrelationId()
+    {
+	return _localCorrletionId;
+    }
+
+    public String toString()
+    {
+	StringBuilder buf = new StringBuilder("Method event: \n");
+	buf.append("Channel id: \n").append(_channelId);
+	buf.append("Method: \n").append(_method);
+	buf.append("Request Id: ").append(_correlationId);
+	buf.append("Local Correlation Id: ").append(_localCorrletionId);
+	return buf.toString();
+    }
+}