public static CompletableFuture<IMessageReceiver> createMessageReceiverFromConnectionStringBuilderAsync(ConnectionStringBuilder amqpConnectionStringBuilder, ReceiveMode receiveMode) {
        Utils.assertNonNull("amqpConnectionStringBuilder", amqpConnectionStringBuilder);
        return createMessageReceiverFromEntityPathAsync(amqpConnectionStringBuilder.getEndpoint(), amqpConnectionStringBuilder.getEntityPath(), Util.getClientSettingsFromConnectionStringBuilder(amqpConnectionStringBuilder), receiveMode);
    }
public static CompletableFuture < IMessageReceiver > createMessageReceiverFromConnectionStringBuilderAsync ( ConnectionStringBuilder amqpConnectionStringBuilder , ReceiveMode receiveMode ) { Utils . assertNonNull ( "amqpConnectionStringBuilder" , amqpConnectionStringBuilder ) ; return createMessageReceiverFromEntityPathAsync ( amqpConnectionStringBuilder . getEndpoint ( ) , amqpConnectionStringBuilder . getEntityPath ( ) , Util . getClientSettingsFromConnectionStringBuilder ( amqpConnectionStringBuilder ) , receiveMode ) ; }
Create {@link IMessageReceiver} asynchronously from ConnectionStringBuilder

@param amqpConnectionStringBuilder the connection string builder
@param receiveMode                 {@link ReceiveMode} PeekLock or ReceiveAndDelete
@return a CompletableFuture representing the pending creating