Contents

require 'miu/sockets'
require 'miu/writable'
require 'miu/utility'

module Miu
  module Publisher
    class << self
      def new(*args, &block)
        options = Miu::Utility.extract_options! args
        host = args.shift || '127.0.0.1'
        port = args.shift || Miu.default_sub_port
        socket = options[:socket] || PubSocket

        klass = Class.new(socket, &block)
        klass.send :include, Writable

        klass.new.tap do |pub|
          address = Miu::Socket.build_address host, port
          pub.connect address
        end
      end

      def included(base)
        base.extend ClassMethods
      end
    end

    module ClassMethods
      def socket_type(socket = nil)
        if socket
          @socket_type = socket
        else
          @socket_type
        end
      end
    end

    attr_reader :publisher

    def initialize(host, port, tag)
      @publisher = Miu::Publisher.new host, port, :socket => self.class.socket_type
      @tag = tag
    end

    def close
      @publisher.close
    end

    def write(message)
      @publisher.write @tag, message
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
miu-0.2.3	lib/miu/publisher.rb
miu-0.2.2	lib/miu/publisher.rb