public class StompSubscription extends Object
Modifier and Type | Field and Description |
---|---|
protected String |
ackMode |
static String |
AUTO_ACK |
static String |
CLIENT_ACK |
protected ConsumerInfo |
consumerInfo |
protected ActiveMQDestination |
destination |
protected LinkedHashMap<MessageId,MessageDispatch> |
dispatchedMessage |
static String |
INDIVIDUAL_ACK |
protected ProtocolConverter |
protocolConverter |
protected String |
subscriptionId |
protected String |
transformation |
protected LinkedList<MessageDispatch> |
unconsumedMessage |
Constructor and Description |
---|
StompSubscription(ProtocolConverter stompTransport,
String subscriptionId,
ConsumerInfo consumerInfo,
String transformation) |
Modifier and Type | Method and Description |
---|---|
String |
getAckMode() |
ConsumerInfo |
getConsumerInfo() |
ActiveMQDestination |
getDestination() |
String |
getSubscriptionId() |
MessageAck |
onStompMessageNack(String messageId,
TransactionId transactionId) |
void |
setAckMode(String ackMode) |
void |
setDestination(ActiveMQDestination destination) |
public static final String AUTO_ACK
public static final String CLIENT_ACK
public static final String INDIVIDUAL_ACK
protected final ProtocolConverter protocolConverter
protected final String subscriptionId
protected final ConsumerInfo consumerInfo
protected final LinkedHashMap<MessageId,MessageDispatch> dispatchedMessage
protected final LinkedList<MessageDispatch> unconsumedMessage
protected String ackMode
protected ActiveMQDestination destination
protected String transformation
public StompSubscription(ProtocolConverter stompTransport, String subscriptionId, ConsumerInfo consumerInfo, String transformation)
public MessageAck onStompMessageNack(String messageId, TransactionId transactionId) throws ProtocolException
ProtocolException
public String getAckMode()
public void setAckMode(String ackMode)
public String getSubscriptionId()
public void setDestination(ActiveMQDestination destination)
public ActiveMQDestination getDestination()
public ConsumerInfo getConsumerInfo()
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.