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

Removed MessageHandlerRejectedExecutionException as it is no longer used, and moved MessageListMethodAdapter to the 'aggregator' package since that is the only place it is used (and it may be refactored away).

Browse Source
This commit is contained in:
Mark Fisher
2008-09-22 22:28:18 +00:00
parent 8a103b7ec5
commit f07c7fc2fd
5 changed files with 1 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/CompletionStrategyAdapter.java
View File

@@ -20,7 +20,6 @@ import java.lang.reflect.Method;
import java.util.List;
import org.springframework.integration.ConfigurationException;
import org.springframework.integration.handler.MessageListMethodAdapter;
import org.springframework.integration.message.Message;
/**

2
org.springframework.integration/src/main/java/org/springframework/integration/handler/MessageListMethodAdapter.java → org.springframework.integration/src/main/java/org/springframework/integration/aggregator/MessageListMethodAdapter.java
View File

@@ -14,7 +14,7 @@
* limitations under the License.
*/
package org.springframework.integration.handler;
package org.springframework.integration.aggregator;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;

1
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/MethodInvokingAggregator.java
View File

@@ -19,7 +19,6 @@ package org.springframework.integration.aggregator;
import java.lang.reflect.Method;
import java.util.List;
import org.springframework.integration.handler.MessageListMethodAdapter;
import org.springframework.integration.message.GenericMessage;
import org.springframework.integration.message.Message;
import org.springframework.util.CollectionUtils;

39
org.springframework.integration/src/main/java/org/springframework/integration/handler/MessageHandlerRejectedExecutionException.java
View File

@@ -1,39 +0,0 @@
/*
* Copyright 2002-2008 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.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.integration.handler;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MessageHandlingException;
/**
* An exception indicating that a message was rejected by a handler; typically
* this would be the result of a thread pool executor rejecting a handler task.
*
* @author Mark Fisher
*/
@SuppressWarnings("serial")
public class MessageHandlerRejectedExecutionException extends MessageHandlingException {
public MessageHandlerRejectedExecutionException(Message<?> message) {
super(message);
}
public MessageHandlerRejectedExecutionException(Message<?> message, Throwable cause) {
super(message, "handler rejected execution", cause);
}
}

24
org.springframework.integration/src/test/java/org/springframework/integration/handler/TestHandlers.java
View File

@@ -51,30 +51,6 @@ public abstract class TestHandlers {
};
}
/**
* Create a handler that throws a {@link MessageHandlerRejectedExecutionException}.
*/
public final static Object rejectingHandler() {
return new Object() {
public Message<?> handle(Message<?> message) {
throw new MessageHandlerRejectedExecutionException(message);
}
};
}
/**
* Create a handler that counts down on the provided latch and
* then throws a {@link MessageHandlerRejectedExecutionException}.
*/
public final static Object rejectingCountDownHandler(final CountDownLatch latch) {
return new Object() {
public Message<?> handle(Message<?> message) {
latch.countDown();
throw new MessageHandlerRejectedExecutionException(message);
}
};
}
/**
* Create a handler that increments the provided counter.
*/