Skip to content

Commit 347040e

Browse files
committed
fix: compile after rebase
1 parent cc49cb3 commit 347040e

2 files changed

Lines changed: 3 additions & 2 deletions

File tree

src/test/java/org/eclipse/dataplane/DataplaneTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,8 @@ void shouldFail_whenDataFlowDoesNotExist() {
132132
void shouldSendDataFlowStatusMessage_whenDataFlowIsErrored() {
133133
controlPlane.stubFor(post(anyUrl()).willReturn(aResponse().withStatus(200)));
134134
var dataplane = Dataplane.newInstance().id("dataplane-id").onPrepare(Result::success).build();
135-
dataplane.prepare(createPrepareMessage());
135+
dataplane.registerControlPlane(new ControlPlaneRegistrationMessage("controlplaneId", URI.create("http://localhost/any")));
136+
dataplane.prepare("controlplaneId", createPrepareMessage());
136137

137138
var result = dataplane.notifyErrored("dataFlowId", new RuntimeException("some-error"));
138139

src/test/java/org/eclipse/dataplane/scenario/AuthorizationTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ void shouldGetUnauthorized_withDataPlaneIsNotAuthenticated() {
120120
var consumerProcessId = "consumer_" + UUID.randomUUID();
121121
var prepareMessage = createPrepareMessage(consumerProcessId, controlPlane.consumerCallbackAddress(), "FileSystemAsync-PUSH");
122122

123-
controlPlane.consumerPrepare(prepareMessage).statusCode(202).extract().as(DataFlowResponseMessage.class);
123+
controlPlane.consumerPrepare(prepareMessage).statusCode(202).extract().as(DataFlowStatusMessage.class);
124124

125125
var notifyPreparedResult = dataPlane.getById(consumerProcessId)
126126
.compose(dataFlow -> dataPlane.notifyPrepared(consumerProcessId, Result::success));

0 commit comments

Comments
 (0)