Modifier and Type	Class and Description
private static class	StompSubProtocolHandler.DefaultStats
public static interface	StompSubProtocolHandler.Stats Contract for access to session counters.

Modifier and Type	Field and Description
public static final String	CONNECTED_USER_HEADER The name of the header set on the CONNECTED frame indicating the name of the user authenticated on the WebSocket session.
private final Map<String, BufferingStompDecoder>	decoders
private static final byte[]	EMPTY_PAYLOAD
private StompSubProtocolErrorHandler	errorHandler
private ApplicationEventPublisher	eventPublisher
private MessageHeaderInitializer	headerInitializer
private Boolean	immutableMessageInterceptorPresent
private static final Log	logger
private int	messageSizeLimit
public static final int	MINIMUM_WEBSOCKET_MESSAGE_SIZE This handler supports assembling large STOMP messages split into multiple WebSocket messages and STOMP clients (like stomp.js) indeed split large STOMP messages at 16K boundaries.
private Map<String, MessageChannel>	orderedHandlingMessageChannels
private final StompSubProtocolHandler.DefaultStats	stats
private final Map<String, Principal>	stompAuthentications
private StompDecoder	stompDecoder
private StompEncoder	stompEncoder
private static final String[]	SUPPORTED_VERSIONS

Access	Constructor and Description
public	StompSubProtocolHandler()

Method Summary

Modifier and Type	Method and Description
public void	afterSessionEnded(WebSocketSession the client session session, CloseStatus the reason why the session was closed closeStatus, MessageChannel a channel outputChannel) Implements org.springframework.web.socket.messaging.SubProtocolHandler.afterSessionEnded. Invoked after a `WebSocketSession` has ended.
public void	afterSessionStarted(WebSocketSession the client session session, MessageChannel a channel outputChannel) Implements org.springframework.web.socket.messaging.SubProtocolHandler.afterSessionStarted. Invoked after a `WebSocketSession` has started.
private StompHeaderAccessor	afterStompSessionConnected(Message<?> message, StompHeaderAccessor accessor, WebSocketSession session)
private StompHeaderAccessor	convertConnectAcktoStompConnected(StompHeaderAccessor connectAckHeaders) The simple broker produces `SimpMessageType.CONNECT_ACK` that's not STOMP specific and needs to be turned into a STOMP CONNECTED frame.
private Message<byte[]>	createDisconnectMessage(WebSocketSession session)
private boolean	detectImmutableMessageInterceptor(MessageChannel channel)
private String	getDisconnectReceipt(SimpMessageHeaderAccessor simpHeaders)
public StompSubProtocolErrorHandler	getErrorHandler() Return the configured error handler.
public MessageHeaderInitializer	getHeaderInitializer() Return the configured header initializer.
public int	getMessageSizeLimit() Get the configured message buffer size limit in bytes.
public StompSubProtocolHandler.Stats	getStats() Return a structured object with internal state and counters.
public String	getStatsInfo() Return a String describing internal state and counters.
private StompHeaderAccessor	getStompHeaderAccessor(Message<?> message)
public List<String>	getSupportedProtocols() Implements org.springframework.web.socket.messaging.SubProtocolHandler.getSupportedProtocols. Return the list of sub-protocols supported by this handler (never `null`).
private Principal	getUser(WebSocketSession session)
private void	handleError(WebSocketSession session, Throwable ex, Message<byte[]> clientMessage)
public void	handleMessageFromClient(WebSocketSession the client session session, WebSocketMessage<?> the client message webSocketMessage, MessageChannel an output channel to send messages to targetChannel) Implements org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageFromClient. Handle incoming WebSocket messages from clients.
public void	handleMessageToClient(WebSocketSession the client session session, Message<?> the client message message) Implements org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageToClient. Handle STOMP messages going back out to WebSocket clients.
public boolean	isPreserveReceiveOrder() Whether the handler is configured to handle inbound messages in the order in which they were received.
private void	publishEvent(ApplicationEventPublisher publisher, ApplicationEvent event)
public String	resolveSessionId(Message<?> the message to resolve the session id from message) Implements org.springframework.web.socket.messaging.SubProtocolHandler.resolveSessionId. Resolve the session id from the given message or return `null`.
private void	sendErrorMessage(WebSocketSession session, Throwable error) Invoked when no `errorHandler` is configured to send an ERROR frame to the client.
private void	sendToClient(WebSocketSession session, StompHeaderAccessor stompAccessor, byte[] payload)
public void	setApplicationEventPublisher(ApplicationEventPublisher event publisher to be used by this object applicationEventPublisher) Implements org.springframework.context.ApplicationEventPublisherAware.setApplicationEventPublisher. Set the ApplicationEventPublisher that this object runs in. Invoked after population of normal bean properties but before an init callback like InitializingBean's afterPropertiesSet or a custom init-method.
public void	setDecoder(StompDecoder decoder) Configure a `StompDecoder` for decoding STOMP frames.
public void	setEncoder(StompEncoder encoder) Configure a `StompEncoder` for encoding STOMP frames.
public void	setErrorHandler(StompSubProtocolErrorHandler the error handler errorHandler) Configure a handler for error messages sent to clients which allows customizing the error messages or preventing them from being sent.
public void	setHeaderInitializer(MessageHeaderInitializer headerInitializer) Configure a `MessageHeaderInitializer` to apply to the headers of all messages created from decoded STOMP frames and other messages sent to the client inbound channel.
public void	setMessageSizeLimit(int messageSizeLimit) Configure the maximum size allowed for an incoming STOMP message.
public void	setPreserveReceiveOrder(boolean whether to publish in order preserveReceiveOrder) Whether client messages must be handled in the order received.
protected StompHeaderAccessor	toMutableAccessor(StompHeaderAccessor headerAccessor, Message<?> message)
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

CONNECTED_USER_HEADER	back to summary
public static final String CONNECTED_USER_HEADER The name of the header set on the CONNECTED frame indicating the name of the user authenticated on the WebSocket session.

decoders	back to summary
private final Map<String, BufferingStompDecoder> decoders

EMPTY_PAYLOAD	back to summary
private static final byte[] EMPTY_PAYLOAD

errorHandler	back to summary
private StompSubProtocolErrorHandler errorHandler Annotations @Nullable

eventPublisher	back to summary
private ApplicationEventPublisher eventPublisher Annotations @Nullable

headerInitializer	back to summary
private MessageHeaderInitializer headerInitializer Annotations @Nullable

immutableMessageInterceptorPresent	back to summary
private Boolean immutableMessageInterceptorPresent Annotations @Nullable

logger	back to summary
private static final Log logger

messageSizeLimit	back to summary
private int messageSizeLimit

MINIMUM_WEBSOCKET_MESSAGE_SIZE	back to summary
public static final int MINIMUM_WEBSOCKET_MESSAGE_SIZE This handler supports assembling large STOMP messages split into multiple WebSocket messages and STOMP clients (like stomp.js) indeed split large STOMP messages at 16K boundaries. Therefore the WebSocket server input message buffer size must allow 16K at least plus a little extra for SockJS framing.

orderedHandlingMessageChannels	back to summary
private Map<String, MessageChannel> orderedHandlingMessageChannels Annotations @Nullable

stats	back to summary
private final StompSubProtocolHandler.DefaultStats stats

stompAuthentications	back to summary
private final Map<String, Principal> stompAuthentications

stompDecoder	back to summary
private StompDecoder stompDecoder

stompEncoder	back to summary
private StompEncoder stompEncoder

SUPPORTED_VERSIONS	back to summary
private static final String[] SUPPORTED_VERSIONS

Constructor Detail

StompSubProtocolHandler	back to summary
public StompSubProtocolHandler()

Method Detail

afterSessionEnded back to summary

afterSessionEnded	back to summary
public void afterSessionEnded(WebSocketSession session, CloseStatus closeStatus, MessageChannel outputChannel) Implements org.springframework.web.socket.messaging.SubProtocolHandler.afterSessionEnded. Doc from org.springframework.web.socket.messaging.SubProtocolHandler.afterSessionEnded. Invoked after a `WebSocketSession` has ended. Parameters session:WebSocketSession the client session closeStatus:CloseStatus the reason why the session was closed outputChannel:MessageChannel a channel Annotations @Override

public void afterSessionEnded(WebSocketSession session, CloseStatus closeStatus, MessageChannel outputChannel)

Implements org.springframework.web.socket.messaging.SubProtocolHandler.afterSessionEnded.

Doc from org.springframework.web.socket.messaging.SubProtocolHandler.afterSessionEnded.

Invoked after a WebSocketSession has ended.

Parameters

session:WebSocketSession: the client session
closeStatus:CloseStatus: the reason why the session was closed
outputChannel:MessageChannel: a channel

Annotations

@Override

afterSessionStarted back to summary

afterSessionStarted	back to summary
public void afterSessionStarted(WebSocketSession session, MessageChannel outputChannel) Implements org.springframework.web.socket.messaging.SubProtocolHandler.afterSessionStarted. Doc from org.springframework.web.socket.messaging.SubProtocolHandler.afterSessionStarted. Invoked after a `WebSocketSession` has started. Parameters session:WebSocketSession the client session outputChannel:MessageChannel a channel Annotations @Override

public void afterSessionStarted(WebSocketSession session, MessageChannel outputChannel)

Implements org.springframework.web.socket.messaging.SubProtocolHandler.afterSessionStarted.

Doc from org.springframework.web.socket.messaging.SubProtocolHandler.afterSessionStarted.

Invoked after a WebSocketSession has started.

Parameters

session:WebSocketSession: the client session
outputChannel:MessageChannel: a channel

Annotations

@Override

afterStompSessionConnected	back to summary
private StompHeaderAccessor afterStompSessionConnected(Message<?> message, StompHeaderAccessor accessor, WebSocketSession session)

convertConnectAcktoStompConnected	back to summary
private StompHeaderAccessor convertConnectAcktoStompConnected(StompHeaderAccessor connectAckHeaders) The simple broker produces `SimpMessageType.CONNECT_ACK` that's not STOMP specific and needs to be turned into a STOMP CONNECTED frame.

createDisconnectMessage	back to summary
private Message<byte[]> createDisconnectMessage(WebSocketSession session)

detectImmutableMessageInterceptor	back to summary
private boolean detectImmutableMessageInterceptor(MessageChannel channel)

getDisconnectReceipt	back to summary
private String getDisconnectReceipt(SimpMessageHeaderAccessor simpHeaders) Annotations @Nullable

getErrorHandler	back to summary
public StompSubProtocolErrorHandler getErrorHandler() Return the configured error handler. Annotations @Nullable

getErrorHandler

back to summary

public StompSubProtocolErrorHandler getErrorHandler()

Return the configured error handler.

Annotations

@Nullable

getHeaderInitializer	back to summary
public MessageHeaderInitializer getHeaderInitializer() Return the configured header initializer. Annotations @Nullable

getHeaderInitializer

back to summary

public MessageHeaderInitializer getHeaderInitializer()

Return the configured header initializer.

Annotations

@Nullable

getMessageSizeLimit	back to summary
public int getMessageSizeLimit() Get the configured message buffer size limit in bytes. Since 4.0.3

getMessageSizeLimit

back to summary

public int getMessageSizeLimit()

Get the configured message buffer size limit in bytes.

Since: 4.0.3

getStats	back to summary
public StompSubProtocolHandler.Stats getStats() Return a structured object with internal state and counters. Since 5.2

getStats

back to summary

public StompSubProtocolHandler.Stats getStats()

Return a structured object with internal state and counters.

Since: 5.2

getStatsInfo	back to summary
public String getStatsInfo() Return a String describing internal state and counters. Effectively `toString()` on `getStats()`.

getStompHeaderAccessor	back to summary
private StompHeaderAccessor getStompHeaderAccessor(Message<?> message)

getSupportedProtocols back to summary

getSupportedProtocols	back to summary
public List<String> getSupportedProtocols() Implements org.springframework.web.socket.messaging.SubProtocolHandler.getSupportedProtocols. Doc from org.springframework.web.socket.messaging.SubProtocolHandler.getSupportedProtocols. Return the list of sub-protocols supported by this handler (never `null`). Annotations @Override

public List<String> getSupportedProtocols()

Implements org.springframework.web.socket.messaging.SubProtocolHandler.getSupportedProtocols.

Doc from org.springframework.web.socket.messaging.SubProtocolHandler.getSupportedProtocols.

Return the list of sub-protocols supported by this handler (never null).

Annotations

@Override

getUser	back to summary
private Principal getUser(WebSocketSession session) Annotations @Nullable

handleError	back to summary
private void handleError(WebSocketSession session, Throwable ex, Message<byte[]> clientMessage)

handleMessageFromClient	back to summary
public void handleMessageFromClient(WebSocketSession session, WebSocketMessage<?> webSocketMessage, MessageChannel targetChannel) Implements org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageFromClient. Handle incoming WebSocket messages from clients. Parameters session:WebSocketSession Doc from org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageFromClient. the client session webSocketMessage:WebSocketMessage<?> Doc from org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageFromClient. the client message targetChannel:MessageChannel Doc from org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageFromClient. an output channel to send messages to Annotations @Override

handleMessageFromClient

back to summary

public void handleMessageFromClient(WebSocketSession session, WebSocketMessage<?> webSocketMessage, MessageChannel targetChannel)

Implements org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageFromClient.

Handle incoming WebSocket messages from clients.

Parameters

session:WebSocketSession

Doc from org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageFromClient.

the client session

webSocketMessage:WebSocketMessage<?>

Doc from org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageFromClient.

the client message

targetChannel:MessageChannel

Doc from org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageFromClient.

an output channel to send messages to

Annotations

@Override

handleMessageToClient	back to summary
public void handleMessageToClient(WebSocketSession session, Message<?> message) Implements org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageToClient. Handle STOMP messages going back out to WebSocket clients. Parameters session:WebSocketSession Doc from org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageToClient. the client session message:Message<?> Doc from org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageToClient. the client message Annotations @Override @SuppressWarnings:unchecked

handleMessageToClient

back to summary

public void handleMessageToClient(WebSocketSession session, Message<?> message)

Implements org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageToClient.

Handle STOMP messages going back out to WebSocket clients.

Parameters

session:WebSocketSession

Doc from org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageToClient.

the client session

message:Message<?>

Doc from org.springframework.web.socket.messaging.SubProtocolHandler.handleMessageToClient.

the client message

Annotations

@Override
@SuppressWarnings:unchecked

isPreserveReceiveOrder	back to summary
public boolean isPreserveReceiveOrder() Whether the handler is configured to handle inbound messages in the order in which they were received. Since 6.1

isPreserveReceiveOrder

back to summary

public boolean isPreserveReceiveOrder()

Whether the handler is configured to handle inbound messages in the order in which they were received.

Since: 6.1

publishEvent	back to summary
private void publishEvent(ApplicationEventPublisher publisher, ApplicationEvent event)

resolveSessionId back to summary

resolveSessionId	back to summary
public String resolveSessionId(Message<?> message) Implements org.springframework.web.socket.messaging.SubProtocolHandler.resolveSessionId. Doc from org.springframework.web.socket.messaging.SubProtocolHandler.resolveSessionId. Resolve the session id from the given message or return `null`. Parameters message:Message<?> the message to resolve the session id from Annotations @Override @Nullable

public String resolveSessionId(Message<?> message)

Implements org.springframework.web.socket.messaging.SubProtocolHandler.resolveSessionId.

Doc from org.springframework.web.socket.messaging.SubProtocolHandler.resolveSessionId.

Resolve the session id from the given message or return null.

Parameters

message:Message<?>: the message to resolve the session id from

Annotations

@Override
@Nullable

sendErrorMessage	back to summary
private void sendErrorMessage(WebSocketSession session, Throwable error) Invoked when no `errorHandler` is configured to send an ERROR frame to the client.

sendToClient	back to summary
private void sendToClient(WebSocketSession session, StompHeaderAccessor stompAccessor, byte[] payload)

setApplicationEventPublisher	back to summary
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) Implements org.springframework.context.ApplicationEventPublisherAware.setApplicationEventPublisher. Doc from org.springframework.context.ApplicationEventPublisherAware.setApplicationEventPublisher. Set the ApplicationEventPublisher that this object runs in. Invoked after population of normal bean properties but before an init callback like InitializingBean's afterPropertiesSet or a custom init-method. Invoked before ApplicationContextAware's setApplicationContext. Parameters applicationEventPublisher:ApplicationEventPublisher event publisher to be used by this object Annotations @Override

setApplicationEventPublisher

back to summary

public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

Implements org.springframework.context.ApplicationEventPublisherAware.setApplicationEventPublisher.

Doc from org.springframework.context.ApplicationEventPublisherAware.setApplicationEventPublisher.

Set the ApplicationEventPublisher that this object runs in.

Invoked after population of normal bean properties but before an init callback like InitializingBean's afterPropertiesSet or a custom init-method. Invoked before ApplicationContextAware's setApplicationContext.

Parameters

applicationEventPublisher:ApplicationEventPublisher: event publisher to be used by this object

Annotations

@Override

setDecoder back to summary

setDecoder	back to summary
public void setDecoder(StompDecoder decoder) Configure a `StompDecoder` for decoding STOMP frames. Since 4.3.5

public void setDecoder(StompDecoder decoder)

Configure a StompDecoder for decoding STOMP frames.

Since: 4.3.5

setEncoder back to summary

setEncoder	back to summary
public void setEncoder(StompEncoder encoder) Configure a `StompEncoder` for encoding STOMP frames. Since 4.3.5

public void setEncoder(StompEncoder encoder)

Configure a StompEncoder for encoding STOMP frames.

Since: 4.3.5

setErrorHandler	back to summary
public void setErrorHandler(StompSubProtocolErrorHandler errorHandler) Configure a handler for error messages sent to clients which allows customizing the error messages or preventing them from being sent. By default this isn't configured in which case an ERROR frame is sent with a message header reflecting the error. Parameters errorHandler:StompSubProtocolErrorHandler the error handler

setErrorHandler

back to summary

public void setErrorHandler(StompSubProtocolErrorHandler errorHandler)

Configure a handler for error messages sent to clients which allows customizing the error messages or preventing them from being sent.

By default this isn't configured in which case an ERROR frame is sent with a message header reflecting the error.

Parameters

errorHandler:StompSubProtocolErrorHandler: the error handler

setHeaderInitializer back to summary

setHeaderInitializer	back to summary
public void setHeaderInitializer(MessageHeaderInitializer headerInitializer) Configure a `MessageHeaderInitializer` to apply to the headers of all messages created from decoded STOMP frames and other messages sent to the client inbound channel. By default this property is not set.

public void setHeaderInitializer(MessageHeaderInitializer headerInitializer)

Configure a MessageHeaderInitializer to apply to the headers of all messages created from decoded STOMP frames and other messages sent to the client inbound channel.

By default this property is not set.

setMessageSizeLimit	back to summary
public void setMessageSizeLimit(int messageSizeLimit) Configure the maximum size allowed for an incoming STOMP message. Since a STOMP message can be received in multiple WebSocket messages, buffering may be required and therefore it is necessary to know the maximum allowed message size. By default this property is set to 64K. Since 4.0.3

setMessageSizeLimit

back to summary

public void setMessageSizeLimit(int messageSizeLimit)

Configure the maximum size allowed for an incoming STOMP message. Since a STOMP message can be received in multiple WebSocket messages, buffering may be required and therefore it is necessary to know the maximum allowed message size.

By default this property is set to 64K.

Since: 4.0.3

setPreserveReceiveOrder back to summary

public void setPreserveReceiveOrder(boolean preserveReceiveOrder)

Whether client messages must be handled in the order received.

By default messages sent to the "clientInboundChannel" may not be handled in the same order because the channel is backed by a ThreadPoolExecutor that in turn does not guarantee processing in order.

When this flag is set to true messages within the same session will be sent to the "clientInboundChannel" one at a time to preserve the order in which they were received.

Parameters

preserveReceiveOrder:boolean: whether to publish in order

Since

6.1

toMutableAccessor	back to summary
protected StompHeaderAccessor toMutableAccessor(StompHeaderAccessor headerAccessor, Message<?> message)

toString back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations

@Override

org.springframework.web.socket.messaging back to summary

private Class StompSubProtocolHandler.DefaultStats

Class Inheritance

extends Object
implements Stats

java.lang.Object
org.springframework.web.socket.messaging.StompSubProtocolHandler.DefaultStats

All Implemented Interfaces

org.springframework.web.socket.messaging.StompSubProtocolHandler.Stats

Field Summary

Modifier and Type	Field and Description
private final AtomicInteger	connect
private final AtomicInteger	connected
private final AtomicInteger	disconnect

Constructor Summary

Access	Constructor and Description
private	DefaultStats()

Method Summary

Modifier and Type	Method and Description
public int	getTotalConnect() Implements org.springframework.web.socket.messaging.StompSubProtocolHandler.Stats.getTotalConnect. The number of CONNECT frames processed.
public int	getTotalConnected() Implements org.springframework.web.socket.messaging.StompSubProtocolHandler.Stats.getTotalConnected. The number of CONNECTED frames processed.
public int	getTotalDisconnect() Implements org.springframework.web.socket.messaging.StompSubProtocolHandler.Stats.getTotalDisconnect. The number of DISCONNECT frames processed.
public void	incrementConnectCount()
public void	incrementConnectedCount()
public void	incrementDisconnectCount()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

connect	back to summary
private final AtomicInteger connect

connected	back to summary
private final AtomicInteger connected

disconnect	back to summary
private final AtomicInteger disconnect

Constructor Detail

DefaultStats	back to summary
private DefaultStats()

Method Detail

getTotalConnect

back to summary

public int getTotalConnect()

Implements org.springframework.web.socket.messaging.StompSubProtocolHandler.Stats.getTotalConnect.

Doc from org.springframework.web.socket.messaging.StompSubProtocolHandler.Stats.getTotalConnect.

The number of CONNECT frames processed.

Annotations

@Override

getTotalConnected

back to summary

public int getTotalConnected()

Implements org.springframework.web.socket.messaging.StompSubProtocolHandler.Stats.getTotalConnected.

Doc from org.springframework.web.socket.messaging.StompSubProtocolHandler.Stats.getTotalConnected.

The number of CONNECTED frames processed.

Annotations

@Override

getTotalDisconnect

back to summary

public int getTotalDisconnect()

Implements org.springframework.web.socket.messaging.StompSubProtocolHandler.Stats.getTotalDisconnect.

Doc from org.springframework.web.socket.messaging.StompSubProtocolHandler.Stats.getTotalDisconnect.

The number of DISCONNECT frames processed.

Annotations

@Override

incrementConnectCount	back to summary
public void incrementConnectCount()

incrementConnectedCount	back to summary
public void incrementConnectedCount()

incrementDisconnectCount	back to summary
public void incrementDisconnectCount()

toString back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations

@Override

public Class StompSubProtocolHandler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class StompSubProtocolHandler.DefaultStats

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Interface StompSubProtocolHandler.Stats

Method Summary

Method Detail

Modifier and Type	Method and Description
public int	getTotalConnect() The number of CONNECT frames processed.
public int	getTotalConnected() The number of CONNECTED frames processed.
public int	getTotalDisconnect() The number of DISCONNECT frames processed.