Fixed the build

This commit is contained in:
Marcin Grzejszczak
2019-03-18 13:20:20 +01:00
parent ebb34b278e
commit 73c71241ca
4 changed files with 3 additions and 27 deletions

View File

@@ -70,12 +70,6 @@
<optional>true</optional>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>com.google.code.findbugs</groupId>
<artifactId>jsr305</artifactId>
<version>3.0.2</version>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.eclipse.sisu</groupId>
<artifactId>org.eclipse.sisu.plexus</artifactId>
@@ -162,8 +156,6 @@
<filter>
<excludes>
<exclude>org/slf4j/</exclude>
<exclude>org/apache/commons/lang3/</exclude>
<exclude>com/google/common/base/</exclude>
</excludes>
</filter>
</filters>

View File

@@ -51,8 +51,8 @@ class StubRunnerMessageRouter extends AbstractMessageRouter {
return Collections
.singleton((MessageChannel) this.beanFactory.getBean(channelName));
}
return Collections.singleton((MessageChannel) this.beanFactory
.getBean(StubRunnerStreamConfiguration.DummyMessageHandler.CHANNEL_NAME));
return Collections
.singleton((MessageChannel) this.beanFactory.getBean("nullChannel"));
}
}

View File

@@ -48,7 +48,6 @@ import org.springframework.integration.dsl.GenericEndpointSpec;
import org.springframework.integration.dsl.IntegrationFlowBuilder;
import org.springframework.integration.dsl.IntegrationFlows;
import org.springframework.integration.transformer.MessageTransformingHandler;
import org.springframework.messaging.Message;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.util.StringUtils;
@@ -96,11 +95,6 @@ public class StubRunnerStreamConfiguration {
BatchStubRunner batchStubRunner) {
Map<StubConfiguration, Collection<Contract>> contracts = batchStubRunner
.getContracts();
IntegrationFlowBuilder dummyBuilder = IntegrationFlows
.from(DummyMessageHandler.CHANNEL_NAME)
.handle(new DummyMessageHandler(), "handle");
beanFactory.initializeBean(dummyBuilder.get(),
DummyMessageHandler.CHANNEL_NAME + ".flow");
for (Entry<StubConfiguration, Collection<Contract>> entry : contracts
.entrySet()) {
StubConfiguration key = entry.getKey();
@@ -158,15 +152,6 @@ public class StubRunnerStreamConfiguration {
return new FlowRegistrar();
}
static class DummyMessageHandler {
static String CHANNEL_NAME = "stub_runner_dummy_channel";
public void handle(Message<?> message) {
}
}
static class FlowRegistrar {
}

View File

@@ -38,7 +38,6 @@ import org.springframework.cloud.stream.messaging.Source
import org.springframework.context.annotation.Configuration
import org.springframework.messaging.Message
import org.springframework.test.context.ContextConfiguration
/**
* @author Marcin Grzejszczak
*/
@@ -145,7 +144,7 @@ class StreamStubRunnerSpec extends Specification {
assertJsons(receivedMessage.payload)
receivedMessage.headers.get('BOOK-NAME') == 'foo'
}
def 'should trigger a label with no output message'() {
when:
// tag::trigger_no_output[]