doraalin
doraalin
extra option to allow nsq_tail&nsq_to_file to print message timestamp, for example: -timestamp
Signed-off-by: 元守 change rpc call in async way in PutMessageToCluster & PutMessagesToCluster async in put messages to cluster
Async rpc calls introduced in put message to nsqd slave，instead of message synchronization between each slave nsqd one by one. master nsqd calls each nsqd in async way, then listen...
LookupAddressUpdate not initialized, once first lookup failed due to timeout
port back topic info from public class back to inner class in NSQMessage.
message consumer failure handler when messeage consumption throws exception.
Current ordered subscribe in java sdk is consumer baed, may consider allowing ordered consumption to be performed in topic based.