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

Interface ActiveMQServerSessionPlugin

All Superinterfaces:
ActiveMQServerBasePlugin
All Known Subinterfaces:
ActiveMQServerPlugin
public interface ActiveMQServerSessionPlugin extends ActiveMQServerBasePlugin

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    afterCloseSession(org.apache.activemq.artemis.core.server.ServerSession session, boolean failed)
    After a session is closed
    default void
    afterCreateSession(org.apache.activemq.artemis.core.server.ServerSession session)
    After a session has been created.
    default void
    afterSessionMetadataAdded(org.apache.activemq.artemis.core.server.ServerSession session, String key, String data)
    After session metadata is added to the session
    default void
    beforeCloseSession(org.apache.activemq.artemis.core.server.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, org.apache.activemq.artemis.core.persistence.OperationContext context, Map<SimpleString,RoutingType> prefixes)
    Before a session is created.
    default void
    beforeSessionMetadataAdded(org.apache.activemq.artemis.core.server.ServerSession session, String key, String data)
    Before session metadata is added to the session
    default void
    duplicateSessionMetadataFailure(org.apache.activemq.artemis.core.server.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, setInit, unregistered

  • Method Details

    • 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, org.apache.activemq.artemis.core.persistence.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(org.apache.activemq.artemis.core.server.ServerSession session) throws ActiveMQException
      After a session has been created.
      Parameters:
      session - The newly created session
      Throws:
      ActiveMQException

    • beforeCloseSession

      default void beforeCloseSession(org.apache.activemq.artemis.core.server.ServerSession session, boolean failed) throws ActiveMQException
      Before a session is closed
      Parameters:
      session -
      failed -
      Throws:
      ActiveMQException

    • afterCloseSession

      default void afterCloseSession(org.apache.activemq.artemis.core.server.ServerSession session, boolean failed) throws ActiveMQException
      After a session is closed
      Parameters:
      session -
      failed -
      Throws:
      ActiveMQException

    • beforeSessionMetadataAdded

      default void beforeSessionMetadataAdded(org.apache.activemq.artemis.core.server.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(org.apache.activemq.artemis.core.server.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(org.apache.activemq.artemis.core.server.ServerSession session, String key, String data) throws ActiveMQException
      After session metadata is added to the session
      Parameters:
      session -
      key -
      data -
      Throws:
      ActiveMQException