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
pass message as string like: '{ "header": ... , "body": { .. }}'
 and optionally exchange_name: 'your exchange name'