# File lib/nanite/cluster.rb, line 63 def publish(request, target) # We need to initialize the 'target' field of the request object so that the serializer has # access to it. begin old_target = request.target request.target = target unless target == 'mapper-offline' Nanite::Log.debug("SEND #{request.to_s([:from, :tags, :target])}") amq.queue(target).publish(serializer.dump(request, enforce_format?(target)), :persistent => request.persistent) ensure request.target = old_target end end