Open jameshnsears opened 6 years ago
take off an ingest msg in a transactional... tx.start = take off message = find smallest shard = send to smallest shard = tx.commit
if no shards reply then tx.rollback, wait a little an try n times more before shutting down
take off an ingest msg in a transactional... tx.start = take off message = find smallest shard = send to smallest shard = tx.commit
if no shards reply then tx.rollback, wait a little an try n times more before shutting down