svn commit: r516040 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessagePull.java

[js...@apache.org]

Author: jstrachan
Date: Thu Mar  8 05:38:40 2007
New Revision: 516040

URL: http://svn.apache.org/viewvc?view=rev&rev=516040
Log:
added some extra properties to the MessagePull command for when we implement AMQ-1196

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessagePull.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessagePull.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessagePull.java?view=diff&rev=516040&r1=516039&r2=516040
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessagePull.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessagePull.java Thu Mar  8 05:38:40 2007
@@ -33,6 +33,8 @@
     protected ConsumerId consumerId;
     protected ActiveMQDestination destination;
     protected long timeout;
+    private MessageId messageId;
+    private String correlationId;
 
     public byte getDataStructureType() {
         return DATA_STRUCTURE_TYPE;
@@ -83,4 +85,32 @@
         this.timeout = timeout;
     }
 
+    /**
+     * An optional correlation ID which could be used by a broker to decide which messages are pulled
+     * on demand from a queue for a consumer
+     *
+     * @openwire:property version=3
+     */
+    public String getCorrelationId() {
+        return correlationId;
+    }
+
+    public void setCorrelationId(String correlationId) {
+        this.correlationId = correlationId;
+    }
+
+
+    /**
+     * An optional message ID which could be used by a broker to decide which messages are pulled
+     * on demand from a queue for a consumer
+     *
+     * @openwire:property version=3
+     */
+    public MessageId getMessageId() {
+        return messageId;
+    }
+
+    public void setMessageId(MessageId messageId) {
+        this.messageId = messageId;
+    }
 }