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