public void registerConsumer(Thread consumer, Transceptable transceptable) {
		synchronized(consumers) {
			consumers.put(consumer, transceptable);
			Fluid.log(consumer.getName() + " registered as a consumer", 2);
		}
	}