From ece8d6c806ec49a93d4a8ab50ff52056e39f318a Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Mon, 25 Jan 2010 23:08:34 +0000 Subject: [PATCH] added a warn-level log message in case a MessageListener was already configured on the listener container being used within the message-driven endpoint --- .../integration/jms/JmsMessageDrivenEndpoint.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/JmsMessageDrivenEndpoint.java b/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/JmsMessageDrivenEndpoint.java index 2e583dfc3a..bacb44dbc3 100644 --- a/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/JmsMessageDrivenEndpoint.java +++ b/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/JmsMessageDrivenEndpoint.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2009 the original author or authors. + * Copyright 2002-2010 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -37,6 +37,10 @@ public class JmsMessageDrivenEndpoint extends AbstractEndpoint implements Dispos public JmsMessageDrivenEndpoint(AbstractMessageListenerContainer listenerContainer, ChannelPublishingJmsMessageListener listener) { Assert.notNull(listenerContainer, "listener container must not be null"); Assert.notNull(listener, "listener must not be null"); + if (logger.isWarnEnabled() && listenerContainer.getMessageListener() != null) { + logger.warn("The provided listener container already has a MessageListener implementation, " + + "but it will be overridden by the provided ChannelPublishingJmsMessageListener."); + } listenerContainer.setMessageListener(listener); this.listener = listener; this.listenerContainer = listenerContainer;