The LocalPublisherManagerImpl invokes some methods that can block, such as a get that can go remote. We need to convert these to use the non blocking API instead and change the appropriate Flowable to compensate for that.

Examples are invocations of Cache#containsKey, Cache#get, Cache#getCacheEntry.