Uploaded image for project: 'Kogito'
  1. Kogito
  2. KOGITO-3798

Events are not passed between Kogito services

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Critical Critical
    • 1.0.0.Final
    • 1.0.0.Final
    • Core Engine
    • None
    • False
    • False
    • Undefined
    • Hide

      Install Infinispan 11
      Install Kafka 2.6.0
      Create required topics:

      bin/kafka-topics.sh --create --topic visaapplications --bootstrap-server localhost:9092
      bin/kafka-topics.sh --create --topic visasapproved --bootstrap-server localhost:9092
      bin/kafka-topics.sh --create --topic visasrejected --bootstrap-server localhost:9092
      bin/kafka-topics.sh --create --topic kogito-processinstances-events --bootstrap-server localhost:9092
      bin/kafka-topics.sh --create --topic kogito-usertaskinstances-events --bootstrap-server localhost:9092
      

      Build and start travels services and visas ("mvn clean install -DskipTests", then "java -jar travels-runner.jar" in target dir), don't forget to update Infinispan credentials in application.properties if user is specified in Infinispan.
      Submit travel request requiring visa:

      curl -H "Content-Type: application/json" -H "Accept: application/json" -X POST http://localhost:8080/travels -d @- << EOF
      {
      	"traveller" : {
      		"firstName" : "Jan",
      		"lastName" : "Kowalski",
      		"email" : "jan.kowalski@example.com",
      		"nationality" : "Polish",
      		"address" : {
      			"street" : "polna",
      			"city" : "Krakow",
      			"zipCode" : "32000",
      			"country" : "Poland"
      		}
      	},
      	"trip" : {
      		"city" : "New York",
      		"country" : "US",
      		"begin" : "2019-12-10T00:00:00.000+02:00",
      		"end" : "2019-12-15T00:00:00.000+02:00"
      	}
      }
      EOF
      

      Submit Visa application:

      curl -H "Content-Type: application/json" -H "Accept: application/json" -X POST http://localhost:8080/travels/{uuid}/VisaApplication/{task-uuid} -d @- << EOF
      {
      	"visaApplication" : {
      		"firstName" : "Jan",
      		"lastName" : "Kowalski",
      		"nationality" : "Polish",
      		"city" : "New York",
      		"country" : "US",
      		"passportNumber" : "ABC09876",
      		"duration" : 25
      	}
      }
      EOF
      

      Check Visa service - there is no active process:

      curl -X GET http://localhost:8090/visaApplications
      []
      

      There should be Visa application process active.

      Can be reproduced using dedicated BDD test - https://github.com/kiegroup/kogito-cloud-operator/blob/master/test/features/deploy_travel_agency.feature#L75-L160

      Show
      Install Infinispan 11 Install Kafka 2.6.0 Create required topics: bin/kafka-topics.sh --create --topic visaapplications --bootstrap-server localhost:9092 bin/kafka-topics.sh --create --topic visasapproved --bootstrap-server localhost:9092 bin/kafka-topics.sh --create --topic visasrejected --bootstrap-server localhost:9092 bin/kafka-topics.sh --create --topic kogito-processinstances-events --bootstrap-server localhost:9092 bin/kafka-topics.sh --create --topic kogito-usertaskinstances-events --bootstrap-server localhost:9092 Build and start travels services and visas ("mvn clean install -DskipTests", then "java -jar travels-runner.jar" in target dir), don't forget to update Infinispan credentials in application.properties if user is specified in Infinispan. Submit travel request requiring visa: curl -H "Content-Type: application/json" -H "Accept: application/json" -X POST http://localhost:8080/travels -d @- << EOF { "traveller" : { "firstName" : "Jan", "lastName" : "Kowalski", "email" : "jan.kowalski@example.com", "nationality" : "Polish", "address" : { "street" : "polna", "city" : "Krakow", "zipCode" : "32000", "country" : "Poland" } }, "trip" : { "city" : "New York", "country" : "US", "begin" : "2019-12-10T00:00:00.000+02:00", "end" : "2019-12-15T00:00:00.000+02:00" } } EOF Submit Visa application: curl -H "Content-Type: application/json" -H "Accept: application/json" -X POST http://localhost:8080/travels/{uuid}/VisaApplication/{task-uuid} -d @- << EOF { "visaApplication" : { "firstName" : "Jan", "lastName" : "Kowalski", "nationality" : "Polish", "city" : "New York", "country" : "US", "passportNumber" : "ABC09876", "duration" : 25 } } EOF Check Visa service - there is no active process: curl -X GET http://localhost:8090/visaApplications [] There should be Visa application process active. Can be reproduced using dedicated BDD test - https://github.com/kiegroup/kogito-cloud-operator/blob/master/test/features/deploy_travel_agency.feature#L75-L160
    • ---
    • ---
    • 2020 Week 46-48 (from Nov 9)

      Reproduced using kogito-travel-agency service on OpenShift.

      When traveller with required visa is passed into travels service and VisaApplication task is completed, the visa application event doesn't start visaApplications process in visas service.

      Expected outcome should be a running visaApplications process to process the visa.

              rhn-support-zanini Ricardo Zanini
              ksuta Karel Suta
              Karel Suta Karel Suta
              Karel Suta Karel Suta
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

                Created:
                Updated:
                Resolved: