身份验证AWS方法Rest DSL

我不能使用OAuth2/SAML断言,所以我只需要请求一个令牌并缓存它,然后再使用它。这是我的测试代码

    @Override 
    public void configure() throws Exception { 

        //Configure the Rest Web Service Component transport to use a REST implementation
        restConfiguration() //Configures the REST DSL to use a specific REST implementation
            .component("jetty")         //Specifies the Camel component to use as the REST transport
            .host("localhost")          //The hostname to use for exposing the REST service
            .port("8282")           //The port number to use for exposing the REST service JMX tooling
            .scheme("https")            //The protocol to use for exposing the REST service
            .contextPath("/oauth/token")        //Sets a leading context path for the REST services
            .bindingMode(RestBindingMode.json)  //Enables binding mode for JSON 
            .jsonDataFormat("json-jackson")     //Specifies the component that Camel uses to implement the JSON data format
            .dataFormatProperty("prettyPrint", "true"); //set arbitrary properties on the underlying data format component

        //Configure the Rest Endpoint
        rest("/oauth")      //Defines a service using the REST DSL. Each of the verb clauses are terminated by a to() keyword,
                            //which forwards the incoming message to an endpoint 
            .post("/token")
            .produces("application/json")
            .consumes("application/json")
            .type(TokenEntities.class)
            .route()
            .routeId("Get Auth Token Route")
            .autoStartup(true)
            .id("Get Auth Token Service")
            .description("Get Authorization Token")
            .process(new UAARequestTokenProcessor())
            .to("https://d1e53858-2903-4c21-86c0-95edc7a5cef2.pager-uaa.run.aws-usw02-pr.ice.pager.io/oauth/token")
            .to("log:logger?showBody=true")
            .to("direct:accessToken")
            .endRest();

        //Define the Route - from() Defines a regular Camel route.
        from("direct:accessToken").to("log:logger?showBody=true"); }

public class UAARequestTokenProcessor implements Processor {

private static final Logger LOG = LoggerFactory.getLogger(UAARequestTokenProcessor.class);

private String clientId = "myClientID";
private String userName = "myUserName";
private String password = "myPassword";

@Override
public void process(Exchange exchange) throws Exception {

        LOG.info("Processing UAA token request for " + clientId + " and " + userName);

        Message msg = exchange.getOut(); //create outbound message exchange

        StringBuilder authHeader = new StringBuilder("Basic ");       
        authHeader.append(Base64.getEncoder().encodeToString((clientId + ":").getBytes("UTF_8")));

        String body = String.format("grant_type=password&username=%s&password=%s",
                  URLEncoder.encode(userName, "UTF-8"), //Translates a string into x-www-form-urlencoded format
                  URLEncoder.encode(password, "UTF-8"));

         msg.setHeader(Exchange.CONTENT_TYPE, "MediaType.APPLICATION_FORM_URLENCODE");
         msg.setHeader("Authorization", authHeader.toString());
         msg.setBody(body);
    }

}