protonj2-client/src/main/java/org/apache/qpid/protonj2/client/impl/ClientSender.java [130:149]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        return this;
    }

    private void addToTailOfBlockedQueue(ClientOutgoingEnvelope send) {
        blocked.addLast(send);
        if (options.sendTimeout() > 0 && send.sendTimeout() == null) {
            send.sendTimeout(executor.schedule(() -> {
                blocked.remove(send);
                send.failed(send.createSendTimedOutException());
            }, options.sendTimeout(), TimeUnit.MILLISECONDS));
        }
    }

    private void addToHeadOfBlockedQueue(ClientOutgoingEnvelope send) {
        blocked.addFirst(send);
        if (options.sendTimeout() > 0 && send.sendTimeout() == null) {
            send.sendTimeout(executor.schedule(() -> {
                blocked.remove(send);
                send.failed(send.createSendTimedOutException());
            }, options.sendTimeout(), TimeUnit.MILLISECONDS));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



protonj2-client/src/main/java/org/apache/qpid/protonj2/client/impl/ClientStreamSender.java [130:149]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        return this;
    }

    private void addToTailOfBlockedQueue(ClientOutgoingEnvelope send) {
        blocked.addLast(send);
        if (options.sendTimeout() > 0 && send.sendTimeout() == null) {
            send.sendTimeout(executor.schedule(() -> {
                blocked.remove(send);
                send.failed(send.createSendTimedOutException());
            }, options.sendTimeout(), TimeUnit.MILLISECONDS));
        }
    }

    private void addToHeadOfBlockedQueue(ClientOutgoingEnvelope send) {
        blocked.addFirst(send);
        if (options.sendTimeout() > 0 && send.sendTimeout() == null) {
            send.sendTimeout(executor.schedule(() -> {
                blocked.remove(send);
                send.failed(send.createSendTimedOutException());
            }, options.sendTimeout(), TimeUnit.MILLISECONDS));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -