public class InfraFactory extends Object
Modifier and Type | Method and Description |
---|---|
static RemoteKieSession |
createRemoteKieSession(Properties configuration,
Listener listener,
Producer producer) |
static RemoteStreamingKieSession |
createRemoteStreamingKieSession(Properties configuration,
Listener listener,
Producer producer) |
static org.apache.kafka.clients.consumer.KafkaConsumer |
getConsumer(String topic,
Properties properties) |
static ConsumerHandler |
getConsumerHandler(Producer producer,
EnvConfig envConfig) |
static EventConsumer |
getEventConsumer(EnvConfig config) |
static ItemToProcess |
getItemToProcess(org.apache.kafka.clients.consumer.ConsumerRecord record) |
static Producer |
getProducer(boolean isLocal) |
static SessionSnapshooter |
getSnapshooter(EnvConfig envConfig) |
public static EventConsumer getEventConsumer(EnvConfig config)
public static SessionSnapshooter getSnapshooter(EnvConfig envConfig)
public static ConsumerHandler getConsumerHandler(Producer producer, EnvConfig envConfig)
public static org.apache.kafka.clients.consumer.KafkaConsumer getConsumer(String topic, Properties properties)
public static RemoteKieSession createRemoteKieSession(Properties configuration, Listener listener, Producer producer)
public static Producer getProducer(boolean isLocal)
public static RemoteStreamingKieSession createRemoteStreamingKieSession(Properties configuration, Listener listener, Producer producer)
public static ItemToProcess getItemToProcess(org.apache.kafka.clients.consumer.ConsumerRecord record)
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.