class CrystalMQ::Producer
Public Class Methods
new(host, topic)
click to toggle source
# File lib/crystalmq.rb, line 94 def initialize(host, topic) @host = host @topic = topic connect_socket rescue SocketError connect_socket retry end
Public Instance Methods
connect_socket()
click to toggle source
# File lib/crystalmq.rb, line 103 def connect_socket @socket = TCPSocket.new(@host, 1234) @socket.sync = true rescue SocketError retry end
terminate()
click to toggle source
# File lib/crystalmq.rb, line 117 def terminate @socket.close end
write(message)
click to toggle source
# File lib/crystalmq.rb, line 110 def write(message) @socket.write(ProducerPayload.new(@topic, message).to_msgpack) rescue SocketError connect_socket retry end