Skip to content

Instantly share code, notes, and snippets.

@bbrowning
Forked from jcrossley3/destination_spec.rb
Created October 1, 2010 20:01
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
Save bbrowning/606769 to your computer and use it in GitHub Desktop.
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
message.should eql( "howdy" )
end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment