StompActors

A suite of Celluloid actors to interact with Stomp protocol, using OnStomp gem.

Installation

Add this line to your application’s Gemfile:

gem 'stomp_actors'

And then execute:

$ bundle

Or install it yourself as:

$ gem install stomp_actors

Inherit from StompActors::Consumer then define #queue and #uri values, and #receive(msg) method.

Define #subscribe_opts to customize subscription options.

Use ack(msg) to acknowledge message, if needed.

Example:

```ruby class MyConsumer < StompActors::Consumer def uri “stomp://127.0.0.1:61613” end

def queue “/queue/foo” end

def subscribe_opts { ack: ‘client’ } end

def receive(msg) # do something with msg ack(msg) end end

MyConsumer.new # your actor is now subscribed and will receive messages. ```

Inherit from StompActors::Producer then define #queue and #uri values.

Use emit(msg) to send message to the defined queue.

Example:

```ruby class MyProducer < StompActors::Producer def uri “stomp://127.0.0.1:61613” end

def queue “/queue/foo” end end

p = MyProducer.new p.emit(“stuff”) # message sent to queue ```