def request(type, payload = '', opts = {}, &blk)
raise "Mapper proxy not initialized" unless identity && options
request = Request.new(type, payload, nil, opts)
request.from = identity
request.token = Identity.generate
request.persistent = opts.key?(:persistent) ? opts[:persistent] : options[:persistent]
pending_requests[request.token] =
{ :intermediate_handler => opts[:intermediate_handler], :result_handler => blk }
Nanite::Log.debug("SEND #{request.to_s([:tags, :target])}")
amqp.fanout('request', :no_declare => options[:secure]).publish(serializer.dump(request))
end