in kogito-quarkus-examples/process-performance-client/src/main/java/org/kie/kogito/performance/client/RequestDispatcherFactory.java [32:45]
public static RequestDispatcher getDispatcher(RequestType type, String processId) {
switch (type) {
case REST:
return new SyncRestDispatcher(processId);
case REST_ASYNC:
return new AsyncRestDispatcher(processId);
case KAFKA:
return new KafkaDispatcher(processId);
default:
throw new UnsupportedOperationException("Unknown type " + type);
}
}