code: public static CompletableFuture<MessageReceiver> create(
              final MessagingFactory factory,
              final String name,
              final String recvPath,
              final int prefetchCount,
              final ReceiverSettingsProvider settingsProvider) {
          MessageReceiver msgReceiver = new MessageReceiver(
                  factory,
                  name,
                  recvPath,
                  prefetchCount,
                  settingsProvider);
          return msgReceiver.createLink();
      }
docs: Connection has to be associated with Reactor before Creating a receiver on it.