al333z / bunny   0.0.3

Apache License 2.0 GitHub

An opinionated wrapper for the RabbitMQ Java client, in Scala.

Scala versions: 2.12 2.11

bunny Build Status

Rationale

This tiny lib has only one purpose: simplify the life of the developer when creating a RabbitMQ Channel. The assumptions are:

  • a consumer owns a queue, so it'll need to create a queue and the corresponding binding(s) from one or multiple exchange(s)
  • a producer owns an exchange, so it'll need to create an exchange

This library will give you a few methods to do this, whitout any further boilerplate.

Samples

val rabbitConfig = RabbitConfig(
    host = "localhost",
    vhost = "/",
    username = "guest",
    password = "guest"
)

val consumingChannel = BunnyChannelFactory(rabbitConfig)
      .forConsumer(
        queueName = "q",
        exchangeName = "e",
        routingKey = "k"
)

val producingChannel = BunnyChannelFactory(rabbitConfig)
      .forProducer(
        exchangeName = "e",
        exchangeType = "topic"
)

// your code that use the channels..

For more, take a look at the tests.

Docs

The methods that BunnyChannelFactory offers are:

  • forConsumer(queueName: String, exchangeName: String, routingKey: String, args: Map[String, AnyRef] = Map()): Try[Channel], which will create a queue and the binding to the exchanges provided.
  • def forConsumer(queueName: String, bindings: Binding*): Try[Channel], which is like the previous, but with only one exchange.
  • def forProducer(exchangeName: String, exchangeType: String): Try[ConfirmedChannelContainer], which will create a new exchange in which a producer can push messages. The channel which is returned supports publisher confirms.
  • def forProducerUnconfirmed(exchangeName: String, exchangeType: String): Try[UnconfirmedChannelContainer], like the previous without the publisher confirms turned on.
  • other additional two methods forProducerWithQueueBound and forProducerUnconfirmedWithQueueBound, which are like the previous but will also create a binding to a queue. One use case for these two are for supporting error queues.

Installation

libraryDependencies += "com.al333z" %% "bunny" % "0.0.4"