public void producerError(Exception e) {
		Object[] threads;
		synchronized(consumers) {
			threads = new ArrayList(consumers.keySet()).toArray();
		}
		Transceptable transceptable;
		for(int i = 0; i < threads.length; i++) {
			transceptable = (Transceptable)consumers.get(threads[i]);
			if(transceptable != null) 
				transceptable.intercept(e);
		}
	}