Cleaned up barrier logic for the LockQueuePollers. Had to make sure that SetDistributedTxnMessages get processed first by the PartitionExecutor... #115