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