class StompActors::Producer

Public Class Methods

new() click to toggle source
# File lib/stomp_actors/producer.rb, line 10
def initialize
  async.connect
end

Public Instance Methods

emit(msg, opts = {}) click to toggle source
# File lib/stomp_actors/producer.rb, line 14
def emit(msg, opts = {})
  client.publish(queue, msg, opts)
end