File tree Expand file tree Collapse file tree 1 file changed +15
-1
lines changed
Expand file tree Collapse file tree 1 file changed +15
-1
lines changed Original file line number Diff line number Diff line change @@ -644,7 +644,7 @@ TransactionOutbox outbox = TransactionOutbox.builder()
644644 // Sets how long we should keep records of requests with a unique request id so duplicate requests
645645 // can be rejected. Defaults to 7 days.
646646 .retentionThreshold(Duration . ofDays(1 ))
647- // We can intercept task successes, single failures and blocked tasks . The most common use is to catch blocked tasks
647+ // We can intercept and modify numerous events . The most common use is to catch blocked tasks
648648 // and raise alerts for these to be investigated. A Slack interactive message is particularly effective here
649649 // since it can be wired up to call unblock() automatically.
650650 .listener(new TransactionOutboxListener () {
@@ -659,6 +659,20 @@ TransactionOutbox outbox = TransactionOutbox.builder()
659659 eventPublisher. publish(new BlockedOutboxTaskEvent (entry. getId()));
660660 }
661661
662+ @Override
663+ public Map<String , String > extractSession () {
664+ return Map . of();
665+ }
666+
667+ @Override
668+ public void wrapInvocationAndInit (Invocator invocator ) {
669+ invocator. runUnchecked();
670+ }
671+
672+ @Override
673+ public void wrapInvocation (Invocator invocator ) throws Exception {
674+ invocator. run();
675+ }
662676 })
663677 .build();
664678
You can’t perform that action at this time.
0 commit comments