add Endpoint to Streaming interface
add ReplayAndObserveStreaming, Add ProcessingEventstrcuture