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

Interface SessionCallback

All Known Implementing Classes:
CoreSessionCallback
public interface SessionCallback

  • Method Details

    • supportsDirectDelivery

      default boolean supportsDirectDelivery()
      A requirement to do direct delivery is: no extra locking required at the protocol layer. which cannot be guaranteed at AMQP as proton will need the locking. So, disable this on AMQP or any other protocol requiring extra lock.

    • hasCredits

      boolean hasCredits(ServerConsumer consumerID)
      This one gives a chance for Proton to have its own flow control.

    • hasCredits

      default boolean hasCredits(ServerConsumer consumerID, MessageReference ref)
      This one includes the MessageReference for protocols like MQTT 5 (which only enforces flow control on durable messages (i.e. QoS 1 & 2))

    • afterDelivery

      void afterDelivery() throws Exception
      This can be used to complete certain operations outside of the lock, like acks or other operations.
      Throws:
      Exception

    • updateDeliveryCountAfterCancel

      boolean updateDeliveryCountAfterCancel(ServerConsumer consumer, MessageReference ref, boolean failed)
      Use this to updates specifics on the message after a redelivery happened. Return true if there was specific logic applied on the protocol, so the ServerConsumer won't make any adjustments.

    • sendProducerCreditsMessage

      void sendProducerCreditsMessage(int credits, SimpleString address)

    • sendProducerCreditsFailMessage

      void sendProducerCreditsFailMessage(int credits, SimpleString address)

    • sendMessage

      int sendMessage(MessageReference ref, ServerConsumer consumerID, int deliveryCount)

    • sendLargeMessage

      int sendLargeMessage(MessageReference ref, ServerConsumer consumerID, long bodySize, int deliveryCount)

    • sendLargeMessageContinuation

      int sendLargeMessageContinuation(ServerConsumer consumerID, byte[] body, boolean continues, boolean requiresResponse)

    • closed

      void closed()

    • disconnect

      void disconnect(ServerConsumer consumerId, String errorMessage)

    • isWritable

      boolean isWritable(ReadyListener callback, Object protocolContext)

    • browserFinished

      void browserFinished(ServerConsumer consumer)
      Some protocols (Openwire) needs a special message with the browser is finished.

    • close

      default void close(boolean failed)

    • getCurrentTransaction

      default Transaction getCurrentTransaction()