public PublisherThread(ActiveMQConnectionFactory factory,
			Vector<MessageAdaptor> messageSource, String topic) {
		this.factory = factory;
		this.messageSource = messageSource;
		this.topic = topic;
	}