single thread queue listener batches
add rx merge code
check for null
adding properties for queue names and batch size