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

INT-851 Added method name to the "name" property of the MessageHistory.Event for a gateway.

Browse Source
This commit is contained in:
Mark Fisher
2009-12-24 02:37:54 +00:00
parent 65102cc725
commit afb53e166d
3 changed files with 38 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
org.springframework.integration/src/test/java/org/springframework/integration/gateway/GatewayProxyFactoryBeanTests.java
View File

@@ -20,6 +20,7 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import java.lang.reflect.Method;
import java.util.Iterator;
import java.util.Random;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Executor;
@@ -34,7 +35,10 @@ import org.springframework.integration.channel.PollableChannel;
import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.core.Message;
import org.springframework.integration.core.MessageChannel;
import org.springframework.integration.core.MessageHistory.ComponentType;
import org.springframework.integration.core.MessageHistory.Event;
import org.springframework.integration.endpoint.EventDrivenConsumer;
import org.springframework.integration.handler.BridgeHandler;
import org.springframework.integration.message.MessageHandler;
import org.springframework.integration.message.StringMessage;
import org.springframework.util.ReflectionUtils;
@@ -249,12 +253,39 @@ public class GatewayProxyFactoryBeanTests {
}).start();
}
@Test
public void testMethodNameInHistory() throws Exception {
GatewayProxyFactoryBean proxyFactory = new GatewayProxyFactoryBean();
DirectChannel channel = new DirectChannel();
channel.setBeanName("testChannel");
EventDrivenConsumer consumer = new EventDrivenConsumer(channel, new BridgeHandler());
consumer.start();
proxyFactory.setDefaultRequestChannel(channel);
proxyFactory.setServiceInterface(TestEchoService.class);
proxyFactory.afterPropertiesSet();
TestEchoService proxy = (TestEchoService) proxyFactory.getObject();
Message<?> message = proxy.echo("test");
Iterator<Event> historyIterator = message.getHeaders().getHistory().iterator();
Event event1 = historyIterator.next();
Event event2 = historyIterator.next();
assertEquals(ComponentType.gateway, event1.getComponentType());
assertEquals("echo", event1.getComponentName());
assertEquals(ComponentType.channel, event2.getComponentType());
assertEquals("testChannel", event2.getComponentName());
}
public static void throwTestException() throws TestException {
throw new TestException();
}
static interface TestEchoService {
Message<?> echo(String s);
}
static interface TestExceptionThrowingInterface {
String throwCheckedException(String s) throws TestException;