Page History

System.out.println("Start Listening Consignment Data ");
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(propLoader.getValue(PROVIDER_URL));
			connection = (QueueConnection)connectionFactory.createConnection();
			connection.start();
			
			session = connection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
			Queue queue = session.createQueue(propLoader.getValue(QUEUE_NAME));
			consumer = session.createConsumer(queue);

			while(true){
				Message message = consumer.receive();
				processMessage(message);
			}