node_handler.rb

class NodeHandler
  def process!(message)
    payload = message.decode[:message]
    puts payload.to_yaml
    queue = TorqueBox::Messaging::Queue.new("/queues/node")
    queue.publish('OK', :correlation_id => message.jmsmessage_id)
  end
end

torquebox.yml

messaging:
  /queues/node:
    NodeHandler:
      filter: "synchronous = 'true'"