Stilts 0.1.0-SNAPSHOT

org.projectodd.stilts.conduit.stomp
Class ConduitStompConnection

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

Stilts 0.1.0-SNAPSHOT

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