Create a QueueEntry class to hold items in the stream. This fixes a bug where fields named ts or op would not be indexed by the river. It also improves readability and removes the need for several class casts.