Class RabbitAccessor

java.lang.Object
org.springframework.amqp.rabbit.connection.RabbitAccessor
All Implemented Interfaces:
InitializingBean
Direct Known Subclasses:
ObservableListenerContainer, RabbitTemplate
public abstract class RabbitAccessor extends Object implements InitializingBean
Author:
Mark Fisher, Dave Syer, Gary Russell, Artem Bilan

  • Field Details

    • logger

      protected final Log logger
      Logger available to subclasses.

  • Constructor Details

    • RabbitAccessor

      public RabbitAccessor()

  • Method Details

    • isChannelTransacted

      public boolean isChannelTransacted()

    • setChannelTransacted

      public void setChannelTransacted(boolean transactional)
      Flag to indicate that channels created by this component will be transactional.
      Parameters:
      transactional - the flag value to set

    • setConnectionFactory

      public void setConnectionFactory(ConnectionFactory connectionFactory)
      Set the ConnectionFactory to use for obtaining RabbitMQ Connections.
      Parameters:
      connectionFactory - The connection factory.

    • getConnectionFactory

      public ConnectionFactory getConnectionFactory()
      Returns:
      The ConnectionFactory that this accessor uses for obtaining RabbitMQ Connections.

    • afterPropertiesSet

      public void afterPropertiesSet()
      Specified by:
      afterPropertiesSet in interface InitializingBean

    • createConnection

      protected Connection createConnection()
      Create a RabbitMQ Connection via this template's ConnectionFactory and its host and port values.
      Returns:
      the new RabbitMQ Connection
      See Also:

    • getConnection

      protected @Nullable Connection getConnection(RabbitResourceHolder holder)
      Fetch an appropriate Connection from the given RabbitResourceHolder.
      Parameters:
      holder - the RabbitResourceHolder
      Returns:
      an appropriate Connection fetched from the holder, or null if none found

    • getChannel

      protected @Nullable com.rabbitmq.client.Channel getChannel(RabbitResourceHolder holder)
      Fetch an appropriate Channel from the given RabbitResourceHolder.
      Parameters:
      holder - the RabbitResourceHolder
      Returns:
      an appropriate Channel fetched from the holder, or null if none found

    • getTransactionalResourceHolder

      protected RabbitResourceHolder getTransactionalResourceHolder()

    • convertRabbitAccessException

      protected RuntimeException convertRabbitAccessException(Exception ex)

    • obtainObservationRegistry

      protected void obtainObservationRegistry(@Nullable ApplicationContext appContext)

    • getObservationRegistry

      protected io.micrometer.observation.ObservationRegistry getObservationRegistry()