org.projectodd.stilts.conduit.stomp
Class ConduitStompConnection

java.lang.Object
  org.projectodd.stilts.conduit.stomp.ConduitStompConnection

All Implemented Interfaces:

StompConnection

public class ConduitStompConnection
extends Object
implements StompConnection

Constructor Summary

ConduitStompConnection(ConduitStompProvider stompProvider, XAMessageConduit messageConduit, String sessionId, StompFrame.Version version, Heartbeat hb)

Method Summary

void	abort(String transactionId)
void	begin(String transactionId, Headers headers)
void	commit(String transactionId)
Subscription	createSubscription(String destination, String subscriptionId, Headers headers)
protected ConduitStompTransaction	createTransaction(Transaction jtaTransaction, String transactionId)
void	disconnect()
Heartbeat	getHeartbeat()
XAMessageConduit	getMessageConduit()
String	getSessionId()
ConduitStompProvider	getStompProvider()
StompFrame.Version	getVersion()
protected void	send(StompMessage message)
void	send(StompMessage message, String transactionId)
Subscription	subscribe(String destination, String subscriptionId, Headers headers)
void	unsubscribe(String id, Headers headers)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConduitStompConnection

public ConduitStompConnection(ConduitStompProvider stompProvider,
                              XAMessageConduit messageConduit,
                              String sessionId,
                              StompFrame.Version version,
                              Heartbeat hb)
                       throws StompException

Throws:

StompException

Method Detail

getHeartbeat

public Heartbeat getHeartbeat()

Specified by:

getHeartbeat in interface StompConnection

getSessionId

public String getSessionId()

Specified by:

getSessionId in interface StompConnection

getVersion

public StompFrame.Version getVersion()

Specified by:

getVersion in interface StompConnection

getStompProvider

public ConduitStompProvider getStompProvider()

getMessageConduit

public XAMessageConduit getMessageConduit()

send

public void send(StompMessage message,
                 String transactionId)
          throws StompException

Specified by:

send in interface StompConnection

Throws:

StompException

send

protected void send(StompMessage message)
             throws StompException

Throws:

StompException

begin

public void begin(String transactionId,
                  Headers headers)
           throws StompException

Specified by:

begin in interface StompConnection

Throws:

StompException

commit

public void commit(String transactionId)
            throws StompException

Specified by:

commit in interface StompConnection

Throws:

StompException

abort

public void abort(String transactionId)
           throws StompException

Specified by:

abort in interface StompConnection

Throws:

StompException

subscribe

public Subscription subscribe(String destination,
                              String subscriptionId,
                              Headers headers)
                       throws StompException

Specified by:

subscribe in interface StompConnection

Throws:

StompException

createSubscription

public Subscription createSubscription(String destination,
                                       String subscriptionId,
                                       Headers headers)
                                throws Exception

Throws:

Exception

unsubscribe

public void unsubscribe(String id,
                        Headers headers)
                 throws StompException

Specified by:

unsubscribe in interface StompConnection

Throws:

StompException

disconnect

public void disconnect()
                throws NotConnectedException

Specified by:

disconnect in interface StompConnection

Throws:

NotConnectedException

createTransaction

protected ConduitStompTransaction createTransaction(Transaction jtaTransaction,
                                                    String transactionId)
                                             throws Exception

Throws:

Exception