Distributed Streams should also be used for Replication Cache

Currently Replication is treated as a local cache. However we should use Distributed Stream by default. A user can force it to process locally in a Replcation cache by using Flag.CACHE_MODE_LOCAL on an advanced cache.