def handle_intermediate_results(actor, meth, deliverable, *args)
messagekey = case args.size
when 1
'defaultkey'
when 2
args.first.to_s
else
raise ArgumentError, "handle_intermediate_results passed unexpected number of arguments (#{args.size})"
end
message = args.last
@evmclass.defer(lambda {
[deliverable.reply_to, IntermediateMessage.new(deliverable.token, deliverable.reply_to, identity, messagekey, message)]
}, lambda { |r|
amq.queue(r.first, :no_declare => options[:secure]).publish(serializer.dump(r.last))
})
end