Stilts 0.1.0-SNAPSHOT

org.projectodd.stilts.stomplet.impl
Class SubscriberImpl

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

Stilts 0.1.0-SNAPSHOT

Copyright © 2011 JBoss, a division of Red Hat, Inc.. All Rights Reserved.