mirror of https://github.com/dapr/java-sdk.git
chore: Apply suggestions
Signed-off-by: Javier Aliaga <javier@diagrid.io>
This commit is contained in:
parent
df4087210d
commit
c5625c4d53
|
|
@ -31,18 +31,20 @@ public class TestNamedActivitiesWorkflow implements Workflow {
|
|||
TestWorkflowPayload workflowPayload = ctx.getInput(TestWorkflowPayload.class);
|
||||
workflowPayload.setWorkflowId(instanceId);
|
||||
|
||||
var payloadAfterA = ctx.callActivity("a", workflowPayload, TestWorkflowPayload.class).await();
|
||||
var payloadAfterA = ctx.callActivity("a", workflowPayload, TestWorkflowPayload.class)
|
||||
.await();
|
||||
|
||||
var payloadAfterB = ctx.callActivity("b", payloadAfterA, TestWorkflowPayload.class).await();
|
||||
var payloadAfterB = ctx.callActivity("b", payloadAfterA, TestWorkflowPayload.class)
|
||||
.await();
|
||||
|
||||
var payloadAfterC = ctx.callActivity("c", payloadAfterB, TestWorkflowPayload.class)
|
||||
.await();
|
||||
.await();
|
||||
|
||||
var payloadAfterD = ctx.callActivity("d", payloadAfterC, TestWorkflowPayload.class)
|
||||
.await();
|
||||
.await();
|
||||
|
||||
var payloadAfterE = ctx.callActivity("e", payloadAfterD, TestWorkflowPayload.class)
|
||||
.await();
|
||||
.await();
|
||||
|
||||
ctx.complete(payloadAfterE);
|
||||
};
|
||||
|
|
|
|||
|
|
@ -6,10 +6,7 @@ import io.dapr.workflows.WorkflowActivityContext;
|
|||
import org.junit.Test;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
import static org.mockito.Mockito.mock;
|
||||
import static org.mockito.Mockito.times;
|
||||
import static org.mockito.Mockito.verify;
|
||||
import static org.mockito.Mockito.when;
|
||||
import static org.mockito.Mockito.*;
|
||||
|
||||
public class WorkflowActivityClassWrapperTest {
|
||||
public static class TestActivity implements WorkflowActivity {
|
||||
|
|
@ -22,7 +19,7 @@ public class WorkflowActivityClassWrapperTest {
|
|||
|
||||
@Test
|
||||
public void getName() {
|
||||
WorkflowActivityClassWrapper<TestActivity> wrapper = new WorkflowActivityClassWrapper<>( TestActivity.class);
|
||||
WorkflowActivityClassWrapper<TestActivity> wrapper = new WorkflowActivityClassWrapper<>(TestActivity.class);
|
||||
|
||||
assertEquals(
|
||||
"io.dapr.workflows.runtime.WorkflowActivityClassWrapperTest.TestActivity",
|
||||
|
|
|
|||
|
|
@ -19,15 +19,13 @@ import io.dapr.workflows.WorkflowStub;
|
|||
import org.junit.jupiter.api.Test;
|
||||
import org.slf4j.Logger;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
|
||||
import static org.mockito.ArgumentMatchers.eq;
|
||||
import static org.mockito.Mockito.mock;
|
||||
import static org.mockito.Mockito.times;
|
||||
import static org.mockito.Mockito.verify;
|
||||
|
||||
import java.io.ByteArrayOutputStream;
|
||||
import java.io.PrintStream;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
|
||||
import static org.mockito.ArgumentMatchers.eq;
|
||||
import static org.mockito.Mockito.*;
|
||||
|
||||
public class WorkflowRuntimeBuilderTest {
|
||||
public static class TestWorkflow implements Workflow {
|
||||
@Override
|
||||
|
|
@ -94,6 +92,6 @@ public class WorkflowRuntimeBuilderTest {
|
|||
.info(eq("Registered Workflow: {}"), eq("TestWorkflow"));
|
||||
|
||||
verify(testLogger, times(1))
|
||||
.info(eq("Registered Activity: {}"), eq( "io.dapr.workflows.runtime.WorkflowRuntimeBuilderTest.TestActivity"));
|
||||
.info(eq("Registered Activity: {}"), eq("io.dapr.workflows.runtime.WorkflowRuntimeBuilderTest.TestActivity"));
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue