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

Renamed the 'processMessage' method to 'onMessageInternal' (it is the subclass implementation that is invoked from the base class 'onMessage' method).

Browse Source
This commit is contained in:
Mark Fisher
2008-09-19 02:56:47 +00:00
parent 866c9757e1
commit b1dfee7473
7 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
org.springframework.integration.event/src/main/java/org/springframework/integration/event/ApplicationEventOutboundChannelAdapter.java
View File

@@ -40,7 +40,7 @@ public class ApplicationEventOutboundChannelAdapter<T> extends AbstractMessageCo
}
@Override
protected void processMessage(Message<?> message) {
protected void onMessageInternal(Message<?> message) {
Assert.notNull(this.applicationEventPublisher, "applicationEventPublisher is required");
this.applicationEventPublisher.publishEvent(new MessagingEvent((Message<?>) message));
}

2
org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/ByteStreamOutboundChannelAdapter.java
View File

@@ -54,7 +54,7 @@ public class ByteStreamOutboundChannelAdapter extends AbstractMessageConsumingEn
@Override
public void processMessage(Message<?> message) {
public void onMessageInternal(Message<?> message) {
Object payload = message.getPayload();
if (payload == null) {
if (logger.isWarnEnabled()) {

2
org.springframework.integration.stream/src/main/java/org/springframework/integration/stream/CharacterStreamOutboundChannelAdapter.java
View File

@@ -118,7 +118,7 @@ public class CharacterStreamOutboundChannelAdapter extends AbstractMessageConsum
}
@Override
public void processMessage(Message<?> message) {
public void onMessageInternal(Message<?> message) {
Object payload = message.getPayload();
if (payload == null) {
if (logger.isWarnEnabled()) {

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

@@ -73,7 +73,7 @@ public abstract class AbstractInOutEndpoint extends AbstractMessageConsumingEndp
}
@Override
protected void processMessage(Message<?> message) {
protected void onMessageInternal(Message<?> message) {
for (EndpointInterceptor interceptor : this.interceptors) {
message = interceptor.preHandle(message);
if (message == null) {

4
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractMessageConsumingEndpoint.java
View File

@@ -139,7 +139,7 @@ public abstract class AbstractMessageConsumingEndpoint extends AbstractEndpoint
this.logger.debug("endpoint '" + this + "' processing message: " + message);
}
try {
this.processMessage(message);
this.onMessageInternal(message);
}
catch (Exception e) {
if (e instanceof MessagingException) {
@@ -152,6 +152,6 @@ public abstract class AbstractMessageConsumingEndpoint extends AbstractEndpoint
}
}
protected abstract void processMessage(Message<?> message);
protected abstract void onMessageInternal(Message<?> message);
}

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

@@ -40,7 +40,7 @@ public class OutboundChannelAdapter extends AbstractMessageConsumingEndpoint {
@Override
protected void processMessage(Message<?> message) {
protected void onMessageInternal(Message<?> message) {
if (!this.target.send(message)) {
throw new MessageDeliveryException(message, "failed to deliver Message to target");
}

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

@@ -75,7 +75,7 @@ public class RouterEndpoint extends AbstractMessageConsumingEndpoint {
}
@Override
protected void processMessage(Message<?> message) {
protected void onMessageInternal(Message<?> message) {
boolean sent = false;
Collection<MessageChannel> results = this.channelResolver.resolveChannels(message);
if (results != null) {