From 9d13cd57c8d588d8fe2950007090059d49f93f2c Mon Sep 17 00:00:00 2001 From: Nico Korthout Date: Tue, 2 Jan 2024 14:49:27 +0100 Subject: [PATCH] fix: support instance migration response (cherry picked from commit 0c24ced2f752b9eac6ab0c28c13c3002c1648308) --- .../zeebe/process/test/engine/GrpcResponseMapper.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/engine/src/main/java/io/camunda/zeebe/process/test/engine/GrpcResponseMapper.java b/engine/src/main/java/io/camunda/zeebe/process/test/engine/GrpcResponseMapper.java index 90ee63c3d..ea52ca6ca 100644 --- a/engine/src/main/java/io/camunda/zeebe/process/test/engine/GrpcResponseMapper.java +++ b/engine/src/main/java/io/camunda/zeebe/process/test/engine/GrpcResponseMapper.java @@ -40,6 +40,8 @@ import io.camunda.zeebe.gateway.protocol.GatewayOuterClass.FailJobResponse; import io.camunda.zeebe.gateway.protocol.GatewayOuterClass.FormMetadata; import io.camunda.zeebe.gateway.protocol.GatewayOuterClass.MatchedDecisionRule; +import io.camunda.zeebe.gateway.protocol.GatewayOuterClass.MigrateProcessInstanceRequest; +import io.camunda.zeebe.gateway.protocol.GatewayOuterClass.MigrateProcessInstanceResponse; import io.camunda.zeebe.gateway.protocol.GatewayOuterClass.ModifyProcessInstanceRequest; import io.camunda.zeebe.gateway.protocol.GatewayOuterClass.ModifyProcessInstanceResponse; import io.camunda.zeebe.gateway.protocol.GatewayOuterClass.ProcessMetadata; @@ -100,6 +102,8 @@ class GrpcResponseMapper { Map.entry(UpdateJobRetriesRequest.class, this::createJobUpdateRetriesResponse), Map.entry(UpdateJobTimeoutRequest.class, this::createJobUpdateTimeOutResponse), Map.entry(ModifyProcessInstanceRequest.class, this::createModifyProcessInstanceResponse), + Map.entry( + MigrateProcessInstanceRequest.class, this::createMigrateProcessInstanceResponse), Map.entry(BroadcastSignalRequest.class, this::createBroadcastSignalResponse)); GeneratedMessageV3 map( @@ -294,6 +298,10 @@ private GeneratedMessageV3 createModifyProcessInstanceResponse() { return ModifyProcessInstanceResponse.newBuilder().build(); } + private GeneratedMessageV3 createMigrateProcessInstanceResponse() { + return MigrateProcessInstanceResponse.getDefaultInstance(); + } + private GeneratedMessageV3 createBroadcastSignalResponse() { final SignalRecord signal = new SignalRecord(); signal.wrap(valueBufferView);