Replace use of deprecated DirectProcessor

[edwin-greene]

Problem

SharedTopicListener uses reactor.core.publisher.DirectProcessor which is deprecated.

Solution

Update SharedTopicListener to use Project Reactor Sinks. Make sure that the Sink implementation is as performant as the DirectProcesser.

Alternatives

No response