This post originated from an RSS feed registered with Java Buzz
by Brian McCallister.
Original Post: JRuby Rocks
Feed Title: Waste of Time
Feed URL: http://kasparov.skife.org/blog/index.rss
Feed Description: A simple waste of time and weblog experiment
So, trying to reproduce a timing issue in ActiveMQ failover (which Hiram seems to have fixed in the recent 4.0.2 release, thank you!) I was able to whip various clients together super-quick:
#!/usr/bin/env jruby
require 'java'
module AMQFailoverTest
include_package "org.apache.activemq"
include_class "javax.jms.Session"
b = "failover://(tcp://golem:35000,tcp://golem:35001)"
factory = ActiveMQConnectionFactory.new b
connection = factory.createConnection();
session = connection.createSession(false, Session::AUTO_ACKNOWLEDGE)
producer = session.createProducer(session.createTopic("test"))
loop do
producer.send(session.createTextMessage("this is only a test"))
end
end
Previous Topic
