MODIFIED broker implementation to use non-blocking concurrent linked queues instead of synchronized array lists. Also cleaned code a bit and fixed some javadoc comments.