SpringCloud/stream-applications
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert "Fix router sink tests"

Browse Source 
This reverts commit d43893c1ef.
This commit is contained in:
Soby Chacko
2021-04-05 15:43:52 -04:00
parent d43893c1ef
commit 55b306e160
2 changed files with 16 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
applications/processor/filter-processor/src/test/java/org/springframework/cloud/stream/app/processor/filter/FilterProcessorTests.java
View File

@@ -18,7 +18,6 @@ package org.springframework.cloud.stream.app.processor.filter;
import java.nio.charset.StandardCharsets;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.springframework.boot.WebApplicationType;
@@ -38,7 +37,6 @@ import static org.assertj.core.api.Assertions.assertThat;
/**
* @author Christian Tzolov
*/
@Disabled("temporarily")
public class FilterProcessorTests {
@Test

32
applications/sink/router-sink/src/test/java/org/springframework/cloud/stream/app/sink/router/RouterSinkIntegrationTests.java
View File

@@ -42,7 +42,7 @@ public class RouterSinkIntegrationTests {
InputDestination processorInput = context.getBean(InputDestination.class);
Message<?> message = MessageBuilder.withPayload("hello".getBytes()).setHeader("routeTo", "baz").build();
Message<?> message = MessageBuilder.withPayload("hello").setHeader("routeTo", "baz").build();
processorInput.send(message);
OutputDestination processorOutput = context.getBean(OutputDestination.class);
@@ -81,7 +81,7 @@ public class RouterSinkIntegrationTests {
InputDestination processorInput = context.getBean(InputDestination.class);
Message<?> message = MessageBuilder.withPayload("foo".getBytes())
Message<?> message = MessageBuilder.withPayload("foo")
.setHeader("route", "foo").build();
processorInput.send(message);
@@ -103,24 +103,24 @@ public class RouterSinkIntegrationTests {
InputDestination processorInput = context.getBean(InputDestination.class);
Message<?> message = MessageBuilder.withPayload("foo".getBytes())
Message<?> message = MessageBuilder.withPayload("foo")
.setHeader("route", "foo").build();
processorInput.send(message);
OutputDestination processorOutput = context.getBean(OutputDestination.class);
assertThat(context.getBean("baz")).isNotNull();
Message<byte[]> sourceMessage = processorOutput.receive(10000, "baz");
Message<byte[]> sourceMessage = processorOutput.receive(10000, "baz.destination");
assertThat(new String(sourceMessage.getPayload())).isEqualTo("foo");
message = MessageBuilder.withPayload("bar".getBytes())
message = MessageBuilder.withPayload("bar")
.setHeader("route", "bar").build();
processorInput.send(message);
processorOutput = context.getBean(OutputDestination.class);
assertThat(context.getBean("qux")).isNotNull();
sourceMessage = processorOutput.receive(10000, "qux");
sourceMessage = processorOutput.receive(10000, "qux.destination");
assertThat(new String(sourceMessage.getPayload())).isEqualTo("bar");
}
}
@@ -137,26 +137,26 @@ public class RouterSinkIntegrationTests {
InputDestination processorInput = context.getBean(InputDestination.class);
Message<?> message = MessageBuilder.withPayload("foo".getBytes())
Message<?> message = MessageBuilder.withPayload("foo")
.setHeader("route", "foo").build();
processorInput.send(message);
message = MessageBuilder.withPayload("bar".getBytes())
message = MessageBuilder.withPayload("bar")
.setHeader("route", "bar").build();
processorInput.send(message);
message = MessageBuilder.withPayload("hello".getBytes())
message = MessageBuilder.withPayload("hello")
.setHeader("route", "baz").build();
processorInput.send(message);
OutputDestination processorOutput = context.getBean(OutputDestination.class);
Message<byte[]> sourceMessage = processorOutput.receive(10000, "foo");
Message<byte[]> sourceMessage = processorOutput.receive(10000, "foo.destination");
assertThat(new String(sourceMessage.getPayload())).isEqualTo("foo");
sourceMessage = processorOutput.receive(10000, "bar");
sourceMessage = processorOutput.receive(10000, "bar.destination");
assertThat(new String(sourceMessage.getPayload())).isEqualTo("bar");
sourceMessage = processorOutput.receive(10000, "discards");
sourceMessage = processorOutput.receive(10000, "discards.destination");
assertThat(new String(sourceMessage.getPayload())).isEqualTo("hello");
}
}
@@ -173,20 +173,20 @@ public class RouterSinkIntegrationTests {
InputDestination processorInput = context.getBean(InputDestination.class);
Message<?> message = MessageBuilder.withPayload("foo".getBytes())
Message<?> message = MessageBuilder.withPayload("foo")
.setHeader("route", "foo").build();
processorInput.send(message);
OutputDestination processorOutput = context.getBean(OutputDestination.class);
Message<byte[]> sourceMessage = processorOutput.receive(10000, "baz");
Message<byte[]> sourceMessage = processorOutput.receive(10000, "baz.destination");
assertThat(new String(sourceMessage.getPayload())).isEqualTo("foo");
message = MessageBuilder.withPayload("bar".getBytes())
message = MessageBuilder.withPayload("bar")
.setHeader("route", "bar").build();
processorInput.send(message);
sourceMessage = processorOutput.receive(10000, "qux");
sourceMessage = processorOutput.receive(10000, "qux.destination");
assertThat(new String(sourceMessage.getPayload())).isEqualTo("bar");
}
}