Как я могу получить доступ к текущему ZonedDateTime (или дате) по "маршруту" при обработке с помощью цикла "таймер"?

Фон:

Метод "configure()" в приведенном ниже примере кода зацикливается через указанный интервал времени, в который я хочу записать текущее значение "ZonedDateTime.now()".

Проблема:

Значение ZonedDateTime.now () всегда является одним и тем же значением, несмотря на разницу во времени интервала.

Вопрос:

Какой метод я могу использовать для доступа к текущему значению ZonedDateTime.now () на каждом интервале?

(ПРИМЕЧАНИЕ: в конечном итоге я хочу использовать это значение в качестве параметра в вызове REST)

Образец кода:

package aaa.bbb.ccc.dateparmissue;

import java.time.ZonedDateTime;
import java.time.format.DateTimeFormatter;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.cdi.ContextName;

@ContextName("rest-dsl")
public class DateParmIssue extends RouteBuilder {

    public DateParmIssue() {
    }

    private final String codeList = "AA,BB,CC";
    private final int notifyTime = 10;  //<==10 second interval

    @Override
    public void configure() throws Exception {

    org.apache.log4j.MDC.put("app.name", "dateParmIssue");

    System.getProperties().list(System.out);

    onException(Exception.class)
        .log("onException_processing_exception:" +  this.exceptionMessage().toString() + "...send to_error_queue:" + body(String.class).toString())
        .handled(true);

    from("timer://foo?fixedRate=true&period=" + (notifyTime * 1000))
        .setBody(constant(this.codeList))
        .to("seda:node0");

    from("seda:node0")
        .split().tokenize(",")
        .to("seda:node1");

    from("seda:node1")  
          .log("seda:node1...body-code=${body}...zdt=" + simple(ZonedDateTime.now().format(DateTimeFormatter.ISO_OFFSET_DATE_TIME)));
    }    
}

Пример вывода...

2017-12-27 12:17:11,649 | INFO  | 1 - seda://node1 | route3                           | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | direct:node1...body-code=AA...zdt=Simple: 2017-12-27T12:17:10.306-05:00
2017-12-27 12:17:11,653 | INFO  | 1 - seda://node1 | route3                           | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | direct:node1...body-code=BB...zdt=Simple: 2017-12-27T12:17:10.306-05:00
2017-12-27 12:17:11,653 | INFO  | 1 - seda://node1 | route3                           | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | direct:node1...body-code=CC...zdt=Simple: 2017-12-27T12:17:10.306-05:00
2017-12-27 12:17:21,630 | INFO  | 1 - seda://node1 | route3                           | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | direct:node1...body-code=AA...zdt=Simple: 2017-12-27T12:17:10.306-05:00
2017-12-27 12:17:21,630 | INFO  | 1 - seda://node1 | route3                           | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | direct:node1...body-code=BB...zdt=Simple: 2017-12-27T12:17:10.306-05:00
2017-12-27 12:17:21,631 | INFO  | 1 - seda://node1 | route3                           | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | direct:node1...body-code=CC...zdt=Simple: 2017-12-27T12:17:10.306-05:00
2017-12-27 12:17:31,633 | INFO  | 1 - seda://node1 | route3                           | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | direct:node1...body-code=AA...zdt=Simple: 2017-12-27T12:17:10.306-05:00
2017-12-27 12:17:31,636 | INFO  | 1 - seda://node1 | route3                           | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | direct:node1...body-code=BB...zdt=Simple: 2017-12-27T12:17:10.306-05:00
2017-12-27 12:17:31,637 | INFO  | 1 - seda://node1 | route3                           | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | direct:node1...body-code=CC...zdt=Simple: 2017-12-27T12:17:10.306-05:00
Источник

1 ответ

Решение

Оказывается, что "таймер" вставляет в заголовок свойство "firedTime", которое можно использовать (хотя в настоящее время оно является объектом java.util.Date, а не одним из более новых объектов даты Java 8 - например, ZonedDateTime),

Таким образом, альтернатива может быть следующей - то есть, которая показывает дату изменения...

from("seda:node1")
    .process(new Processor(){
        public void process(Exchange exchange) {
        exchange.getIn().setHeader("code", exchange.getIn().getBody().toString());
        exchange.getIn().setBody((new Date(exchange.getIn().getHeader("firedTime").toString()).toInstant()).atZone(ZoneId.systemDefault()).format(DateTimeFormatter.ISO_OFFSET_DATE_TIME));
        }
    })
    .log("seda:node1...body-code=${in.header.code}...zdt=${body}");

... и дата теперь меняется...

2017-12-28 15:37:18,017 | INFO  | 7 - seda://node1 | route17                          | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | seda:node1...body-code=AA...zdt=2017-12-28T15:37:18-05:00
2017-12-28 15:37:18,019 | INFO  | 7 - seda://node1 | route17                          | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | seda:node1...body-code=BB...zdt=2017-12-28T15:37:18-05:00
2017-12-28 15:37:18,020 | INFO  | 7 - seda://node1 | route17                          | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | seda:node1...body-code=CC...zdt=2017-12-28T15:37:18-05:00
2017-12-28 15:37:28,017 | INFO  | 7 - seda://node1 | route17                          | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | seda:node1...body-code=AA...zdt=2017-12-28T15:37:28-05:00
2017-12-28 15:37:28,017 | INFO  | 7 - seda://node1 | route17                          | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | seda:node1...body-code=BB...zdt=2017-12-28T15:37:28-05:00
2017-12-28 15:37:28,018 | INFO  | 7 - seda://node1 | route17                          | 232 - org.apache.camel.camel-core - 2.17.0.redhat-630187 | seda:node1...body-code=CC...zdt=2017-12-28T15:37:28-05:00
Источник
Другие вопросы по тегам