public class StompQueueBrowserSubscription extends StompSubscription
ackMode, AUTO_ACK, CLIENT_ACK, consumerInfo, destination, dispatchedMessage, INDIVIDUAL_ACK, protocolConverter, subscriptionId, transformation, unconsumedMessage
Constructor and Description |
---|
StompQueueBrowserSubscription(ProtocolConverter stompTransport,
String subscriptionId,
org.apache.activemq.command.ConsumerInfo consumerInfo,
String transformation) |
Modifier and Type | Method and Description |
---|---|
org.apache.activemq.command.MessageAck |
onStompMessageNack(String messageId,
org.apache.activemq.command.TransactionId transactionId) |
getAckMode, getConsumerInfo, getDestination, getSubscriptionId, setAckMode, setDestination
public StompQueueBrowserSubscription(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
onStompMessageNack
in class StompSubscription
ProtocolException
Copyright © 2005–2021 FuseSource, Corp.. All rights reserved.