Modifier and Type | Method and Description |
---|---|
StompFrame |
VersionedStompFrameHandler.createMessageFrame(ServerMessage serverMessage,
StompSubscription subscription,
int deliveryCount) |
abstract StompFrame |
VersionedStompFrameHandler.createStompFrame(String command) |
StompFrame |
StompConnection.createStompMessage(ServerMessage serverMessage,
StompSubscription subscription,
int deliveryCount) |
StompFrame |
StompDecoder.decode(ActiveMQBuffer buffer) |
StompFrame |
StompConnection.decode(ActiveMQBuffer buffer) |
StompFrame |
VersionedStompFrameHandler.decode(ActiveMQBuffer buffer) |
StompFrame |
ActiveMQStompException.getFrame() |
StompFrame |
VersionedStompFrameHandler.handleFrame(StompFrame request) |
StompFrame |
VersionedStompFrameHandler.handleReceipt(String receiptID) |
StompFrame |
VersionedStompFrameHandler.onAbort(StompFrame request) |
abstract StompFrame |
VersionedStompFrameHandler.onAck(StompFrame request) |
StompFrame |
VersionedStompFrameHandler.onBegin(StompFrame frame) |
StompFrame |
VersionedStompFrameHandler.onCommit(StompFrame request) |
abstract StompFrame |
VersionedStompFrameHandler.onConnect(StompFrame frame) |
abstract StompFrame |
VersionedStompFrameHandler.onDisconnect(StompFrame frame) |
abstract StompFrame |
VersionedStompFrameHandler.onNack(StompFrame request) |
StompFrame |
VersionedStompFrameHandler.onSend(StompFrame frame) |
abstract StompFrame |
VersionedStompFrameHandler.onStomp(StompFrame request) |
StompFrame |
VersionedStompFrameHandler.onSubscribe(StompFrame request) |
StompFrame |
VersionedStompFrameHandler.onUnknown(String command) |
abstract StompFrame |
VersionedStompFrameHandler.onUnsubscribe(StompFrame request) |
protected StompFrame |
StompDecoder.parseBody() |
StompFrame |
VersionedStompFrameHandler.postprocess(StompFrame request) |
Modifier and Type | Method and Description |
---|---|
static void |
StompUtils.copyStandardHeadersFromFrameToMessage(StompFrame frame,
ServerMessageImpl msg) |
static void |
StompUtils.copyStandardHeadersFromMessageToFrame(MessageInternal message,
StompFrame command,
int deliveryCount) |
void |
ActiveMQStompProtocolLogger.errorSendingFrame(Exception e,
StompFrame frame) |
void |
StompConnection.handleFrame(StompFrame request) |
StompFrame |
VersionedStompFrameHandler.handleFrame(StompFrame request) |
void |
StompConnection.negotiateVersion(StompFrame frame) |
StompFrame |
VersionedStompFrameHandler.onAbort(StompFrame request) |
abstract StompFrame |
VersionedStompFrameHandler.onAck(StompFrame request) |
StompFrame |
VersionedStompFrameHandler.onBegin(StompFrame frame) |
StompFrame |
VersionedStompFrameHandler.onCommit(StompFrame request) |
abstract StompFrame |
VersionedStompFrameHandler.onConnect(StompFrame frame) |
abstract StompFrame |
VersionedStompFrameHandler.onDisconnect(StompFrame frame) |
abstract StompFrame |
VersionedStompFrameHandler.onNack(StompFrame request) |
StompFrame |
VersionedStompFrameHandler.onSend(StompFrame frame) |
abstract StompFrame |
VersionedStompFrameHandler.onStomp(StompFrame request) |
StompFrame |
VersionedStompFrameHandler.onSubscribe(StompFrame request) |
abstract StompFrame |
VersionedStompFrameHandler.onUnsubscribe(StompFrame request) |
void |
StompConnection.physicalSend(StompFrame frame) |
void |
StompConnection.ping(StompFrame pingFrame) |
StompFrame |
VersionedStompFrameHandler.postprocess(StompFrame request) |
void |
FrameEventListener.replySent(StompFrame reply) |
void |
FrameEventListener.requestAccepted(StompFrame request) |
boolean |
StompProtocolManager.send(StompConnection connection,
StompFrame frame) |
void |
StompConnection.sendFrame(StompFrame frame) |
void |
StompProtocolManager.sendReply(StompConnection connection,
StompFrame frame) |
Modifier and Type | Class and Description |
---|---|
class |
StompFrameV10 |
Modifier and Type | Method and Description |
---|---|
StompFrame |
StompFrameHandlerV10.createStompFrame(String command) |
StompFrame |
StompFrameHandlerV10.onAck(StompFrame request) |
StompFrame |
StompFrameHandlerV10.onConnect(StompFrame frame) |
StompFrame |
StompFrameHandlerV10.onDisconnect(StompFrame frame) |
StompFrame |
StompFrameHandlerV10.onNack(StompFrame request) |
StompFrame |
StompFrameHandlerV10.onStomp(StompFrame request) |
StompFrame |
StompFrameHandlerV10.onUnsubscribe(StompFrame request) |
Modifier and Type | Method and Description |
---|---|
StompFrame |
StompFrameHandlerV10.onAck(StompFrame request) |
StompFrame |
StompFrameHandlerV10.onConnect(StompFrame frame) |
StompFrame |
StompFrameHandlerV10.onDisconnect(StompFrame frame) |
StompFrame |
StompFrameHandlerV10.onNack(StompFrame request) |
StompFrame |
StompFrameHandlerV10.onStomp(StompFrame request) |
StompFrame |
StompFrameHandlerV10.onUnsubscribe(StompFrame request) |
void |
StompFrameHandlerV10.replySent(StompFrame reply) |
void |
StompFrameHandlerV10.requestAccepted(StompFrame request) |
Modifier and Type | Class and Description |
---|---|
class |
StompFrameV11 |
Modifier and Type | Method and Description |
---|---|
StompFrame |
StompFrameHandlerV11.createPingFrame() |
StompFrame |
StompFrameHandlerV11.createStompFrame(String command) |
StompFrame |
StompFrameHandlerV11.onAck(StompFrame request) |
StompFrame |
StompFrameHandlerV11.onConnect(StompFrame frame) |
StompFrame |
StompFrameHandlerV11.onDisconnect(StompFrame frame) |
StompFrame |
StompFrameHandlerV11.onNack(StompFrame request) |
StompFrame |
StompFrameHandlerV11.onStomp(StompFrame request) |
StompFrame |
StompFrameHandlerV11.onUnsubscribe(StompFrame request) |
protected StompFrame |
StompFrameHandlerV11.StompDecoderV11.parseBody() |
Modifier and Type | Method and Description |
---|---|
StompFrame |
StompFrameHandlerV11.onAck(StompFrame request) |
StompFrame |
StompFrameHandlerV11.onConnect(StompFrame frame) |
StompFrame |
StompFrameHandlerV11.onDisconnect(StompFrame frame) |
StompFrame |
StompFrameHandlerV11.onNack(StompFrame request) |
StompFrame |
StompFrameHandlerV11.onStomp(StompFrame request) |
StompFrame |
StompFrameHandlerV11.onUnsubscribe(StompFrame request) |
void |
StompFrameHandlerV11.replySent(StompFrame reply) |
void |
StompFrameHandlerV11.requestAccepted(StompFrame request) |
Modifier and Type | Class and Description |
---|---|
class |
StompFrameV12 |
Modifier and Type | Method and Description |
---|---|
StompFrame |
StompFrameHandlerV12.createMessageFrame(ServerMessage serverMessage,
StompSubscription subscription,
int deliveryCount) |
StompFrame |
StompFrameHandlerV12.createStompFrame(String command) |
StompFrame |
StompFrameHandlerV12.onAck(StompFrame request)
Version 1.2's ACK frame only requires 'id' header
here we use id = messageID
|
protected StompFrame |
StompFrameHandlerV12.StompDecoderV12.parseBody() |
Modifier and Type | Method and Description |
---|---|
StompFrame |
StompFrameHandlerV12.onAck(StompFrame request)
Version 1.2's ACK frame only requires 'id' header
here we use id = messageID
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.