org.apache.activemq.transport.stomp
public class StompSubscription extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
ackMode |
static java.lang.String |
AUTO_ACK |
static java.lang.String |
CLIENT_ACK |
protected ConsumerInfo |
consumerInfo |
protected ActiveMQDestination |
destination |
protected java.util.LinkedHashMap<MessageId,MessageDispatch> |
dispatchedMessage |
static java.lang.String |
INDIVIDUAL_ACK |
protected ProtocolConverter |
protocolConverter |
protected java.lang.String |
subscriptionId |
protected java.lang.String |
transformation |
protected java.util.LinkedList<MessageDispatch> |
unconsumedMessage |
Constructor and Description |
---|
StompSubscription(ProtocolConverter stompTransport,
java.lang.String subscriptionId,
ConsumerInfo consumerInfo,
java.lang.String transformation) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getAckMode() |
ConsumerInfo |
getConsumerInfo() |
ActiveMQDestination |
getDestination() |
java.lang.String |
getSubscriptionId() |
MessageAck |
onStompMessageNack(java.lang.String messageId,
TransactionId transactionId) |
void |
setAckMode(java.lang.String ackMode) |
void |
setDestination(ActiveMQDestination destination) |
public static final java.lang.String AUTO_ACK
public static final java.lang.String CLIENT_ACK
public static final java.lang.String INDIVIDUAL_ACK
protected final ProtocolConverter protocolConverter
protected final java.lang.String subscriptionId
protected final ConsumerInfo consumerInfo
protected final java.util.LinkedHashMap<MessageId,MessageDispatch> dispatchedMessage
protected final java.util.LinkedList<MessageDispatch> unconsumedMessage
protected java.lang.String ackMode
protected ActiveMQDestination destination
protected java.lang.String transformation
public StompSubscription(ProtocolConverter stompTransport, java.lang.String subscriptionId, ConsumerInfo consumerInfo, java.lang.String transformation)
public MessageAck onStompMessageNack(java.lang.String messageId, TransactionId transactionId) throws ProtocolException
ProtocolException
public java.lang.String getAckMode()
public void setAckMode(java.lang.String ackMode)
public java.lang.String getSubscriptionId()
public void setDestination(ActiveMQDestination destination)
public ActiveMQDestination getDestination()
public ConsumerInfo getConsumerInfo()
Copyright © 2005-2014. All Rights Reserved.