void |
StompProtocolManager.abortTransaction(StompConnection connection,
String txID) |
void |
StompProtocolManager.acknowledge(StompConnection connection,
String messageID,
String subscriptionID) |
void |
StompProtocolManager.beginTransaction(StompConnection connection,
String txID) |
void |
StompProtocolManager.cleanup(StompConnection connection) |
void |
StompProtocolManager.commitTransaction(StompConnection connection,
String txID) |
void |
ActiveMQStompProtocolLogger.connectionClosed(StompConnection connection) |
void |
StompProtocolManager.createSubscription(StompConnection connection,
String subscriptionID,
String durableSubscriptionName,
String destination,
String selector,
String ack,
boolean noLocal) |
static VersionedStompFrameHandler |
VersionedStompFrameHandler.getHandler(StompConnection connection,
StompVersions version) |
StompSession |
StompProtocolManager.getSession(StompConnection connection) |
StompSession |
StompProtocolManager.getTransactedSession(StompConnection connection,
String txID) |
boolean |
StompProtocolManager.send(StompConnection connection,
StompFrame frame) |
void |
StompProtocolManager.sendReply(StompConnection connection,
StompFrame frame) |
void |
StompProtocolManager.unsubscribe(StompConnection connection,
String subscriptionID,
String durableSubscriberName) |