Ben Browning bbrowning

bbrowning / node_handler.rb

Created February 25, 2011 13:48 — forked from goldmann/gist:843793

	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

bbrowning / destination_spec.rb

Created October 1, 2010 20:01 — forked from jcrossley3/destination_spec.rb

	it "should be able to publish to and receive from a topic" do
	topic = TorqueBox::Messaging::Topic.new "/topics/foo"
	topic.start

	latch = java.util.concurrent.CountDownLatch.new(1)
	t1 = Thread.new { topic.publish "howdy"; latch.countDown }
	latch.await
	message = topic.receive

	topic.destroy