Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AbstractMessageConsumingEndpoint is now AbstractMessageConsumer.

Browse Source
This commit is contained in:
Mark Fisher
2008-10-06 18:23:00 +00:00
parent 27e288be08
commit 7d8dc775e4
7 changed files with 14 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
org.springframework.integration/src/main/java/org/springframework/integration/config/annotation/AbstractMethodAnnotationPostProcessor.java
View File

@@ -28,7 +28,7 @@ import org.springframework.integration.channel.ChannelRegistryAware;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.PollableChannel;
import org.springframework.integration.channel.SubscribableChannel;
import org.springframework.integration.endpoint.AbstractMessageConsumingEndpoint;
import org.springframework.integration.endpoint.AbstractMessageConsumer;
import org.springframework.integration.endpoint.AbstractMessageHandlingEndpoint;
import org.springframework.integration.endpoint.MessageEndpoint;
import org.springframework.integration.endpoint.PollingConsumerEndpoint;
@@ -95,7 +95,7 @@ public abstract class AbstractMethodAnnotationPostProcessor<T extends Annotation
if (StringUtils.hasText(inputChannelName)) {
MessageChannel inputChannel = this.messageBus.lookupChannel(inputChannelName);
Assert.notNull(inputChannel, "unable to resolve inputChannel '" + inputChannelName + "'");
if (consumer instanceof AbstractMessageConsumingEndpoint) {
if (consumer instanceof AbstractMessageConsumer) {
if (inputChannel instanceof PollableChannel) {
PollingConsumerEndpoint pollingEndpoint = new PollingConsumerEndpoint(
consumer, (PollableChannel) inputChannel);

7
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractMessageConsumingEndpoint.java → org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractMessageConsumer.java
View File

@@ -27,11 +27,14 @@ import org.springframework.integration.util.ErrorHandler;
import org.springframework.util.Assert;
/**
* Base class for MessageConsumer implementations.
* Base class for MessageConsumer implementations that provides basic
* validation and error handling capabilities. Asserts that the incoming
* Message is not null and that it does not contain a null payload. For custom
* error handling, provide a reference to an {@link ErrorHandler}.
*
* @author Mark Fisher
*/
public abstract class AbstractMessageConsumingEndpoint implements MessageConsumer {
public abstract class AbstractMessageConsumer implements MessageConsumer {
protected final Log logger = LogFactory.getLog(this.getClass());

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractMessageHandlingEndpoint.java
View File

@@ -36,7 +36,7 @@ import org.springframework.util.Assert;
/**
* @author Mark Fisher
*/
public abstract class AbstractMessageHandlingEndpoint extends AbstractMessageConsumingEndpoint implements ChannelRegistryAware {
public abstract class AbstractMessageHandlingEndpoint extends AbstractMessageConsumer implements ChannelRegistryAware {
private MessageChannel outputChannel;

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/MessagingBridge.java
View File

@@ -23,7 +23,7 @@ import org.springframework.util.Assert;
/**
* @author Mark Fisher
*/
public class MessagingBridge extends AbstractMessageConsumingEndpoint {
public class MessagingBridge extends AbstractMessageConsumer {
private final MessageConsumer consumer;

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/OutboundChannelAdapter.java
View File

@@ -27,7 +27,7 @@ import org.springframework.util.Assert;
*
* @author Mark Fisher
*/
public class OutboundChannelAdapter extends AbstractMessageConsumingEndpoint {
public class OutboundChannelAdapter extends AbstractMessageConsumer {
private final MessageConsumer consumer;

4
org.springframework.integration/src/main/java/org/springframework/integration/router/RouterEndpoint.java
View File

@@ -22,7 +22,7 @@ import org.springframework.integration.channel.ChannelRegistry;
import org.springframework.integration.channel.ChannelRegistryAware;
import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.MessageChannelTemplate;
import org.springframework.integration.endpoint.AbstractMessageConsumingEndpoint;
import org.springframework.integration.endpoint.AbstractMessageConsumer;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MessageDeliveryException;
import org.springframework.util.Assert;
@@ -30,7 +30,7 @@ import org.springframework.util.Assert;
/**
* @author Mark Fisher
*/
public class RouterEndpoint extends AbstractMessageConsumingEndpoint implements ChannelRegistryAware {
public class RouterEndpoint extends AbstractMessageConsumer implements ChannelRegistryAware {
private final ChannelResolver channelResolver;