diff --git a/spring-integration-jmx/src/main/java/org/springframework/integration/monitor/SimpleMessageSourceMonitor.java b/spring-integration-jmx/src/main/java/org/springframework/integration/monitor/SimpleMessageSourceMonitor.java index c54508eda1..863b00caba 100644 --- a/spring-integration-jmx/src/main/java/org/springframework/integration/monitor/SimpleMessageSourceMonitor.java +++ b/spring-integration-jmx/src/main/java/org/springframework/integration/monitor/SimpleMessageSourceMonitor.java @@ -65,10 +65,11 @@ public class SimpleMessageSourceMonitor implements MethodInterceptor, MessageSou public Object invoke(MethodInvocation invocation) throws Throwable { String method = invocation.getMethod().getName(); - if ("receive".equals(method)) { + Object result = invocation.proceed(); + if ("receive".equals(method) && result!=null) { messageCount.incrementAndGet(); } - return invocation.proceed(); + return result; } @Override