Open elandau opened 11 years ago
Current suro-server Sink interface should be refactored to be reused in schlep producer. Please define schlep producer interface here and I will do refactoring and you can implement proper Sink interface for producing messages to SQS and CassQueue, Kafka and Suro are mine.
Generic API for sending messages to SQS, Kafka, Suro, CassQueue, etc..