@Test public void testBuilder() { final BaseLocalTransactionEvent in = mock(BaseLocalTransactionEvent.class); final Supplier process = mock(Supplier.class); final BaseTransactionCommand send = mock(BaseTransactionCommand.class); final BaseTransactionEvent blow = mock(BaseTransactionEvent.class); final WorkerMeta meta = mock(WorkerMeta.class); final Consumer attach = mock(Consumer.class); final LocalTransactionStepDefinition result = LocalTransactionStepDefinition.builder() .in(in) .process(Optional.of(process)) .send(Stream.of(send)) .blow(Stream.of(blow)) .meta(meta) .attach(attach) .build(); assertEquals(in, result.getIn()); assertEquals(process, result.getProcess().get()); assertTrue(result.getSend().allMatch(s -> s.equals(send))); assertTrue(result.getBlow().allMatch(b -> b.equals(blow))); assertEquals(meta, result.getMeta()); assertEquals(attach, result.getAttach().get()); }
public static <T extends BaseLocalTransactionEvent> LocalTransactionPipelineBuilder<T> builder() { return new LocalTransactionPipelineBuilder<T>(); }
LocalTransactionStepDefinition extends AbstractTransactionStepDefinition<BaseLocalTransactionEvent> { public static <T extends BaseLocalTransactionEvent> LocalTransactionPipelineBuilder<T> builder() { return new LocalTransactionPipelineBuilder<T>(); } }
LocalTransactionStepDefinition extends AbstractTransactionStepDefinition<BaseLocalTransactionEvent> { public static <T extends BaseLocalTransactionEvent> LocalTransactionPipelineBuilder<T> builder() { return new LocalTransactionPipelineBuilder<T>(); } LocalTransactionStepDefinition(BaseLocalTransactionEvent in,Optional<List<String>> businessKey,Optional<Supplier> process, 
    		Stream<BaseTransactionCommand> send, Stream<BaseTransactionEvent> blow, 
    		ReceivedCommand receivedCommand, Optional<Consumer<String>> attach, 
    		ReceivedCommandGTX receivedCommandGTX, 
    		@NotNull WorkerMeta meta,CompensateWhen compensateWhen);  LocalTransactionStepDefinition(); }
LocalTransactionStepDefinition extends AbstractTransactionStepDefinition<BaseLocalTransactionEvent> { public static <T extends BaseLocalTransactionEvent> LocalTransactionPipelineBuilder<T> builder() { return new LocalTransactionPipelineBuilder<T>(); } LocalTransactionStepDefinition(BaseLocalTransactionEvent in,Optional<List<String>> businessKey,Optional<Supplier> process, 
    		Stream<BaseTransactionCommand> send, Stream<BaseTransactionEvent> blow, 
    		ReceivedCommand receivedCommand, Optional<Consumer<String>> attach, 
    		ReceivedCommandGTX receivedCommandGTX, 
    		@NotNull WorkerMeta meta,CompensateWhen compensateWhen);  LocalTransactionStepDefinition(); static LocalTransactionPipelineBuilder<T> builder(); void accept(StepLocalTxVisitor visitor); @NotNull WorkerMeta getMeta(); }
LocalTransactionStepDefinition extends AbstractTransactionStepDefinition<BaseLocalTransactionEvent> { public static <T extends BaseLocalTransactionEvent> LocalTransactionPipelineBuilder<T> builder() { return new LocalTransactionPipelineBuilder<T>(); } LocalTransactionStepDefinition(BaseLocalTransactionEvent in,Optional<List<String>> businessKey,Optional<Supplier> process, 
    		Stream<BaseTransactionCommand> send, Stream<BaseTransactionEvent> blow, 
    		ReceivedCommand receivedCommand, Optional<Consumer<String>> attach, 
    		ReceivedCommandGTX receivedCommandGTX, 
    		@NotNull WorkerMeta meta,CompensateWhen compensateWhen);  LocalTransactionStepDefinition(); static LocalTransactionPipelineBuilder<T> builder(); void accept(StepLocalTxVisitor visitor); @NotNull WorkerMeta getMeta();  }