# setup JRuby & require the hazlecast Jar
require 'java'
require 'hazelcast-1.8.5.jar'

# bring the Hazelcast package into the current namespace
java_import com.hazelcast.core.Hazelcast
java_import com.hazelcast.core.MessageListener

class ChatPrinter
  include MessageListener
  def onMessage(msg)
    puts msg
  end
end

topic = Hazelcast.getTopic("chat_room_or_whatever")
topic.addMessageListener(ChatPrinter.new)
topic.publish("== #{Process.pid} has joined ==")

while true
  msg = gets.chomp
  msg == 'q' ? break : topic.publish("#{Process.pid}: #{msg}")
end