package amqp
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- final class AmqpCachedConnectionProvider extends AmqpConnectionProvider
- final class AmqpConnectionFactoryConnectionProvider extends AmqpConnectionProvider
Uses a native com.rabbitmq.client.ConnectionFactory to configure an AMQP connection factory.
- sealed trait AmqpConnectionProvider extends AnyRef
Only for internal implementations
Only for internal implementations
- Annotations
- @DoNotInherit()
- sealed trait AmqpConnectorSettings extends AnyRef
Internal API
Internal API
- Annotations
- @InternalApi()
- final class AmqpCredentials extends AnyRef
- final class AmqpDetailsConnectionProvider extends AmqpConnectionProvider
- final class AmqpReplyToSinkSettings extends AmqpConnectorSettings
- final class AmqpSSLConfiguration extends AnyRef
- sealed trait AmqpSourceSettings extends AmqpConnectorSettings
- final class AmqpUriConnectionProvider extends AmqpConnectionProvider
- final class AmqpWriteSettings extends AmqpConnectorSettings
- final class BindingDeclaration extends Declaration
- sealed trait Declaration extends AnyRef
- final class ExchangeDeclaration extends Declaration
- final class NamedQueueSourceSettings extends AmqpSourceSettings
- final class QueueDeclaration extends Declaration
- final class ReadResult extends AnyRef
- final class TemporaryQueueSourceSettings extends AmqpSourceSettings
- final class WriteMessage extends AnyRef
- final class WriteResult extends AnyRef
Value Members
- object AmqpCachedConnectionProvider
- object AmqpConnectionFactoryConnectionProvider
- object AmqpCredentials
- object AmqpDetailsConnectionProvider
- case object AmqpLocalConnectionProvider extends AmqpConnectionProvider with Product with Serializable
Connects to a local AMQP broker at the default port with no password.
- object AmqpReplyToSinkSettings
- object AmqpSSLConfiguration
- object AmqpUriConnectionProvider
- object AmqpWriteSettings
- object BindingDeclaration
- object ExchangeDeclaration
- object NamedQueueSourceSettings
- object QueueDeclaration
- object ReadResult
- object TemporaryQueueSourceSettings
- object WriteMessage
- object WriteResult