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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConduitStompConnection
public ConduitStompConnection(ConduitStompProvider stompProvider,
XAMessageConduit messageConduit,
String sessionId,
StompFrame.Version version,
Heartbeat hb)
throws StompException
- Throws:
StompException
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
Copyright © 2011 JBoss, a division of Red Hat, Inc.. All Rights Reserved.