indexing
	description	: "System's root class"
	date: "$Date: 2009-08-06 01:07:08 +0800 (星期四, 06 八月 2009) $"
	revision: "$Revision: 48 $"

class
	PRODUCER

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_message: MESSAGE
			l_message_rec: TEXT_MESSAGE
			l_msg_map, l_msg_map_rec: MAP_MESSAGE
			i: NATURAL
		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_producer := l_session.create_producer (l_destination)

			from
				i := 0
			until
				False
			loop
				l_message := l_session.create_text_message ("Hallo Eiffel Welt " + i.out + (create {TIME}.make_now).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_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

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

			(create {ACTIVEMQCPP}).shutdown_library
		end

end