indexing
	description	: "System's root class"
	date: "$Date$"
	revision: "$Revision$"

class
	APPLICATION

create
	make

feature -- Initialization

	make is
			-- Run application.
		local
			l_factory: ACTIVEMQ_CONNECTION_FACTORY
			l_connection: CONNECTION
			l_session: SESSION
			l_destination: DESTINATION
			l_producer: MESSAGE_PRODUCER
			l_consumer: MESSAGE_CONSUMER
			l_message: MESSAGE
			l_message_rec: TEXT_MESSAGE
			l_msg_map, l_msg_map_rec: MAP_MESSAGE
			i: NATURAL
		do
			create l_factory.make ("tcp://127.0.0.1:61616?wireFormat=openwire")
			l_connection := l_factory.create_connection
			l_connection.start
			l_session := l_connection.create_session_auto_ack
			l_destination := l_session.create_queue ("TEST.FOO")
			l_producer := l_session.create_producer (l_destination)
			l_consumer := l_session.create_consumer (l_destination)

--			from
--				i := 0
--			until
--				i > 10
--			loop
				l_message := l_session.create_text_message ("Hallo Eiffel Welt "+i.out)
				l_message.set_ems_correlation_id ("blub")
--				l_producer.send (l_message)
				l_msg_map := l_session.create_map_message
				l_msg_map.set_string ("foo", "bar++")
				l_msg_map.set_bytes ("moo", "cow++")
				--l_msg_map.set_bytes ("moo", "cow++")
				l_msg_map.set_ems_correlation_id ("glug")
				l_msg_map.set_ems_reply_to (l_session.create_temporary_queue)
				l_producer.send (l_msg_map)
				i := i + 1
--			end

--			from
--				i := 0
--			until
--				i > 20
--			loop
				l_message := l_consumer.receive
				l_message_rec ?= l_message
				l_msg_map_rec ?= l_message
				print ("----------------------------------%N")
				if l_message_rec /= Void then
					print ("content:" + l_message_rec.get_text + "%N")
					print ("id:" + l_message_rec.get_ems_message_id + "%N")
					print ("correlation id:" + l_message_rec.get_ems_correlation_id + "%N")
					print ("reply to:")
					print(l_message_rec.get_ems_reply_to)
					print ("%N")
				else
					print ("content (foo):" + l_msg_map_rec.get_string ("foo")+ "%N")
					print ("content (moo):==" + l_msg_map_rec.get_bytes ("moo")+ "==%N")
					print ("content (moo):==" + l_msg_map_rec.get_bytes ("moo").is_equal("cow++").out + "==%N")
					print ("id:" + l_msg_map_rec.get_ems_message_id + "%N")
					print ("correlation id:" + l_msg_map_rec.get_ems_correlation_id + "%N")
					print ("reply to:")
					print (l_msg_map_rec.get_ems_reply_to /= Void)
					print ("%N")
				end
				i := i + 1
--			end


				-- cleanup
			l_session.close
			l_connection.close
			l_consumer.close
		end

end -- class APPLICATION