Implemented ability to batch up which events get sent with each other
Added logging to clarify when events are buffered and when they are sent.
Simplified logic in stream based publish method. Set version to snapshot until ready for release.
Creating DefaultStreamingBus as the appropriate implementation for streaming behaviors.
Putting in implementation for streaming to a collection.
Finishing implementation for the StreamingCollectionRegistration to appropriately deliver a Collection when the last event in a sequence is received.
Starting to add support for the streaming iterable handler on the client
Tightening up api to support passing the event header state for each event received in a sequence.
Adding in example stream publisher to AMPere
Adding in streaming subscriber to verify java streaming publisher to java streaming subscriber. Will need to test out still.
Got both a streaming reader and streaming collection handler to work
Adding in Streaming implementation for Collection based handling
Adding in improvements based on feedback from John Ruiz.
Added better true streaming support to AMPere. Fixed up examples to demonstrate how to publish to chunked sequence as well as by using the stream provided from the DefaultStreamingBus
fixed bug in example
Moved field to DefaultStreamingBus from DefaultEventBus
Building implementation for DefaultEventstream DefaultEventStreamFactory, and DefaultStreamingBus
Got generics in place and project is now compiling correctly. Need to add example projects for testing out and verifying serialization and deserialization.
Merge branch 'release-amp-3.1.1' of github.com:Berico-Technologies/AMP into release-amp-3.1.1
Added streaming examples for publishing to chunked sequence and publishing to a stream. Verified messages are getting sent to Rabbit MQ Server