Package org.apache.activemq.artemis.core.protocol.core

Interface CoreRemotingConnection

All Superinterfaces:
BufferHandler, RemotingConnection
All Known Implementing Classes:
RemotingConnectionImpl
public interface CoreRemotingConnection extends RemotingConnection
Extension of RemotingConnection for the ActiveMQ Artemis core protocol

  • Method Details

    • getChannelVersion

      int getChannelVersion()
      The client protocol used on the communication. This will determine if the client has support for certain packet types

    • isVersionBeforeAddressChange

      default boolean isVersionBeforeAddressChange()

    • isVersionBeforeAsyncResponseChange

      default boolean isVersionBeforeAsyncResponseChange()

    • isVersionSupportConsumerPriority

      default boolean isVersionSupportConsumerPriority()

    • isVersionNewFQQN

      default boolean isVersionNewFQQN()

    • isVersionSupportClientID

      default boolean isVersionSupportClientID()

    • isVersionSupportRouting

      default boolean isVersionSupportRouting()

    • isVersionSupportCommitV2

      default boolean isVersionSupportCommitV2()

    • isVersionUsingLongOnPageReplication

      default boolean isVersionUsingLongOnPageReplication()

    • isBeforeTwoEighteen

      default boolean isBeforeTwoEighteen()

    • isBeforeProducerMetricsChanged

      default boolean isBeforeProducerMetricsChanged()

    • setChannelVersion

      void setChannelVersion(int clientVersion)
      Sets the client protocol used on the communication. This will determine if the client has support for certain packet types

    • getChannel

      Channel getChannel(long channelID, int confWindowSize)
      Returns the channel with the channel id specified.

      If it does not exist create it with the confirmation window size.

      Parameters:
      channelID - the channel id
      confWindowSize - the confirmation window size
      Returns:
      the channel

    • putChannel

      void putChannel(long channelID, Channel channel)
      add the channel with the specified channel id
      Parameters:
      channelID - the channel id
      channel - the channel

    • removeChannel

      boolean removeChannel(long channelID)
      remove the channel with the specified channel id
      Parameters:
      channelID - the channel id
      Returns:
      true if removed

    • generateChannelID

      long generateChannelID()
      generate a unique (within this connection) channel id
      Returns:
      the id

    • syncIDGeneratorSequence

      void syncIDGeneratorSequence(long id)
      Resets the id generator used to generate id's.
      Parameters:
      id - the first id to set it to

    • getIDGeneratorSequence

      long getIDGeneratorSequence()
      Returns the next id to be chosen.
      Returns:
      the next id to be chosen

    • getBlockingCallTimeout

      long getBlockingCallTimeout()
      Returns the current timeout for blocking calls).
      Returns:
      the current timeout for blocking calls)

    • getBlockingCallFailoverTimeout

      long getBlockingCallFailoverTimeout()
      Returns the current timeout for blocking calls.
      Returns:
      the current timeout for blocking calls

    • getTransferLock

      Object getTransferLock()
      Returns the transfer lock used when transferring connections.
      Returns:
      the transfer lock used when transferring connections

    • getDefaultActiveMQPrincipal

      ActiveMQPrincipal getDefaultActiveMQPrincipal()
      Returns the default security principal.
      Returns:
      the default security principal

    • blockUntilWritable

      boolean blockUntilWritable(long timeout)