Streams are closed on error
Return value of queue offer is checked
Throws JobException when device can not be found
Queue accepted boolean checked
package protect connection count
Remove unused method and message comparison
Removed sync block from concurrent queue
Added stream closes
Removed syncs on blocking queue
Fixed incorrect equals
Removed sync block on queue and protected count