org.apache.activemq.artemis.core.server.plugin

Interface ActiveMQServerSessionPlugin

All Superinterfaces:

ActiveMQServerBasePlugin

All Known Subinterfaces:

ActiveMQServerPlugin

All Known Implementing Classes:

LoggingActiveMQServerPlugin, NotificationActiveMQServerPlugin

public interface ActiveMQServerSessionPlugin
extends ActiveMQServerBasePlugin

Method Summary

Modifier and Type	Method and Description
default void	afterCloseSession(ServerSession session, boolean failed) After a session is closed
default void	afterCreateSession(ServerSession session) After a session has been created.
default void	afterSessionMetadataAdded(ServerSession session, String key, String data) After session metadata is added to the session
default void	beforeCloseSession(ServerSession session, boolean failed) Before a session is closed
default void	beforeCreateSession(String name, String username, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString,RoutingType> prefixes) Before a session is created.
default void	beforeSessionMetadataAdded(ServerSession session, String key, String data) Before session metadata is added to the session
default void	duplicateSessionMetadataFailure(ServerSession session, String key, String data) Called when adding session metadata fails because the metadata is a duplicate

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBasePlugin

init, registered, unregistered

Method Detail

beforeCreateSession

default void beforeCreateSession(String name,
                                 String username,
                                 int minLargeMessageSize,
                                 RemotingConnection connection,
                                 boolean autoCommitSends,
                                 boolean autoCommitAcks,
                                 boolean preAcknowledge,
                                 boolean xa,
                                 String defaultAddress,
                                 SessionCallback callback,
                                 boolean autoCreateQueues,
                                 OperationContext context,
                                 Map<SimpleString,RoutingType> prefixes)
                          throws ActiveMQException

Before a session is created.

Parameters:

name -

username -

minLargeMessageSize -

connection -

autoCommitSends -

autoCommitAcks -

preAcknowledge -

xa -

defaultAddress -

callback -

autoCreateQueues -

context -

prefixes -

Throws:

ActiveMQException

afterCreateSession

default void afterCreateSession(ServerSession session)
                         throws ActiveMQException

After a session has been created.

Parameters:

session - The newly created session

Throws:

ActiveMQException

beforeCloseSession

default void beforeCloseSession(ServerSession session,
                                boolean failed)
                         throws ActiveMQException

Before a session is closed

Parameters:

session -

failed -

Throws:

ActiveMQException

afterCloseSession

default void afterCloseSession(ServerSession session,
                               boolean failed)
                        throws ActiveMQException

After a session is closed

Parameters:

session -

failed -

Throws:

ActiveMQException

beforeSessionMetadataAdded

default void beforeSessionMetadataAdded(ServerSession session,
                                        String key,
                                        String data)
                                 throws ActiveMQException

Before session metadata is added to the session

Parameters:

session -

key -

data -

Throws:

ActiveMQException

duplicateSessionMetadataFailure

default void duplicateSessionMetadataFailure(ServerSession session,
                                             String key,
                                             String data)
                                      throws ActiveMQException

Called when adding session metadata fails because the metadata is a duplicate

Parameters:

session -

key -

data -

Throws:

ActiveMQException

afterSessionMetadataAdded

default void afterSessionMetadataAdded(ServerSession session,
                                       String key,
                                       String data)
                                throws ActiveMQException

After session metadata is added to the session

Parameters:

session -

key -

data -

Throws:

ActiveMQException