package amqp
Ordering
- Alphabetic
Visibility
- Public
- All
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
- final class AmqpSinkSettings extends AmqpConnectorSettings
- sealed trait AmqpSourceSettings extends AmqpConnectorSettings
- final class AmqpUriConnectionProvider extends AmqpConnectionProvider
- final class BindingDeclaration extends Declaration
- sealed trait Declaration extends AnyRef
- final class ExchangeDeclaration extends Declaration
- final class IncomingMessage extends AnyRef
- final class NamedQueueSourceSettings extends AmqpSourceSettings
- final class OutgoingMessage extends AnyRef
- final class QueueDeclaration extends Declaration
- final class TemporaryQueueSourceSettings extends AmqpSourceSettings
Value Members
- object AmqpCachedConnectionProvider
- object AmqpConnectionFactoryConnectionProvider
- object AmqpCredentials
- object AmqpDetailsConnectionProvider
-
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
Java API
- object AmqpSinkSettings
- object AmqpUriConnectionProvider
- object BindingDeclaration
- object ExchangeDeclaration
- object IncomingMessage
- object NamedQueueSourceSettings
- object OutgoingMessage
- object QueueDeclaration
- object TemporaryQueueSourceSettings