cdegroot/underground — Issue #8: Implement fetch message logic
Author: cdegroot
Created: 2011-10-24 11:56:18+00:00
State: open

Implement an incoming message that requests to fetch a certain message from a queue. Now it gets interesting :)

- Are we keeping per-subscriber queue states in the broker (AMQ-style) or in the client (Kafka style?)
- We now need an output disruptor to actually handle response sending
- Output disruptor should drop messages on the slave, only the master generates output
- Need extra data attached to messages so we know where to send responses to

Given the fact that these are enough concerns, the actual queueing will be "KISS"