org.apache.activemq.transport.stomp
Class StompSubscription

java.lang.Object
  extended by 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

Field Summary
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 Summary
StompSubscription(ProtocolConverter stompTransport, java.lang.String subscriptionId, ConsumerInfo consumerInfo, java.lang.String transformation)
           
 
Method Summary
 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)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

StompSubscription

public StompSubscription(ProtocolConverter stompTransport,
                         java.lang.String subscriptionId,
                         ConsumerInfo consumerInfo,
                         java.lang.String transformation)
Method Detail

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.