Apache Camel: журнал / постоянный обмен информацией о каждом процессоре / компоненте маршрута автоматически
При использовании Apache Camel я хочу, чтобы информация об обмене сохранялась перед каждым процессором / компонентом маршрута автоматически без использования процессора перехвата в маршруте, где в маршруте также применяются errorHandlers. Я попытался использовать interceptStrategy, но перехватчики не срабатывают, когда errorHandlers применяются в маршруте. Также я понял, что использование пользовательской InterceptStrategy не предназначено для конечных пользователей. Кто-нибудь знает альтернативу этому?
В настоящее время мы смотрим на реализацию EventNotifierSupport упоминается @RomanVottner. При реализации ниже мы заметили, что ExchangeSentEvent отправляется дубликат для некоторых процессоров / конечных точек.Почему ExchangeSentEvent отправляется несколько раз для одного и того же действия процессора?
context.getManagementStrategy().addEventNotifier(new RouteHistoryEventNotifier());
public class RouteHistoryEventNotifier extends EventNotifierSupport {
private int retryCounter = 0;
private String lastID = "";
@Override
public void notify(EventObject eventObject) throws Exception {
long startTime = System.currentTimeMillis();
log.info("notify eventname: " + eventObject.getClass().getName() );
if (eventObject instanceof ExchangeRedeliveryEvent) {
ExchangeRedeliveryEvent event = (ExchangeRedeliveryEvent) eventObject;
Exchange exchange = event.getExchange();
String id = getProcessorName(exchange);
retryCounter = event.getAttempt();
log.info("notify eventname: " + event.getClass().getName() + " - retry: " + retryCounter );
}
if (eventObject instanceof ExchangeSentEvent) {
ExchangeSentEvent event = (ExchangeSentEvent) eventObject;
Exchange exchange = event.getExchange();
String id = getProcessorName(exchange);
if(retryCounter > 0) {
id = String.format("%s (%s)", id, retryCounter );
}
// write Exhange with timeTaken and processorId to Database
myRepo.saveStep(id , exchange,startTime, event.getTimeTaken());
}
}
private String getProcessorName(Exchange exchange) {
List<MessageHistory> list = exchange.getProperty(Exchange.MESSAGE_HISTORY, List.class);
MessageHistory msgHistory = list.get(list.size() - 1);
String id = msgHistory.getNode().getId();
if (!lastID.equalsIgnoreCase(id) ) {
lastID = id;
retryCounter = 0;
}
return id;
}
@Override
public boolean isEnabled(EventObject event) {
return true;
}
}
Консольный вывод:
Line 4762: 2018-06-26 14:58:44.503 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.CamelContextStartingEvent
Line 4950: 2018-06-26 14:58:44.607 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.RouteAddedEvent
Line 4978: 2018-06-26 14:58:44.617 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.RouteAddedEvent
Line 4996: 2018-06-26 14:58:44.619 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.RouteStartedEvent
Line 5002: 2018-06-26 14:58:44.619 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.RouteStartedEvent
Line 5005: 2018-06-26 14:58:44.619 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.CamelContextStartedEvent
Line 5010: 2018-06-26 14:58:44.620 [d763f7b:1624c6] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSendingEvent
Line 5011: 2018-06-26 14:58:44.620 [d763f7b:1624c6] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeCreatedEvent
Line 5014: 2018-06-26 14:58:44.620 [d763f7b:513548] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSendingEvent
Line 5018: 2018-06-26 14:58:44.621 [d763f7b:61dde6] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSentEvent
Line 5020: 2018-06-26 14:58:44.622 [d763f7b:783f41] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSendingEvent
Line 5024: 2018-06-26 14:58:44.625 [d763f7b:61dde6] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSentEvent
Line 5026: 2018-06-26 14:58:44.626 [d763f7b:9d0511] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSendingEvent
Line 5030: 2018-06-26 14:58:44.626 [d763f7b:4be680] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSendingEvent
Line 5118: 2018-06-26 14:58:45.353 [d763f7b:acf181] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSentEvent
Line 5123: 2018-06-26 14:58:45.353 [d763f7b:61dde6] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSentEvent
Line 5126: 2018-06-26 14:58:45.354 [d763f7b:ac8552] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSendingEvent
Line 5130: 2018-06-26 14:58:45.360 [d763f7b:61dde6] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSentEvent
Line 5133: 2018-06-26 14:58:45.360 [d763f7b:1624c6] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeCompletedEvent
Line 5136: 2018-06-26 14:58:45.360 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.ExchangeSentEvent
Line 5138: 2018-06-26 14:58:45.360 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.CamelContextStoppingEvent
Line 5183: 2018-06-26 14:58:45.364 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.RouteStoppedEvent
Line 5185: 2018-06-26 14:58:45.364 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.RouteRemovedEvent
Line 5262: 2018-06-26 14:58:45.365 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.RouteStoppedEvent
Line 5286: 2018-06-26 14:58:45.366 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.RouteRemovedEvent
Line 5301: 2018-06-26 14:58:45.367 [d763f7b:d7637b] [ntExecutorGroup] INFO fiers.RouteHistoryEventNotifier - notify eventname: org.apache.camel.management.event.CamelContextStoppedEvent
Вы также можете увидеть OpenTracingEventNotifier или ZipkinEventNotifier в качестве примера