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

Removed ServiceActivatorEndpoint from MethodInvokingConsumerTests.

Browse Source
This commit is contained in:
Mark Fisher
2008-10-14 14:42:16 +00:00
parent 79d9d8dc07
commit 10fd9304f0
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
org.springframework.integration/src/test/java/org/springframework/integration/message/MethodInvokingConsumerTests.java
View File

@@ -30,7 +30,6 @@ import org.springframework.context.support.GenericApplicationContext;
import org.springframework.integration.bus.DefaultMessageBus;
import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.endpoint.PollingConsumerEndpoint;
import org.springframework.integration.endpoint.ServiceActivatorEndpoint;
import org.springframework.integration.util.TestUtils;
/**
@@ -76,16 +75,14 @@ public class MethodInvokingConsumerTests {
GenericApplicationContext context = new GenericApplicationContext();
SynchronousQueue<String> queue = new SynchronousQueue<String>();
TestBean testBean = new TestBean(queue);
MethodInvokingConsumer consumer = new MethodInvokingConsumer(testBean, "foo");
consumer.afterPropertiesSet();
QueueChannel channel = new QueueChannel();
channel.setBeanName("channel");
context.getBeanFactory().registerSingleton("channel", channel);
Message<String> message = new GenericMessage<String>("testing");
channel.send(message);
assertNull(queue.poll());
ServiceActivatorEndpoint serivceActivator = new ServiceActivatorEndpoint(consumer);
PollingConsumerEndpoint endpoint = new PollingConsumerEndpoint(serivceActivator, channel);
MethodInvokingConsumer consumer = new MethodInvokingConsumer(testBean, "foo");
PollingConsumerEndpoint endpoint = new PollingConsumerEndpoint(consumer, channel);
context.getBeanFactory().registerSingleton("testEndpoint", endpoint);
DefaultMessageBus bus = new DefaultMessageBus();
bus.setTaskScheduler(TestUtils.createTaskScheduler(10));