client.rb

require 'rubygems'
require 'dripdrop/node'

Thread.abort_on_exception = true

DripDrop::Node.new do
  route :exposures_sub, :zmq_subscribe, 'tcp://10.224.82.225:2200', :connect

  exposures_sub.on_recv do |message|
    line = message.body
    puts line
  end

  puts "Client started"
end.start!

server.rb

require 'rubygems'
require 'dripdrop/node'
require 'eventmachine-tail'

Thread.abort_on_exception = true

class Tailer < EventMachine::FileTail
  def initialize(zmq_queue, path, startpos = -1)
    super(path, startpos)
    @zmq_queue = zmq_queue
    @buffer = BufferedTokenizer.new
  end

  def receive_data(data)
    @buffer.extract(data).each do |line|
      @zmq_queue.send_message(:name => Time.now.to_i.to_s, :body => line)
    end
  end
end

class Watcher < EventMachine::FileGlobWatch
  def initialize(zm_queue, pathglob, interval=5)
    super(pathglob, interval)
    @zmq_queue = zm_queue
    @tailers = {}
  end

  def file_deleted(path)
    tailer = @tailers.delete(path)
    tailer.close if tailer
    puts "Removed: #{path}"
  end

  def file_found(path)
    @tailers[path] = Tailer.new(@zmq_queue, path)
    puts "Found: #{path}"
  end
end

DripDrop::Node.new do
  route :exposures_pub, :zmq_publish, 'tcp://10.224.82.225:2200', :bind

  Watcher.new(exposures_pub, "/mnt/var/log/apache2/rich-access*")

  puts "Server started"
end.start!