Solicitudes encadenadas Request-Reply con OAuth

return new HttpConnectorTransport.Builder<TwitterRequest>()
        .withName("TwitterHttp")
        .withActorSystem(actorSystem)
        .withConfigRootPath("chained-request-reply-example")
        .withEnricher(httpRequest -> { (1)
            HttpHeader authorization = HttpHeader.parse("Authorization", getAuthorizationHeader(httpRequest));
            HttpRequest request = httpRequest.addHeader(authorization);
            return CompletableFuture.completedFuture(request);
        })
        .build();

var connector = new RequestReplySendConnector
        .Builder<TwitterRequest, TwitterRequest, TwitterResponse, TwitterResponse>("Twitter")
        .withConnectorTransport(connectorTransport)
        .withActorSystem(actorSystem)
        .withMessageLogger(logger()) (1)
        .withSendTransportMessageConverter(request -> { (2)
            var messageHeaders = new MessageHeaders(Map.of(
                    "httpUrl", getUrl(request),
                    "httpMethod", "POST"
            ));
            if (request instanceof UploadMediaRequest) {
                byte[] bytes = ((UploadMediaRequest) request).getData();
                var entity = HttpEntities.create(ContentTypes.APPLICATION_OCTET_STREAM, bytes);
                var payload = createStrictFormDataFromParts(createFormDataBodyPartStrict("media", entity)).toEntity();
                return new TransportMessage(messageHeaders, payload);
            }
            return new TransportMessage(messageHeaders, "");
        })
        .withReceiveTransportMessageConverter(transportMessage -> { (3)
            if (transportMessage.getPayload().toString().contains("media_id_string")) {
                return fromJson(UploadMediaResponse.class).convert(transportMessage);
            } else {
                return fromJson(StatusUpdateResponse.class).convert(transportMessage);
            }
        })
        .withManualStart(false)
        .build();

connector
        .send(ProcessingContext.unknown(), new UploadMediaRequest(kittenPicBytes())) (1)
        .thenApply(twitterResponse -> (UploadMediaResponse) twitterResponse) (2)
        .thenCompose(uploadMediaResponse -> {
            String status = String.format("I am a status update at %s! Also check out this cat photo", LocalDateTime.now());
            var statusUpdateRequest = new StatusUpdateRequest(status, List.of(uploadMediaResponse.getMediaId()));
            return connector.send(ProcessingContext.unknown(), statusUpdateRequest); (3)
        })
        .toCompletableFuture()
        .join();