automorph.transport.amqp.server.RabbitMqServer
See theRabbitMqServer companion object
final case class RabbitMqServer[Effect[_]](effectSystem: EffectSystem[Effect], url: URI, queues: Seq[String], addresses: Seq[Address], connectionFactory: ConnectionFactory, handler: RequestHandler[Effect, Context]) extends ServerTransport[Effect, Context]
RabbitMQ server message transport plugin.
Interprets AMQP request message body as an RPC request and processes it using the specified RPC request handler.
- The response returned by the RPC request handler is used as outgoing AMQP response body.
- AMQP request messages are consumed from the specified queues and automatically acknowledged.
- AMQP response messages are published to default exchange using ''reply-to'' request property as routing key.
Type parameters
- Effect
-
effect type
Value parameters
- addresses
-
broker hostnames and ports for reconnection attempts
- connectionFactory
-
AMQP broker connection factory
- effectSystem
-
effect system plugin
- handler
-
RPC request handler
- queues
-
names of non-durable exclusive queues to consume messages from
- url
-
AMQP broker URL (amqp[s]://[username:password@]host[:port][/virtual_host])
Attributes
Members list
In this article