RabbitMqClient

automorph.transport.amqp.client.RabbitMqClient

See theRabbitMqClient companion object

RabbitMQ client message transport plugin.

Uses the supplied RPC request as AMQP request message body and returns AMQP response message body as a result.

AMQP request messages are published to the specified exchange using direct reply-tomechanism.
AMQP response messages are consumed using direct reply-tomechanism and automatically acknowledged.

Type parameters

addresses: broker hostnames and ports for reconnection attempts
connectionFactory: AMQP broker connection factory
effectSystem: effect system plugin
exchange: direct non-durable AMQP message exchange name
routingKey: AMQP routing key (typically a queue name)
url: AMQP broker URL (amqp[s]://[username:password@]host[:port][/virtual_host])

Constructor: Creates a RabbitMQ client message transport plugin.
See also: Documentation

API
Companion: object
Graph
Supertypes: trait Serializable

trait Product

trait Equals

trait ClientTransport[Effect, Context]

class Object

trait Matchable

class Any
Show all

Sends a request to a remote endpoint and retrieves the response.

An optional request context is used to supply additional information needed to send the request.

Closes this client transport freeing the underlying resources.

Creates default request context based on the configuration of this client transport.

Returns: request context based on the configuration of this client transport
Definition Classes: ClientTransport

Initializes this client to invoke remote APIs.

Sends a request to a remote endpoint without waiting for a response.

An optional request context is used to supply additional information needed to send the request.

In this article

Generated with