Fixed an issue where the hash retrieved when fetching messages from the service node might not be the latest one Updated the MessageReceiveJob to batch process messages (on failure only the failed messages will retry)