gistfile1.txt

from("timer://actionrequests?period=1&delay=" + period)
    // HTTP GET
    .to(value + "actionrequests/" + queueName + "/pop?httpClient.soTimeout=5000")
    // If empty, wait
    .choice()
    .when(header(Exchange.HTTP_RESPONSE_CODE).isEqualTo(204))
    .log(LoggingLevel.TRACE, "actionrequests route idle")
    .delay(period)
    .endChoice()
    // Else process
    .otherwise()
    .log(LoggingLevel.TRACE, LOG, "receiving incomming action request ${body}")
    .unmarshal(gsonActionRequestFormat)
    .log(LoggingLevel.INFO, LOG, "receiving incomming action request [${body.actionid}]")
    .process(actionRequestProcessor)
    // Finnaly, Delete action
    .log(LoggingLevel.INFO, LOG, "sending action request delete [${body.actionid}]")
    .setHeader(Exchange.HTTP_METHOD, constant("DELETE"))
    .setHeader(Exchange.HTTP_PATH, simple("actionrequests/" + queueName + "/${body.actionid}"))
    .setBody(constant(null))
    .to(value);