@Test public void visitFireUntilHaltCommand() { FireUntilHaltCommand command = new FireUntilHaltCommand(); executeAndVerify(command, commandHandler::visit, () -> assertTrue(commandHandler.isFiringUntilHalt())); logger.info("FireUntilHaltCommand:{}", command.toString()); }
public boolean isFiringUntilHalt() { return firingUntilHalt; }
CommandHandler implements VisitorCommand { public boolean isFiringUntilHalt() { return firingUntilHalt; } }
CommandHandler implements VisitorCommand { public boolean isFiringUntilHalt() { return firingUntilHalt; } CommandHandler(KieSessionContext kieSessionContext,
                          EnvConfig envConfig,
                          Producer producer,
                          SessionSnapshooter sessionSnapshooter,
                          ConsumerUtilsCore consumerUtilsCore); }
CommandHandler implements VisitorCommand { public boolean isFiringUntilHalt() { return firingUntilHalt; } CommandHandler(KieSessionContext kieSessionContext,
                          EnvConfig envConfig,
                          Producer producer,
                          SessionSnapshooter sessionSnapshooter,
                          ConsumerUtilsCore consumerUtilsCore); static boolean isEvent(Object obj); static boolean hasTimestamp(Object obj); @Override void visit(FireAllRulesCommand command); @Override void visit(FireUntilHaltCommand command); @Override void visit(HaltCommand command); @Override void visit(InsertCommand command); @Override void visit(EventInsertCommand command); @Override void visit(DeleteCommand command); @Override void visit(UpdateCommand command); @Override void visit(ListObjectsCommand command); @Override void visit(ListObjectsCommandClassType command); @Override void visit(GetObjectCommand command); @Override void visit(ListObjectsCommandNamedQuery command); @Override void visit(FactCountCommand command); @Override void visit(SnapshotOnDemandCommand command); @Override void visit(UpdateKJarCommand command); @Override void visit(GetKJarGAVCommand command); boolean isFiringUntilHalt(); }
CommandHandler implements VisitorCommand { public boolean isFiringUntilHalt() { return firingUntilHalt; } CommandHandler(KieSessionContext kieSessionContext,
                          EnvConfig envConfig,
                          Producer producer,
                          SessionSnapshooter sessionSnapshooter,
                          ConsumerUtilsCore consumerUtilsCore); static boolean isEvent(Object obj); static boolean hasTimestamp(Object obj); @Override void visit(FireAllRulesCommand command); @Override void visit(FireUntilHaltCommand command); @Override void visit(HaltCommand command); @Override void visit(InsertCommand command); @Override void visit(EventInsertCommand command); @Override void visit(DeleteCommand command); @Override void visit(UpdateCommand command); @Override void visit(ListObjectsCommand command); @Override void visit(ListObjectsCommandClassType command); @Override void visit(GetObjectCommand command); @Override void visit(ListObjectsCommandNamedQuery command); @Override void visit(FactCountCommand command); @Override void visit(SnapshotOnDemandCommand command); @Override void visit(UpdateKJarCommand command); @Override void visit(GetKJarGAVCommand command); boolean isFiringUntilHalt();  }