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
      message.should eql( "howdy" )
    end