Remove remaining redundant superinterfaces
This commit is contained in:
@@ -23,7 +23,6 @@ import org.springframework.amqp.rabbit.connection.Connection;
|
||||
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
|
||||
import org.springframework.amqp.rabbit.connection.ConnectionListener;
|
||||
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
||||
import org.springframework.beans.factory.DisposableBean;
|
||||
import org.springframework.integration.amqp.support.AmqpHeaderMapper;
|
||||
import org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper;
|
||||
import org.springframework.integration.amqp.support.MappingUtils;
|
||||
@@ -38,8 +37,7 @@ import org.springframework.util.Assert;
|
||||
*
|
||||
* @since 2.1
|
||||
*/
|
||||
public abstract class AbstractAmqpChannel extends AbstractMessageChannel
|
||||
implements DisposableBean, ConnectionListener {
|
||||
public abstract class AbstractAmqpChannel extends AbstractMessageChannel implements ConnectionListener {
|
||||
|
||||
private final AmqpTemplate amqpTemplate;
|
||||
|
||||
|
||||
@@ -440,7 +440,7 @@ public class FileSplitter extends AbstractMessageSplitter {
|
||||
|
||||
private static final long serialVersionUID = 8514605438145748406L;
|
||||
|
||||
public enum Mark implements Serializable {
|
||||
public enum Mark {
|
||||
START,
|
||||
END
|
||||
}
|
||||
|
||||
@@ -55,8 +55,7 @@ public class BeanPropertySqlParameterSourceFactory implements SqlParameterSource
|
||||
return new StaticBeanPropertySqlParameterSource(input, this.staticParameters);
|
||||
}
|
||||
|
||||
private static final class StaticBeanPropertySqlParameterSource extends AbstractSqlParameterSource implements
|
||||
SqlParameterSource {
|
||||
private static final class StaticBeanPropertySqlParameterSource extends AbstractSqlParameterSource {
|
||||
|
||||
private final BeanPropertySqlParameterSource input;
|
||||
|
||||
|
||||
@@ -22,7 +22,6 @@ import java.util.List;
|
||||
import javax.sql.DataSource;
|
||||
|
||||
import org.springframework.beans.factory.BeanFactory;
|
||||
import org.springframework.beans.factory.InitializingBean;
|
||||
import org.springframework.integration.handler.AbstractReplyProducingMessageHandler;
|
||||
import org.springframework.jdbc.core.JdbcOperations;
|
||||
import org.springframework.jdbc.core.JdbcTemplate;
|
||||
@@ -36,10 +35,11 @@ import org.springframework.util.StringUtils;
|
||||
* @author Dave Syer
|
||||
* @author Gunnar Hillert
|
||||
* @author Artem Bilan
|
||||
* @author Gary Russell
|
||||
*
|
||||
* @since 2.0
|
||||
*/
|
||||
public class JdbcOutboundGateway extends AbstractReplyProducingMessageHandler implements InitializingBean {
|
||||
public class JdbcOutboundGateway extends AbstractReplyProducingMessageHandler {
|
||||
|
||||
private final JdbcMessageHandler handler;
|
||||
|
||||
|
||||
@@ -18,7 +18,6 @@ package org.springframework.integration.jdbc;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
import org.springframework.beans.factory.InitializingBean;
|
||||
import org.springframework.integration.handler.AbstractMessageHandler;
|
||||
import org.springframework.messaging.Message;
|
||||
import org.springframework.util.Assert;
|
||||
@@ -45,9 +44,10 @@ import org.springframework.util.Assert;
|
||||
* feature request at https://jira.springsource.org.
|
||||
*
|
||||
* @author Gunnar Hillert
|
||||
* @author Gary Russell
|
||||
* @since 2.1
|
||||
*/
|
||||
public class StoredProcMessageHandler extends AbstractMessageHandler implements InitializingBean {
|
||||
public class StoredProcMessageHandler extends AbstractMessageHandler {
|
||||
|
||||
private final StoredProcExecutor executor;
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@
|
||||
package org.springframework.integration.jms;
|
||||
|
||||
import org.springframework.beans.BeansException;
|
||||
import org.springframework.beans.factory.DisposableBean;
|
||||
import org.springframework.context.ApplicationContext;
|
||||
import org.springframework.integration.context.OrderlyShutdownCapable;
|
||||
import org.springframework.integration.gateway.MessagingGatewaySupport;
|
||||
@@ -33,7 +32,7 @@ import org.springframework.messaging.MessageChannel;
|
||||
*
|
||||
* @since 5.0
|
||||
*/
|
||||
public class JmsInboundGateway extends MessagingGatewaySupport implements DisposableBean, OrderlyShutdownCapable {
|
||||
public class JmsInboundGateway extends MessagingGatewaySupport implements OrderlyShutdownCapable {
|
||||
|
||||
private final JmsMessageDrivenEndpoint endpoint;
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@
|
||||
package org.springframework.integration.jms;
|
||||
|
||||
import org.springframework.beans.BeansException;
|
||||
import org.springframework.beans.factory.DisposableBean;
|
||||
import org.springframework.context.ApplicationContext;
|
||||
import org.springframework.integration.context.OrderlyShutdownCapable;
|
||||
import org.springframework.integration.endpoint.MessageProducerSupport;
|
||||
@@ -36,8 +35,7 @@ import org.springframework.util.Assert;
|
||||
* @author Gary Russell
|
||||
* @author Artem Bilan
|
||||
*/
|
||||
public class JmsMessageDrivenEndpoint extends MessageProducerSupport
|
||||
implements DisposableBean, OrderlyShutdownCapable {
|
||||
public class JmsMessageDrivenEndpoint extends MessageProducerSupport implements OrderlyShutdownCapable {
|
||||
|
||||
private final AbstractMessageListenerContainer listenerContainer;
|
||||
|
||||
|
||||
@@ -21,7 +21,6 @@ import javax.jms.MessageListener;
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
|
||||
import org.springframework.beans.factory.DisposableBean;
|
||||
import org.springframework.context.SmartLifecycle;
|
||||
import org.springframework.integration.MessageDispatchingException;
|
||||
import org.springframework.integration.context.IntegrationProperties;
|
||||
@@ -49,7 +48,7 @@ import org.springframework.util.Assert;
|
||||
* @since 2.0
|
||||
*/
|
||||
public class SubscribableJmsChannel extends AbstractJmsChannel
|
||||
implements SubscribableChannel, SmartLifecycle, DisposableBean {
|
||||
implements SubscribableChannel, SmartLifecycle {
|
||||
|
||||
private final AbstractMessageListenerContainer container;
|
||||
|
||||
|
||||
@@ -23,9 +23,7 @@ import javax.management.Notification;
|
||||
import javax.management.ObjectName;
|
||||
|
||||
import org.springframework.beans.factory.BeanFactory;
|
||||
import org.springframework.beans.factory.BeanFactoryAware;
|
||||
import org.springframework.beans.factory.BeanFactoryUtils;
|
||||
import org.springframework.beans.factory.InitializingBean;
|
||||
import org.springframework.beans.factory.ListableBeanFactory;
|
||||
import org.springframework.integration.handler.AbstractMessageHandler;
|
||||
import org.springframework.integration.mapping.OutboundMessageMapper;
|
||||
@@ -52,8 +50,7 @@ import org.springframework.util.Assert;
|
||||
*
|
||||
* @since 2.0
|
||||
*/
|
||||
public class NotificationPublishingMessageHandler extends AbstractMessageHandler
|
||||
implements BeanFactoryAware, InitializingBean {
|
||||
public class NotificationPublishingMessageHandler extends AbstractMessageHandler {
|
||||
|
||||
private final PublisherDelegate delegate = new PublisherDelegate();
|
||||
|
||||
|
||||
@@ -32,7 +32,6 @@ import javax.management.MBeanServerConnection;
|
||||
import javax.management.MalformedObjectNameException;
|
||||
import javax.management.ObjectName;
|
||||
|
||||
import org.springframework.beans.factory.InitializingBean;
|
||||
import org.springframework.integration.handler.AbstractReplyProducingMessageHandler;
|
||||
import org.springframework.integration.util.ClassUtils;
|
||||
import org.springframework.jmx.support.ObjectNameManager;
|
||||
@@ -64,7 +63,7 @@ import org.springframework.util.ObjectUtils;
|
||||
*
|
||||
* @since 2.0
|
||||
*/
|
||||
public class OperationInvokingMessageHandler extends AbstractReplyProducingMessageHandler implements InitializingBean {
|
||||
public class OperationInvokingMessageHandler extends AbstractReplyProducingMessageHandler {
|
||||
|
||||
private final MBeanServerConnection server;
|
||||
|
||||
|
||||
@@ -20,7 +20,6 @@ import java.util.concurrent.Executor;
|
||||
|
||||
import org.springframework.beans.factory.BeanFactory;
|
||||
import org.springframework.beans.factory.BeanFactoryAware;
|
||||
import org.springframework.beans.factory.DisposableBean;
|
||||
import org.springframework.context.SmartLifecycle;
|
||||
import org.springframework.core.task.SimpleAsyncTaskExecutor;
|
||||
import org.springframework.data.redis.connection.RedisConnectionFactory;
|
||||
@@ -56,7 +55,7 @@ import org.springframework.util.StringUtils;
|
||||
*/
|
||||
@SuppressWarnings("rawtypes")
|
||||
public class SubscribableRedisChannel extends AbstractMessageChannel
|
||||
implements SubscribableChannel, SmartLifecycle, DisposableBean {
|
||||
implements SubscribableChannel, SmartLifecycle {
|
||||
|
||||
private final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
|
||||
|
||||
|
||||
Reference in New Issue
Block a user