mindol1004/camunda-ddd-and-clean-architecture
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

removed unnecessary fetch variable specification

Browse Source
This commit is contained in:
Luc Weinbrecht
2022-06-27 06:20:12 +02:00
parent 817c683ad5
commit 28c36a589d
4 changed files with 6 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
loan-agreement/src/main/java/de/weinbrecht/luc/bpm/architecture/loan/agreement/adapter/in/process/ApproveLoanAgreement.java
View File

@@ -8,7 +8,6 @@ import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import static de.weinbrecht.luc.bpm.architecture.loan.agreement.adapter.common.ProcessConstants.LOAN_AGREEMENT_NUMBER;
import static de.weinbrecht.luc.bpm.architecture.loan.agreement.adapter.common.ProcessConstants.LOAN_AGREEMENT_TASK;
@Slf4j
@@ -18,7 +17,7 @@ public class ApproveLoanAgreement {
private final LoanAgreementStatusCommand loanAgreementStatusCommand;
@ZeebeWorker(type = LOAN_AGREEMENT_TASK, fetchVariables = LOAN_AGREEMENT_NUMBER, autoComplete = true)
@ZeebeWorker(type = LOAN_AGREEMENT_TASK, autoComplete = true)
public void handleJobFoo(@ZeebeVariable Number loanAgreementNumber) {
loanAgreementStatusCommand.accept(new LoanAgreementNumber(loanAgreementNumber.longValue()));
}

3
loan-agreement/src/main/java/de/weinbrecht/luc/bpm/architecture/loan/agreement/adapter/in/process/RejectionLoanAgreement.java
View File

@@ -8,7 +8,6 @@ import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import static de.weinbrecht.luc.bpm.architecture.loan.agreement.adapter.common.ProcessConstants.LOAN_AGREEMENT_NUMBER;
import static de.weinbrecht.luc.bpm.architecture.loan.agreement.adapter.common.ProcessConstants.LOAN_REJECTION_TASK;
@Slf4j
@@ -18,7 +17,7 @@ public class RejectionLoanAgreement {
private final LoanAgreementStatusCommand loanAgreementStatusCommand;
@ZeebeWorker(type = LOAN_REJECTION_TASK, fetchVariables = LOAN_AGREEMENT_NUMBER, autoComplete = true)
@ZeebeWorker(type = LOAN_REJECTION_TASK, autoComplete = true)
public void handleJobFoo(@ZeebeVariable Number loanAgreementNumber) {
loanAgreementStatusCommand.reject(new LoanAgreementNumber(loanAgreementNumber.longValue()));
}

8
loan-agreement/src/main/java/de/weinbrecht/luc/bpm/architecture/loan/agreement/adapter/in/process/SendCrossSellingRecommendation.java
View File

@@ -10,7 +10,7 @@ import io.camunda.zeebe.spring.client.annotation.ZeebeWorker;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component;
import static de.weinbrecht.luc.bpm.architecture.loan.agreement.adapter.common.ProcessConstants.*;
import static de.weinbrecht.luc.bpm.architecture.loan.agreement.adapter.common.ProcessConstants.SEND_CROSS_SELLING_RECOMMENDATION_TASK;
@RequiredArgsConstructor
@Component
@@ -19,11 +19,7 @@ public class SendCrossSellingRecommendation {
private final RecommendationTrigger recommendationTrigger;
private final LoanAgreementQuery loanAgreementQuery;
@ZeebeWorker(
type = SEND_CROSS_SELLING_RECOMMENDATION_TASK,
fetchVariables = { LOAN_AGREEMENT_NUMBER, BUSINESS_KEY },
autoComplete = true
)
@ZeebeWorker(type = SEND_CROSS_SELLING_RECOMMENDATION_TASK, autoComplete = true)
public void handleJobFoo(@ZeebeVariable Number loanAgreementNumber, @ZeebeVariable String businessKey) {
LoanAgreement loanAgreement = loanAgreementQuery.loadByNumber(
new LoanAgreementNumber(loanAgreementNumber.longValue())

8
recommendation/src/main/java/de/weinbrecht/luc/bpm/architecture/recommendation/adapter/in/process/SendRecommendation.java
View File

@@ -12,7 +12,7 @@ import io.camunda.zeebe.spring.client.annotation.ZeebeWorker;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component;
import static de.weinbrecht.luc.bpm.architecture.recommendation.adapter.common.ProcessConstants.*;
import static de.weinbrecht.luc.bpm.architecture.recommendation.adapter.common.ProcessConstants.SEND_RECOMMENDATION_TASK;
@RequiredArgsConstructor
@Component
@@ -21,11 +21,7 @@ public class SendRecommendation {
private final SendNotification sendNotification;
private final RecommendationQuery recommendationQuery;
@ZeebeWorker(
type = SEND_RECOMMENDATION_TASK,
fetchVariables = {CONTENT_NUMBER, CUSTOMER_NUMBER},
autoComplete = true
)
@ZeebeWorker(type = SEND_RECOMMENDATION_TASK, autoComplete = true)
public void handleJobFoo(@ZeebeVariable Number contentNumber, @ZeebeVariable String customerNumber) {
Content content = recommendationQuery.findContentById(new ContentId(contentNumber.longValue()));
Customer customer = recommendationQuery.findCustomerById(new CustomerId(customerNumber));