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

class
	CONSUMER

create
	make

feature -- Initialization

	make is
			-- Run application.
		local
			l_factory: ACTIVEMQ_CONNECTION_FACTORY
			l_connection: CONNECTION
			l_session: SESSION
			l_destination: DESTINATION
			l_reply_to_dest: DESTINATION
			l_consumer: MESSAGE_CONSUMER
			l_message: MESSAGE
			l_message_rec: TEXT_MESSAGE
			l_msg_map_rec: MAP_MESSAGE
		do
			(create {ACTIVEMQCPP}).initialize_library
			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_topic ("TEST.TOPIC")
			l_consumer := l_session.create_consumer (l_destination)

			from
			until
				False
			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:")
					l_reply_to_dest := l_message_rec.get_ems_reply_to
					print(l_reply_to_dest /= Void)
					print (" " + (create {TIME}.make_now).out)
					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:")
					l_reply_to_dest := l_msg_map_rec.get_ems_reply_to
					print (l_reply_to_dest /= Void)
					print (" " + (create {TIME}.make_now).out)
					print ("%N")
				end
				if l_reply_to_dest /= Void then
					l_reply_to_dest.close
				end
			end

				-- cleanup
			l_destination.close
			l_consumer.close
			l_session.close
			l_connection.close;

			(create {ACTIVEMQCPP}).shutdown_library
		end

end