lib/dripdrop/agent.rb in dripdrop-0.0.2 vs lib/dripdrop/agent.rb in dripdrop-0.0.3
- old
+ new
@@ -1,19 +1,23 @@
require 'dripdrop/message'
require 'zmq'
require 'bert'
class DripDrop
+ #The Agent class is a simple ZMQ Pub client. It uses DripDrop::Message messages
class Agent
attr_reader :address, :context, :socket
+
+ #address should be a string like tcp://127.0.0.1
def initialize(address)
@address = address
@context = ZMQ::Context.new(1)
@socket = @context.socket(ZMQ::PUB)
@socket.connect(@address)
end
- def send_message(name,content)
- puts @socket.send(Message.new(name,content).encoded, 0)
+ #Sends a DripDrop::Message to the socket
+ def send_message(name,body,head={})
+ puts @socket.send(DripDrop::Message.new(name,:body => body, :head => head).encoded, 0)
end
end
end