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