There should be an LRU cache of some sort to save on memory usage.

[ericjperry]

Maybe throw an LRU cache in there and store older messages to disk for replay purposes? This will be non-trivial since the index for each consumer is just the index into the list of messages right now.

[ericjperry]

There is now a system in place to limit the number of messages in memory, but it's written fairly inefficiently. I will do some thinking and try to make it a bit better.