org.apache.activemq.transport.stomp
Class StompSubscription
java.lang.Object
org.apache.activemq.transport.stomp.StompSubscription
- Direct Known Subclasses:
- StompQueueBrowserSubscription
public class StompSubscription
- extends java.lang.Object
Keeps track of the STOMP subscription so that acking is correctly done.
- Author:
- chirino
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AUTO_ACK
public static final java.lang.String AUTO_ACK
- See Also:
- Constant Field Values
CLIENT_ACK
public static final java.lang.String CLIENT_ACK
- See Also:
- Constant Field Values
INDIVIDUAL_ACK
public static final java.lang.String INDIVIDUAL_ACK
- See Also:
- Constant Field Values
protocolConverter
protected final ProtocolConverter protocolConverter
subscriptionId
protected final java.lang.String subscriptionId
consumerInfo
protected final ConsumerInfo consumerInfo
dispatchedMessage
protected final java.util.LinkedHashMap<MessageId,MessageDispatch> dispatchedMessage
unconsumedMessage
protected final java.util.LinkedList<MessageDispatch> unconsumedMessage
ackMode
protected java.lang.String ackMode
destination
protected ActiveMQDestination destination
transformation
protected java.lang.String transformation
StompSubscription
public StompSubscription(ProtocolConverter stompTransport,
java.lang.String subscriptionId,
ConsumerInfo consumerInfo,
java.lang.String transformation)
onStompMessageNack
public MessageAck onStompMessageNack(java.lang.String messageId,
TransactionId transactionId)
throws ProtocolException
- Throws:
ProtocolException
getAckMode
public java.lang.String getAckMode()
setAckMode
public void setAckMode(java.lang.String ackMode)
getSubscriptionId
public java.lang.String getSubscriptionId()
setDestination
public void setDestination(ActiveMQDestination destination)
getDestination
public ActiveMQDestination getDestination()
getConsumerInfo
public ConsumerInfo getConsumerInfo()
Copyright © 2005-2012. All Rights Reserved.