org.projectodd.stilts.stomplet.impl
Class SubscriberImpl

java.lang.Object
  org.projectodd.stilts.stomplet.impl.SubscriberImpl

All Implemented Interfaces:

MessageSink, AcknowledgeableMessageSink, Subscriber

public class SubscriberImpl
extends Object
implements Subscriber

Constructor Summary

SubscriberImpl(Stomplet stomplet, String subscriptionId, String destination, StompletMessageConduit messageConduit, Subscription.AckMode ackMode)

Method Summary

Subscription.AckMode	getAckMode()
String	getDestination()
String	getId()
void	send(StompMessage message)
void	send(StompMessage message, Acknowledger acknowledger)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubscriberImpl

public SubscriberImpl(Stomplet stomplet,
                      String subscriptionId,
                      String destination,
                      StompletMessageConduit messageConduit,
                      Subscription.AckMode ackMode)

Method Detail

getId

public String getId()

Specified by:

getId in interface Subscriber

getAckMode

public Subscription.AckMode getAckMode()

Specified by:

getAckMode in interface Subscriber

send

public void send(StompMessage message)
          throws StompException

Specified by:

send in interface MessageSink

Throws:

StompException

send

public void send(StompMessage message,
                 Acknowledger acknowledger)
          throws StompException

Specified by:

send in interface AcknowledgeableMessageSink

Throws:

StompException

getDestination

public String getDestination()

Specified by:

getDestination in interface Subscriber