modified ClusterDeliveryEndPoint.java (with concurrency map/queue)

Signed-off-by: huangruiqing <ruoyiqing1990@163.com>