Package org.acemq.spring.boot

Class AceMqProperties

java.lang.Object
org.acemq.spring.boot.AceMqProperties
@ConfigurationProperties(prefix="acemq") public class AceMqProperties extends Object
Everything under acemq.* in an application's configuration.

The shape follows the library's own vocabulary rather than Spring AMQP's, because a property that is called something different from the method it configures is a property somebody has to look up twice. acemq.publisher-confirms sets ConnectionConfig.Builder.withoutPublisherConfirms() when false, and the two are named the same thing on purpose.

Nothing here has a default that costs money or safety. Confirms are on, TLS verification is on when TLS is on, and the topology is not applied unless something is declared. The one opinionated default is the URL: amqp://localhost:5672, so a developer with a broker in Docker needs no configuration at all.

  • Constructor Details

    • AceMqProperties

      public AceMqProperties()

  • Method Details

    • isEnabled

      public boolean isEnabled()

    • setEnabled

      public void setEnabled(boolean enabled)

    • getUrl

      public String getUrl()

    • setUrl

      public void setUrl(String url)

    • getUsername

      public String getUsername()

    • setUsername

      public void setUsername(String username)

    • getPassword

      public String getPassword()

    • setPassword

      public void setPassword(String password)

    • getVirtualHost

      public String getVirtualHost()

    • setVirtualHost

      public void setVirtualHost(String virtualHost)

    • getClientName

      public String getClientName()

    • setClientName

      public void setClientName(String clientName)

    • getConnectionTimeout

      public Duration getConnectionTimeout()

    • setConnectionTimeout

      public void setConnectionTimeout(Duration connectionTimeout)

    • getConfirmTimeout

      public Duration getConfirmTimeout()

    • setConfirmTimeout

      public void setConfirmTimeout(Duration confirmTimeout)

    • getBlockedTimeout

      public Duration getBlockedTimeout()

    • setBlockedTimeout

      public void setBlockedTimeout(Duration blockedTimeout)

    • isPublisherConfirms

      public boolean isPublisherConfirms()

    • setPublisherConfirms

      public void setPublisherConfirms(boolean publisherConfirms)

    • getMaxOutstandingPublishes

      public int getMaxOutstandingPublishes()

    • setMaxOutstandingPublishes

      public void setMaxOutstandingPublishes(int maxOutstandingPublishes)

    • getFormat

      public String getFormat()

    • setFormat

      public void setFormat(String format)

    • getTls

      public AceMqProperties.Tls getTls()

    • getTopology

      public AceMqProperties.Topology getTopology()

    • getListener

      public AceMqProperties.Listener getListener()