[jboss-jira] [JBoss JIRA] (DROOLS-4368) HACEP Refactor DefaultKafkaConsumer

[Daniele Zonca (Jira)]

     [ https://issues.jboss.org/browse/DROOLS-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Daniele Zonca updated DROOLS-4368:
----------------------------------
    Description: 
Try to uniform leader/replica flow:
- If I'm the leader it invokes `defaultProcessAsLeader` -> `processLeader` -> `process/processWithSnapshot`
- If I'm a replica it invokes `defaultProcessAsAReplica` -> `consumeEventsFromBufferAsAReplica` -> `processEventsAsAReplica` -> `process`

Try to remove most/all boolean and use proper method parameter

Verify defaultProcessAsAReplica else branch. This should never happen because if leader sent a message about process a specific event, it should be available

  was:
Try to uniform leader/replica flow:
- If I'm the leader it invokes `defaultProcessAsLeader` -> `processLeader` -> `process/processWithSnapshot`
- If I'm a replica it invokes `defaultProcessAsAReplica` -> `consumeEventsFromBufferAsAReplica` -> `processEventsAsAReplica` -> `process`

Try to remove most/all boolean and use proper method parameter



> HACEP Refactor DefaultKafkaConsumer
> -----------------------------------
>
>                 Key: DROOLS-4368
>                 URL: https://issues.jboss.org/browse/DROOLS-4368
>             Project: Drools
>          Issue Type: Task
>          Components: core engine
>            Reporter: Daniele Zonca
>            Assignee: Massimiliano Dessi
>            Priority: Major
>
> Try to uniform leader/replica flow:
> - If I'm the leader it invokes `defaultProcessAsLeader` -> `processLeader` -> `process/processWithSnapshot`
> - If I'm a replica it invokes `defaultProcessAsAReplica` -> `consumeEventsFromBufferAsAReplica` -> `processEventsAsAReplica` -> `process`
> Try to remove most/all boolean and use proper method parameter
> Verify defaultProcessAsAReplica else branch. This should never happen because if leader sent a message about process a specific event, it should be available



--
This message was sent by Atlassian Jira
(v7.12.1#712002)