Feature/decision polling #142
Conversation
| private String decisionRequirementsDefinitionId; | ||
| private String decisionRequirementsDefinitionKey; | ||
| private Double collectResultValue; | ||
|
|
There was a problem hiding this comment.
Leerzeile zu viel, oder ist das extra? Die anderen Typen im Projekt haben keine freien Zeilen zwischen den Attributen, es allerdings auch noch keine Listen oder Maps. 😊
There was a problem hiding this comment.
Rein sinngemäß habe ich hier eine Leerzeile gemacht, kann aber bei Bedarf wieder weg.
| private String removalTime; | ||
| private String rootProcessInstanceId; | ||
| private String value; | ||
|
|
| * | ||
| * | ||
| * | ||
| * | ||
| * @author viadee | ||
| * | ||
| * |
There was a problem hiding this comment.
Wenn das das Einzige ist, was in dieser Datei geändert wird, dann m.E. reverten, damit sich nicht "so viel" ändert?
| * | ||
| * | ||
| * | ||
| * | ||
| * @author viadee | ||
| * | ||
| * |
camunda-kafka-polling-client/pom.xml
Outdated
| <dependency> | ||
| <groupId>de.viadee.camunda</groupId> | ||
| <artifactId>camunda-kafka-model</artifactId> | ||
| <version>2.1.0</version> | ||
| <scope>test</scope> | ||
| </dependency> | ||
| <dependency> | ||
| <groupId>de.viadee.camunda</groupId> | ||
| <artifactId>camunda-kafka-model</artifactId> | ||
| <version>2.1.0</version> | ||
| <scope>compile</scope> | ||
| </dependency> |
There was a problem hiding this comment.
Das Model ist eigentlich bereits als Abhängigkeit in der Pom, ein paar Zeilen weiter oben, und warum ist es 2x hier drin? ;)
| logging.level.de.viadee.camunda.kafka.pollingclient=INFO No newline at end of file | ||
| logging.level.de.viadee.camunda.kafka.pollingclient=DEBUG |
| import de.viadee.camunda.kafka.event.IdentityLinkEvent; | ||
| import de.viadee.camunda.kafka.event.HistoryEvent; | ||
| import de.viadee.camunda.kafka.event.ProcessInstanceEvent; | ||
| import de.viadee.camunda.kafka.event.*; |
| @@ -605,6 +616,57 @@ static Stream<Arguments> pollIdentityLinks() { | |||
| // @formatter:on | |||
| } | |||
|
|
|||
| @DisplayName("Polling of decision Instances") | |||
| .stream() | ||
| .filter(event -> event instanceof DecisionInstanceEvent) | ||
| .map(event -> ((DecisionInstanceEvent) event).getOutputs()) | ||
| .findFirst(); |
There was a problem hiding this comment.
Du könntest das findFirstersetzten z.B. mit .or(() -> Assertions.fail("Decision instance expected, but nothing found"));, dann sparst du dir das Optional.get().
| <dependency> | ||
| <groupId>org.camunda.bpm.dmn</groupId> | ||
| <artifactId>camunda-engine-dmn</artifactId> | ||
| <scope>test</scope> | ||
| </dependency> | ||
|
|
||
| <dependency> | ||
| <groupId>org.camunda.bpm.dmn</groupId> | ||
| <artifactId>camunda-engine-dmn-bom</artifactId> | ||
| <scope>test</scope> | ||
| </dependency> |
There was a problem hiding this comment.
In das nicht bereits mit der camunda-bom abgedeckt?
|
|
||
| // query xml | ||
| try { | ||
| String xml = IOUtils.toString(repositoryService.getResourceAsStream(decisionDefinition.getDeploymentId(), |
There was a problem hiding this comment.
Können wir hier Probleme mit dem Encoding bekommen?
Add layout file for decision definition event mapping Add layout class for decision definition event mapping
Add decision instance class Add decision instance input and output class Add decision instance response class Add decision instance input and output response class Fix unnecessary blank line
|
@MTwelkemeier, @rnschk : Könntet ihr nochmal ein Review machen? Ein baldiger Merge würde @tDalile in der Weiterentwicklung sehr helfen. |
|
Disclaimer: Michael ist in Elternzeit. Wir werden Geduld oder Mut brauchen. |
|
Dann doch lieber Geduld. Einen funktionierenden Workaround für die Weiterentwicklung habe ich bereits. |
tDalile
force-pushed
the
feature/decision-polling
branch
from
6975570 to
44e882d
Compare
Added decision polling. Related to: #62 (comment)