Skip to content

Commit

Permalink
Update missed stream app version in test
Browse files Browse the repository at this point in the history
  • Loading branch information
onobc committed Aug 19, 2024
1 parent f1f17f6 commit 195f719
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ public void testMigration_210_211() throws URISyntaxException {
objectMapper.registerModule(new Jackson2DataflowModule());
final DataFlowTemplate dataFlowTemplate = new DataFlowTemplate(new URI(dataflowCluster.getDataflowUrl()), objectMapper);
dataFlowTemplate.appRegistryOperations().register("time", ApplicationType.source, "docker:springcloudstream/time-source-rabbit:5.0.0", null, false);
dataFlowTemplate.appRegistryOperations().register("log", ApplicationType.sink, "docker:springcloudstream/log-sink-rabbit:3.2.1", null, false);
dataFlowTemplate.appRegistryOperations().register("log", ApplicationType.sink, "docker:springcloudstream/log-sink-rabbit:5.0.0", null, false);
dataFlowTemplate.streamOperations().createStream("timelogger", "time | log", "timelogger", false);

StreamDefinitionResource timelogger = dataFlowTemplate.streamOperations().getStreamDefinition("timelogger");
Expand Down

0 comments on commit 195f719

Please sign in to comment.