add early unsubscribe test
add fixed TakeLastQueueProducer