diff --git a/src/main/java/hlf/java/rest/client/metrics/EmitCustomTransactionListenerMetricsAspect.java b/src/main/java/hlf/java/rest/client/metrics/EmitCustomTransactionListenerMetricsAspect.java index e3898e9..ecf3dcd 100644 --- a/src/main/java/hlf/java/rest/client/metrics/EmitCustomTransactionListenerMetricsAspect.java +++ b/src/main/java/hlf/java/rest/client/metrics/EmitCustomTransactionListenerMetricsAspect.java @@ -38,10 +38,12 @@ public Object interceptedKafkaMetricsEmissionAdvice(ProceedingJoinPoint proceedi if (e instanceof UnrecognizedTransactionPayloadException) { invalidInboundTransactionMessageCounter.increment(); + throw e; } if (e instanceof ContractException) { inboundTxnContractExceptionCounter.increment(); + throw e; } inboundTxnProcessingFailureCounter.increment();