lib/eventhub/processor2.rb
def publish(args = {})
      Celluloid::Actor[:actor_listener].publish(args)
    rescue => error
      EventHub.logger.error("Unexpected exeption while publish: #{error}")
      raise
    end
def publish(args = {})
      Celluloid::Actor[:actor_listener].publish(args)
    rescue => error
      EventHub.logger.error("Unexpected exeption while publish: #{error}")
      raise
    end
def publish ( args = { } ) Celluloid :: Actor [ :actor_listener ] . publish ( args ) rescue => error EventHub . logger . error ( "Unexpected exeption while publish: #{error}" ) raise end
pass message as string like: '{ "header": ... , "body": { .. }}'
 and optionally exchange_name: 'your exchange name'
pass message as string like : { header : ... body : { .. }} and optionally exchange_name : your exchange name