public void consume() {
		ConnectionFactory connectionFactory;
		Connection connection = null;
		Session session = null;
		Destination destination;
		MessageConsumer consumer = null;
		try {
			connectionFactory = new ActiveMQConnectionFactory(DEFAULT_BROKER_URL);
			connection = connectionFactory.createConnection();
			connection.start();
			session = connection.createSession(USE_TRANSACTION, Session.AUTO_ACKNOWLEDGE);
			destination = session.createQueue("TEST.QUEUE");
			consumer = session.createConsumer(destination);
			consumer.setMessageListener(this);
			long sleepTime;
			while(true) {
				sleepTime = (long)(Math.random() * 30000);
				System.out.println(name + " sleeping " + (sleepTime/1000)+1 + " seconds !");
				Thread.sleep(sleepTime);
			}
		} catch (JMSException | InterruptedException e) {
			e.printStackTrace();
		} finally {
			try {
				if(consumer != null) consumer.close();
			} catch (JMSException e) {
				e.printStackTrace();
			} finally {
				try {
					if(session != null) session.close();
				} catch (JMSException e) {
					e.printStackTrace();
				} finally {
					try {
						if(connection != null) connection.close();
					} catch (JMSException e) {
						e.printStackTrace();
					}
				}
				
			}
		}
	}