Automorph
API
Generated with
Automorph/automorph/automorph.transport/automorph.transport.amqp/automorph.transport.amqp.server

automorph.transport.amqp.server

package automorph.transport.amqp.server

Members list

Type members

Classlikes

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.

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

Constructor

Creates a RabbitMQ server message transport plugin.

See also
Companion
object
Supertypes
trait Serializable
trait Product
trait Equals
trait ServerTransport[Effect, Context]
class Object
trait Matchable
class Any
Show all
object RabbitMqServer

Attributes

Companion
class
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
Generated with