public class DroolsConsumerHandler extends Object implements ConsumerHandler
Constructor and Description |
---|
DroolsConsumerHandler(Producer producer,
EnvConfig envConfig,
SessionSnapshooter snapShooter,
ConsumerUtilsCore consumerUtilsCore) |
Modifier and Type | Method and Description |
---|---|
boolean |
initializeKieSessionFromSnapshotOnDemand(EnvConfig config,
SnapshotInfos snapshotInfos) |
void |
process(ItemToProcess item,
State state) |
void |
process(RemoteCommand command,
State state) |
void |
processSideEffectsOnReplica(Queue<Serializable> newSideEffects) |
void |
processWithSnapshot(ItemToProcess item,
State currentState) |
void |
stop() |
public DroolsConsumerHandler(Producer producer, EnvConfig envConfig, SessionSnapshooter snapShooter, ConsumerUtilsCore consumerUtilsCore)
public boolean initializeKieSessionFromSnapshotOnDemand(EnvConfig config, SnapshotInfos snapshotInfos)
public void process(ItemToProcess item, State state)
process
in interface ConsumerHandler
public void process(RemoteCommand command, State state)
process
in interface ConsumerHandler
public void processSideEffectsOnReplica(Queue<Serializable> newSideEffects)
public void processWithSnapshot(ItemToProcess item, State currentState)
processWithSnapshot
in interface ConsumerHandler
public void stop()
stop
in interface ConsumerHandler
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.