module SyncClient::Publisher::PoroPublisher::ClassMethods

Attributes

queue_publisher[R]

Public Instance Methods

publish_to(*args) click to toggle source
# File lib/sync_client/publisher/poro_publisher.rb, line 7
def publish_to(*args)
  @queue_publisher ||= SyncClient::QueuePublisher.new
  options = args.last.is_a?(Hash) ? args.pop : {:for => :sync}
  args.each do |end_point|
    @queue_publisher.add_publisher([], options.merge(:to => end_point))
  end
end