Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	AbstractBrokerMessageHandler.UnsentDisconnectChannelInterceptor Detect unsent DISCONNECT messages and process them anyway.

Field Summary

Modifier and Type	Field and Description
private boolean	autoStartup
private final BrokerAvailabilityEvent	availableEvent
private final AtomicBoolean	brokerAvailable
private final SubscribableChannel	brokerChannel
private final SubscribableChannel	clientInboundChannel
private final MessageChannel	clientOutboundChannel
private final Collection<String>	destinationPrefixes
private ApplicationEventPublisher	eventPublisher
private final Object	lifecycleMonitor
protected final Log	logger
private final BrokerAvailabilityEvent	notAvailableEvent
private Integer	phase
private boolean	preservePublishOrder
private volatile boolean	running
private final ChannelInterceptor	unsentDisconnectInterceptor
private Predicate<String>	userDestinationPredicate

Constructor Summary

Access	Constructor and Description
public	AbstractBrokerMessageHandler(SubscribableChannel the channel for receiving messages from clients (e.g. WebSocket clients) inboundChannel, MessageChannel the channel for sending messages to clients (e.g. WebSocket clients) outboundChannel, SubscribableChannel the channel for the application to send messages to the broker brokerChannel) Constructor with no destination prefixes (matches all destinations).
public	AbstractBrokerMessageHandler(SubscribableChannel the channel for receiving messages from clients (e.g. WebSocket clients) inboundChannel, MessageChannel the channel for sending messages to clients (e.g. WebSocket clients) outboundChannel, SubscribableChannel the channel for the application to send messages to the broker brokerChannel, Collection<String> prefixes to use to filter out messages destinationPrefixes) Constructor with destination prefixes to match to destinations of messages.

Access

Constructor and Description

public

AbstractBrokerMessageHandler(SubscribableChannel

the channel for receiving messages from clients (e.g. WebSocket clients)

inboundChannel, MessageChannel

the channel for sending messages to clients (e.g. WebSocket clients)

outboundChannel, SubscribableChannel

the channel for the application to send messages to the broker

brokerChannel)

Constructor with no destination prefixes (matches all destinations).

public

AbstractBrokerMessageHandler(SubscribableChannel

the channel for receiving messages from clients (e.g. WebSocket clients)

inboundChannel, MessageChannel

the channel for sending messages to clients (e.g. WebSocket clients)

outboundChannel, SubscribableChannel

the channel for the application to send messages to the broker

brokerChannel, Collection<String>

prefixes to use to filter out messages

destinationPrefixes)

Constructor with destination prefixes to match to destinations of messages.

Method Summary

Modifier and Type	Method and Description
protected boolean	Returns: whether to process (true) or skip (false) the destination checkDestinationPrefix(String the destination to check destination) Whether a message with the given destination should be processed.
public ApplicationEventPublisher	getApplicationEventPublisher()
public SubscribableChannel	getBrokerChannel()
public SubscribableChannel	getClientInboundChannel()
public MessageChannel	getClientOutboundChannel()
protected MessageChannel	getClientOutboundChannelForSession(String sessionId) Get the MessageChannel to use for sending messages to clients, possibly a per-session wrapper when `preservePublishOrder=true`.
public Collection<String>	getDestinationPrefixes() Return destination prefixes to use to filter messages to forward to the broker.
public int	getPhase() Overrides default org.springframework.context.SmartLifecycle.getPhase. Return the phase that this lifecycle object is supposed to run in. The default implementation returns `DEFAULT_PHASE` in order to let `stop()` callbacks execute before regular `Lifecycle` implementations.
public void	handleMessage(Message<?> the message to be handled message) Implements org.springframework.messaging.MessageHandler.handleMessage. Handle the given message.
protected abstract void	handleMessageInternal(Message<?> message)
public boolean	isAutoStartup() Overrides default org.springframework.context.SmartLifecycle.isAutoStartup. Returns `true` if this `Lifecycle` component should get started automatically by the container at the time that the containing `ApplicationContext` gets refreshed.
public boolean	isBrokerAvailable() Whether the message broker is currently available and able to process messages.
public boolean	isPreservePublishOrder() Whether to ensure messages are received in the order of publication.
public final boolean	isRunning() Implements org.springframework.context.Lifecycle.isRunning. Check whether this message handler is currently running.
private boolean	isUserDestination(String destination)
protected void	publishBrokerAvailableEvent()
protected void	publishBrokerUnavailableEvent()
public void	setApplicationEventPublisher(ApplicationEventPublisher event publisher to be used by this object publisher) 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	setAutoStartup(boolean autoStartup)
public void	setPhase(int phase) Set the phase that this handler should run in. By default, this is `SmartLifecycle#DEFAULT_PHASE`.
public void	setPreservePublishOrder(boolean whether to publish in order preservePublishOrder) Whether the client must receive messages in the order of publication.
public void	setUserDestinationPredicate(Predicate<String> the predicate to identify user messages with a non-null destination as messages with a user destinations. predicate) Configure a Predicate to identify messages with a user destination.
public void	start() Implements org.springframework.context.Lifecycle.start. Start this component.
protected void	startInternal()
public void	stop() Implements org.springframework.context.Lifecycle.stop. Stop this component, typically in a synchronous fashion, such that the component is fully stopped upon return of this method.
public final void	stop(Runnable callback) Overrides default org.springframework.context.SmartLifecycle.stop. Indicates that a Lifecycle component must stop if it is currently running.
protected void	stopInternal()

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

Field Detail

autoStartup	back to summary
private boolean autoStartup

availableEvent	back to summary
private final BrokerAvailabilityEvent availableEvent

brokerAvailable	back to summary
private final AtomicBoolean brokerAvailable

brokerChannel	back to summary
private final SubscribableChannel brokerChannel

clientInboundChannel	back to summary
private final SubscribableChannel clientInboundChannel

clientOutboundChannel	back to summary
private final MessageChannel clientOutboundChannel

destinationPrefixes	back to summary
private final Collection<String> destinationPrefixes

eventPublisher	back to summary
private ApplicationEventPublisher eventPublisher Annotations @Nullable

lifecycleMonitor	back to summary
private final Object lifecycleMonitor

logger	back to summary
protected final Log logger

notAvailableEvent	back to summary
private final BrokerAvailabilityEvent notAvailableEvent

phase	back to summary
private Integer phase Annotations @Nullable

preservePublishOrder	back to summary
private boolean preservePublishOrder

running	back to summary
private volatile boolean running

unsentDisconnectInterceptor	back to summary
private final ChannelInterceptor unsentDisconnectInterceptor

userDestinationPredicate	back to summary
private Predicate<String> userDestinationPredicate Annotations @Nullable

Constructor Detail

AbstractBrokerMessageHandler	back to summary
public AbstractBrokerMessageHandler(SubscribableChannel inboundChannel, MessageChannel outboundChannel, SubscribableChannel brokerChannel) Constructor with no destination prefixes (matches all destinations). Parameters inboundChannel:SubscribableChannel the channel for receiving messages from clients (e.g. WebSocket clients) outboundChannel:MessageChannel the channel for sending messages to clients (e.g. WebSocket clients) brokerChannel:SubscribableChannel the channel for the application to send messages to the broker

AbstractBrokerMessageHandler

back to summary

public AbstractBrokerMessageHandler(SubscribableChannel inboundChannel, MessageChannel outboundChannel, SubscribableChannel brokerChannel)

Constructor with no destination prefixes (matches all destinations).

Parameters

inboundChannel:SubscribableChannel: the channel for receiving messages from clients (e.g. WebSocket clients)
outboundChannel:MessageChannel: the channel for sending messages to clients (e.g. WebSocket clients)
brokerChannel:SubscribableChannel: the channel for the application to send messages to the broker

AbstractBrokerMessageHandler	back to summary
public AbstractBrokerMessageHandler(SubscribableChannel inboundChannel, MessageChannel outboundChannel, SubscribableChannel brokerChannel, Collection<String> destinationPrefixes) Constructor with destination prefixes to match to destinations of messages. Parameters inboundChannel:SubscribableChannel the channel for receiving messages from clients (e.g. WebSocket clients) outboundChannel:MessageChannel the channel for sending messages to clients (e.g. WebSocket clients) brokerChannel:SubscribableChannel the channel for the application to send messages to the broker destinationPrefixes:Collection<String> prefixes to use to filter out messages

AbstractBrokerMessageHandler

back to summary

public AbstractBrokerMessageHandler(SubscribableChannel inboundChannel, MessageChannel outboundChannel, SubscribableChannel brokerChannel, Collection<String> destinationPrefixes)

Constructor with destination prefixes to match to destinations of messages.

Parameters

inboundChannel:SubscribableChannel: the channel for receiving messages from clients (e.g. WebSocket clients)
outboundChannel:MessageChannel: the channel for sending messages to clients (e.g. WebSocket clients)
brokerChannel:SubscribableChannel: the channel for the application to send messages to the broker
destinationPrefixes:Collection<String>: prefixes to use to filter out messages

Method Detail

checkDestinationPrefix back to summary

checkDestinationPrefix	back to summary
protected boolean checkDestinationPrefix(String destination) Whether a message with the given destination should be processed. This is the case if one of the following conditions is true: The destination starts with one of the configured `destination prefixes`. No prefixes are configured and the destination isn't matched by the `userDestinationPredicate`. The message has no destination. Parameters destination:String the destination to check Returns:boolean whether to process (true) or skip (false) the destination

protected boolean checkDestinationPrefix(String destination)

Whether a message with the given destination should be processed. This is the case if one of the following conditions is true:

The destination starts with one of the configured destination prefixes.
No prefixes are configured and the destination isn't matched by the userDestinationPredicate.
The message has no destination.

Parameters

destination:String: the destination to check

Returns:boolean

whether to process (true) or skip (false) the destination

getApplicationEventPublisher	back to summary
public ApplicationEventPublisher getApplicationEventPublisher() Annotations @Nullable

getBrokerChannel	back to summary
public SubscribableChannel getBrokerChannel()

getClientInboundChannel	back to summary
public SubscribableChannel getClientInboundChannel()

getClientOutboundChannel	back to summary
public MessageChannel getClientOutboundChannel()

getClientOutboundChannelForSession back to summary

getClientOutboundChannelForSession	back to summary
protected MessageChannel getClientOutboundChannelForSession(String sessionId) Get the MessageChannel to use for sending messages to clients, possibly a per-session wrapper when `preservePublishOrder=true`. Since 5.1

protected MessageChannel getClientOutboundChannelForSession(String sessionId)

Get the MessageChannel to use for sending messages to clients, possibly a per-session wrapper when preservePublishOrder=true.

Since: 5.1

getDestinationPrefixes	back to summary
public Collection<String> getDestinationPrefixes() Return destination prefixes to use to filter messages to forward to the broker. Messages that have a destination and where the destination doesn't match are ignored. By default this is not set.

getDestinationPrefixes

back to summary

public Collection<String> getDestinationPrefixes()

Return destination prefixes to use to filter messages to forward to the broker. Messages that have a destination and where the destination doesn't match are ignored.

By default this is not set.

getPhase back to summary

getPhase	back to summary
public int getPhase() Overrides default org.springframework.context.SmartLifecycle.getPhase. Doc from org.springframework.context.SmartLifecycle.getPhase. Return the phase that this lifecycle object is supposed to run in. The default implementation returns `DEFAULT_PHASE` in order to let `stop()` callbacks execute before regular `Lifecycle` implementations. Annotations @Override

public int getPhase()

Overrides default org.springframework.context.SmartLifecycle.getPhase.

Doc from org.springframework.context.SmartLifecycle.getPhase.

Return the phase that this lifecycle object is supposed to run in.

The default implementation returns DEFAULT_PHASE in order to let stop() callbacks execute before regular Lifecycle implementations.

Annotations

@Override

handleMessage	back to summary
public void handleMessage(Message<?> message) Implements org.springframework.messaging.MessageHandler.handleMessage. Doc from org.springframework.messaging.MessageHandler.handleMessage. Handle the given message. Parameters message:Message<?> the message to be handled Annotations @Override

handleMessage

back to summary

public void handleMessage(Message<?> message)

Implements org.springframework.messaging.MessageHandler.handleMessage.

Doc from org.springframework.messaging.MessageHandler.handleMessage.

Handle the given message.

Parameters

message:Message<?>: the message to be handled

Annotations

@Override

handleMessageInternal	back to summary
protected abstract void handleMessageInternal(Message<?> message)

isAutoStartup back to summary

isAutoStartup	back to summary
public boolean isAutoStartup() Overrides default org.springframework.context.SmartLifecycle.isAutoStartup. Doc from org.springframework.context.SmartLifecycle.isAutoStartup. Returns `true` if this `Lifecycle` component should get started automatically by the container at the time that the containing `ApplicationContext` gets refreshed. A value of `false` indicates that the component is intended to be started through an explicit `start()` call instead, analogous to a plain `Lifecycle` implementation. The default implementation returns `true`. Annotations @Override

public boolean isAutoStartup()

Overrides default org.springframework.context.SmartLifecycle.isAutoStartup.

Doc from org.springframework.context.SmartLifecycle.isAutoStartup.

Returns true if this Lifecycle component should get started automatically by the container at the time that the containing ApplicationContext gets refreshed.

A value of false indicates that the component is intended to be started through an explicit start() call instead, analogous to a plain Lifecycle implementation.

The default implementation returns true.

Annotations

@Override

isBrokerAvailable back to summary

isBrokerAvailable	back to summary
public boolean isBrokerAvailable() Whether the message broker is currently available and able to process messages. Note that this is in addition to the `isRunning()` flag, which indicates whether this message handler is running. In other words the message handler must first be running and then the `#isBrokerAvailable()` flag may still independently alternate between being on and off depending on the concrete subclass implementation. Application components may implement `org.springframework.context.ApplicationListener<BrokerAvailabilityEvent>` to receive notifications when broker becomes available and unavailable.

public boolean isBrokerAvailable()

Whether the message broker is currently available and able to process messages.

Note that this is in addition to the isRunning() flag, which indicates whether this message handler is running. In other words the message handler must first be running and then the #isBrokerAvailable() flag may still independently alternate between being on and off depending on the concrete subclass implementation.

Application components may implement org.springframework.context.ApplicationListener<BrokerAvailabilityEvent> to receive notifications when broker becomes available and unavailable.

isPreservePublishOrder	back to summary
public boolean isPreservePublishOrder() Whether to ensure messages are received in the order of publication. Since 5.1

isPreservePublishOrder

back to summary

public boolean isPreservePublishOrder()

Whether to ensure messages are received in the order of publication.

Since: 5.1

isRunning back to summary

isRunning	back to summary
public final boolean isRunning() Implements org.springframework.context.Lifecycle.isRunning. Check whether this message handler is currently running. Note that even when this message handler is running the `isBrokerAvailable()` flag may still independently alternate between being on and off depending on the concrete subclass implementation. Returns:boolean Doc from org.springframework.context.Lifecycle.isRunning. whether the component is currently running Annotations @Override

public final boolean isRunning()

Implements org.springframework.context.Lifecycle.isRunning.

Check whether this message handler is currently running.

Note that even when this message handler is running the isBrokerAvailable() flag may still independently alternate between being on and off depending on the concrete subclass implementation.

Returns:boolean

Doc from org.springframework.context.Lifecycle.isRunning.

whether the component is currently running

Annotations

@Override

isUserDestination	back to summary
private boolean isUserDestination(String destination)

publishBrokerAvailableEvent	back to summary
protected void publishBrokerAvailableEvent()

publishBrokerUnavailableEvent	back to summary
protected void publishBrokerUnavailableEvent()

setApplicationEventPublisher	back to summary
public void setApplicationEventPublisher(ApplicationEventPublisher publisher) 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 publisher:ApplicationEventPublisher event publisher to be used by this object Annotations @Override

setApplicationEventPublisher

back to summary

public void setApplicationEventPublisher(ApplicationEventPublisher publisher)

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

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

Annotations

@Override

setAutoStartup	back to summary
public void setAutoStartup(boolean autoStartup)

setPhase back to summary

setPhase	back to summary
public void setPhase(int phase) Set the phase that this handler should run in. By default, this is `SmartLifecycle#DEFAULT_PHASE`. Since 6.1.4

public void setPhase(int phase)

Set the phase that this handler should run in.

By default, this is SmartLifecycle#DEFAULT_PHASE.

Since: 6.1.4

setPreservePublishOrder back to summary

setPreservePublishOrder	back to summary
public void setPreservePublishOrder(boolean preservePublishOrder) Whether the client must receive messages in the order of publication. By default messages sent to the `"clientOutboundChannel"` may not be processed 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 `"clientOutboundChannel"` one at a time in order to preserve the order of publication. Parameters preservePublishOrder:boolean whether to publish in order Since 5.1

public void setPreservePublishOrder(boolean preservePublishOrder)

Whether the client must receive messages in the order of publication.

By default messages sent to the "clientOutboundChannel" may not be processed 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 "clientOutboundChannel" one at a time in order to preserve the order of publication.

Parameters

preservePublishOrder:boolean: whether to publish in order

Since

5.1

setUserDestinationPredicate back to summary

setUserDestinationPredicate	back to summary
public void setUserDestinationPredicate(Predicate<String> predicate) Configure a Predicate to identify messages with a user destination. When no `destination prefixes` are configured, this helps to recognize and skip user destination messages that need to be pre-processed by the `org.springframework.messaging.simp.user.UserDestinationMessageHandler` before they reach the broker. Parameters predicate:Predicate<String> the predicate to identify user messages with a non-null destination as messages with a user destinations. Since 5.3.4

public void setUserDestinationPredicate(Predicate<String> predicate)

Configure a Predicate to identify messages with a user destination. When no destination prefixes are configured, this helps to recognize and skip user destination messages that need to be pre-processed by the org.springframework.messaging.simp.user.UserDestinationMessageHandler before they reach the broker.

Parameters

predicate:Predicate<String>: the predicate to identify user messages with a non-null destination as messages with a user destinations.

Since

5.3.4

start	back to summary
public void start() Implements org.springframework.context.Lifecycle.start. Doc from org.springframework.context.Lifecycle.start. Start this component. Should not throw an exception if the component is already running. In the case of a container, this will propagate the start signal to all components that apply. Annotations @Override

start

back to summary

public void start()

Implements org.springframework.context.Lifecycle.start.

Doc from org.springframework.context.Lifecycle.start.

Start this component.

Should not throw an exception if the component is already running.

In the case of a container, this will propagate the start signal to all components that apply.

Annotations

@Override

startInternal	back to summary
protected void startInternal()

stop back to summary

stop	back to summary
public void stop() Implements org.springframework.context.Lifecycle.stop. Doc from org.springframework.context.Lifecycle.stop. Stop this component, typically in a synchronous fashion, such that the component is fully stopped upon return of this method. Consider implementing `SmartLifecycle` and its `stop(Runnable)` variant when asynchronous stop behavior is necessary. Note that this stop notification is not guaranteed to come before destruction: On regular shutdown, `Lifecycle` beans will first receive a stop notification before the general destruction callbacks are being propagated; however, on hot refresh during a context's lifetime or on aborted refresh attempts, a given bean's destroy method will be called without any consideration of stop signals upfront. Should not throw an exception if the component is not running (not started yet). In the case of a container, this will propagate the stop signal to all components that apply. Annotations @Override

public void stop()

Implements org.springframework.context.Lifecycle.stop.

Doc from org.springframework.context.Lifecycle.stop.

Stop this component, typically in a synchronous fashion, such that the component is fully stopped upon return of this method. Consider implementing SmartLifecycle and its stop(Runnable) variant when asynchronous stop behavior is necessary.

Note that this stop notification is not guaranteed to come before destruction: On regular shutdown, Lifecycle beans will first receive a stop notification before the general destruction callbacks are being propagated; however, on hot refresh during a context's lifetime or on aborted refresh attempts, a given bean's destroy method will be called without any consideration of stop signals upfront.

Should not throw an exception if the component is not running (not started yet).

In the case of a container, this will propagate the stop signal to all components that apply.

Annotations

@Override

stop back to summary

stop	back to summary
public final void stop(Runnable callback) Overrides default org.springframework.context.SmartLifecycle.stop. Doc from org.springframework.context.SmartLifecycle.stop. Indicates that a Lifecycle component must stop if it is currently running. The provided callback is used by the `LifecycleProcessor` to support an ordered, and potentially concurrent, shutdown of all components having a common shutdown order value. The callback must be executed after the `SmartLifecycle` component does indeed stop. The `LifecycleProcessor` will call only this variant of the `stop` method; i.e. `Lifecycle#stop()` will not be called for `SmartLifecycle` implementations unless explicitly delegated to within the implementation of this method. The default implementation delegates to `stop()` and immediately triggers the given callback in the calling thread. Note that there is no synchronization between the two, so custom implementations may at least want to put the same steps within their common lifecycle monitor (if any). Annotations @Override

public final void stop(Runnable callback)

Overrides default org.springframework.context.SmartLifecycle.stop.

Doc from org.springframework.context.SmartLifecycle.stop.

Indicates that a Lifecycle component must stop if it is currently running.

The provided callback is used by the LifecycleProcessor to support an ordered, and potentially concurrent, shutdown of all components having a common shutdown order value. The callback must be executed after the SmartLifecycle component does indeed stop.

The LifecycleProcessor will call only this variant of the stop method; i.e. Lifecycle#stop() will not be called for SmartLifecycle implementations unless explicitly delegated to within the implementation of this method.

The default implementation delegates to stop() and immediately triggers the given callback in the calling thread. Note that there is no synchronization between the two, so custom implementations may at least want to put the same steps within their common lifecycle monitor (if any).

Annotations

@Override

stopInternal	back to summary
protected void stopInternal()

org.springframework.messaging.simp.broker back to summary

private Class AbstractBrokerMessageHandler.UnsentDisconnectChannelInterceptor

Class Inheritance

extends Object
implements ChannelInterceptor

java.lang.Object
org.springframework.messaging.simp.broker.AbstractBrokerMessageHandler.UnsentDisconnectChannelInterceptor

All Implemented Interfaces

org.springframework.messaging.support.ChannelInterceptor

Detect unsent DISCONNECT messages and process them anyway.

Constructor Summary

Access	Constructor and Description
private	UnsentDisconnectChannelInterceptor()

Method Summary

Modifier and Type	Method and Description
public void	afterSendCompletion(Message<?> message, MessageChannel channel, boolean sent, Exception ex) Overrides default org.springframework.messaging.support.ChannelInterceptor.afterSendCompletion. Invoked after the completion of a send regardless of any exception that have been raised thus allowing for proper resource cleanup.

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

Constructor Detail

UnsentDisconnectChannelInterceptor	back to summary
private UnsentDisconnectChannelInterceptor()

Method Detail

afterSendCompletion back to summary

public void afterSendCompletion(Message<?> message, MessageChannel channel, boolean sent, Exception ex)

Overrides default org.springframework.messaging.support.ChannelInterceptor.afterSendCompletion.

Doc from org.springframework.messaging.support.ChannelInterceptor.afterSendCompletion.

Invoked after the completion of a send regardless of any exception that have been raised thus allowing for proper resource cleanup.

Note that this will be invoked only if preSend successfully completed and returned a Message, i.e. it did not return null.

Annotations

@Override

public abstract Class AbstractBrokerMessageHandler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class AbstractBrokerMessageHandler.UnsentDisconnectChannelInterceptor

Constructor Summary

Method Summary

Constructor Detail

Method Detail