# File lib/nanite/mapper_proxy.rb, line 44 def push(type, payload = '', opts = {}) raise "Mapper proxy not initialized" unless identity && options push = Push.new(type, payload, nil, opts) push.from = identity push.token = Identity.generate push.persistent = opts.key?(:persistent) ? opts[:persistent] : options[:persistent] Nanite::Log.debug("SEND #{push.to_s([:tags, :target])}") amqp.fanout('request', :no_declare => options[:secure]).publish(serializer.dump(push)) end