protected void joinAll() throws InterruptedException {
		if (queues != null) {
			for (QueueManager q : queues) {
				q.getQueueDispatcher().join();
			}
		}
	}
protected void joinAll() throws InterruptedException {
		if (queues != null) {
			for (QueueManager q : queues) {
				q.getQueueDispatcher().join();
			}
		}
	}
protected void joinAll ( ) throws InterruptedException { if ( queues != null ) { for ( QueueManager q : queues ) { q . getQueueDispatcher ( ) . join ( ) ; } } }
used only for testing
used only for testing