Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

added some extra properties to the MessagePull command for when we implement AMQ-1196 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516040 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2007-03-08 13:38:40 +00:00
parent eeafa1cfef
commit e935c5ad3b
1 changed files with 30 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
activemq-core/src/main/java/org/apache/activemq/command/MessagePull.java
View File

@ -33,6 +33,8 @@ public class MessagePull extends BaseCommand {
protected ConsumerId consumerId; protected ConsumerId consumerId;
protected ActiveMQDestination destination; protected ActiveMQDestination destination;
protected long timeout; protected long timeout;
private MessageId messageId;
private String correlationId;
public byte getDataStructureType() { public byte getDataStructureType() {
return DATA_STRUCTURE_TYPE; return DATA_STRUCTURE_TYPE;
@ -83,4 +85,32 @@ public class MessagePull extends BaseCommand {
this.timeout = timeout; 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;
}
} }