public ListenerThread(ActiveMQConnectionFactory factory,
			ConcurrentMap<String, MessageAdaptor> messageResponse, String topic) {
		this.factory = factory;
		this.messageResponse = messageResponse;
		this.topic = topic;
	}