Path Lines of Code jobs-service/jobs-recipients/job-http-recipient/deployment/src/main/java/org/kie/kogito/job/http/recipient/deployment/JobHttpRecipientProcessor.java 39 jobs-service/jobs-recipients/job-http-recipient/runtime/src/main/java/org/kie/kogito/job/http/recipient/HttpJobExecutor.java 48 jobs-service/jobs-recipients/job-http-recipient/runtime/src/main/java/org/kie/kogito/job/http/recipient/HttpRecipientValidator.java 45 jobs-service/jobs-recipients/job-http-recipient/runtime/src/main/java/org/kie/kogito/job/http/recipient/JobHttpRecipientRuntimeConfiguration.java 11 jobs-service/jobs-recipients/job-http-recipient/runtime/src/main/resources/META-INF/quarkus-extension.yaml 15 jobs-service/jobs-recipients/job-recipient-common-http/src/main/java/org/kie/kogito/job/recipient/common/http/HTTPRequest.java 118 jobs-service/jobs-recipients/job-recipient-common-http/src/main/java/org/kie/kogito/job/recipient/common/http/HTTPRequestExecutor.java 144 jobs-service/jobs-recipients/job-recipient-common-http/src/main/java/org/kie/kogito/job/recipient/common/http/converters/HttpConverters.java 10 jobs-service/jobs-recipients/job-sink-recipient/deployment/src/main/java/org/kie/kogito/job/sink/recipient/deployment/JobSinkRecipientProcessor.java 40 jobs-service/jobs-recipients/job-sink-recipient/runtime/src/main/java/org/kie/kogito/job/sink/recipient/JobSinkRecipientRuntimeConfiguration.java 11 jobs-service/jobs-recipients/job-sink-recipient/runtime/src/main/java/org/kie/kogito/job/sink/recipient/SinkJobExecutor.java 130 jobs-service/jobs-recipients/job-sink-recipient/runtime/src/main/java/org/kie/kogito/job/sink/recipient/SinkRecipientValidator.java 61 jobs-service/jobs-recipients/job-sink-recipient/runtime/src/main/resources/META-INF/quarkus-extension.yaml 18 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/events/JobDataEvent.java 44 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/exception/InvalidScheduleTimeException.java 6 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/exception/JobValidationException.java 9 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/executor/DefaultJobExecutorResolver.java 20 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/job/DelegateJob.java 57 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/json/DurationExpirationTimeDeserializer.java 32 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/json/DurationExpirationTimeSerializer.java 25 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/json/ExactExpirationTimeDeserializer.java 21 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/json/ExactExpirationTimeSerializer.java 19 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/json/JacksonConfiguration.java 39 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/json/JobDescriptionDeserializer.java 63 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/json/JobDescriptionSerializer.java 39 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/management/HttpGatekeeperFilter.java 27 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/management/JobServiceInstanceManager.java 145 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/management/JobServiceLeaderHealthCheck.java 24 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/management/JobServiceLeaderLivenessHealthCheck.java 42 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/management/MessagingChangeEvent.java 10 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/management/ReleaseLeaderEvent.java 3 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/messaging/MessagingConsumer.java 37 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/messaging/MessagingHandler.java 5 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/messaging/ReactiveMessagingEventConsumer.java 92 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/messaging/v2/MessagingConsumer.java 37 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/openapi/JobServiceModelFilter.java 94 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/reflection/ReflectionConfiguration.java 63 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/repository/JobServiceManagementRepository.java 10 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/repository/ReactiveJobRepository.java 46 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/repository/impl/BaseReactiveJobRepository.java 52 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/repository/impl/DefaultJobServiceManagementRepository.java 33 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/repository/impl/InMemoryConfiguration.java 16 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/repository/impl/InMemoryJobRepository.java 107 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/repository/marshaller/JobDetailsMarshaller.java 167 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/repository/marshaller/Marshaller.java 5 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/repository/marshaller/RecipientMarshaller.java 35 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/repository/marshaller/TriggerMarshaller.java 176 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/CallbackResourceTest.java 32 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/JobResource.java 79 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/JobServiceManagementResource.java 24 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/RestApiConstants.java 6 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/error/BaseExceptionMapper.java 40 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/error/DefaultExceptionMapper.java 8 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/error/ErrorResponse.java 10 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/error/IllegalArgumentExceptionMapper.java 8 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/error/InvalidScheduleTimeExceptionMapper.java 9 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/error/JobValidationExceptionMapper.java 9 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/error/NotFoundExceptionMapper.java 9 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/error/WebApplicationExceptionMapper.java 13 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/resource/v2/JobResourceV2.java 66 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/scheduler/BaseTimerJobScheduler.java 300 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/scheduler/JobScheduler.java 9 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/scheduler/JobSchedulerManager.java 166 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/scheduler/JobSchedulerManagerErrorEvent.java 15 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/scheduler/JobSchedulerManagerHealthCheck.java 24 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/scheduler/ReactiveJobScheduler.java 15 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/scheduler/impl/TimerDelegateJobScheduler.java 69 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/scheduler/impl/VertxTimerServiceScheduler.java 89 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/stream/AbstractJobStreams.java 67 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/stream/AvailableStreams.java 12 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/stream/JobEventPublisher.java 5 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/stream/JobStreams.java 6 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/stream/JobStreamsEventPublisher.java 32 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/utils/ErrorHandling.java 24 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/utils/FunctionsUtil.java 16 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/validation/JobDetailsValidator.java 45 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/validation/JobValidator.java 49 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/validation/RecipientInstanceValidator.java 23 jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/validation/RecipientValidatorProvider.java 23 jobs-service/jobs-service-common/src/main/resources/META-INF/beans.xml 1 jobs-service/jobs-service-infinispan/docker/infinispan/infinispan.xml 31 jobs-service/jobs-service-infinispan/src/main/java/org/kie/kogito/jobs/service/repository/infinispan/InfinispanConfiguration.java 42 jobs-service/jobs-service-infinispan/src/main/java/org/kie/kogito/jobs/service/repository/infinispan/InfinispanInitialized.java 3 jobs-service/jobs-service-infinispan/src/main/java/org/kie/kogito/jobs/service/repository/infinispan/InfinispanJobRepository.java 112 jobs-service/jobs-service-infinispan/src/main/java/org/kie/kogito/jobs/service/repository/infinispan/marshaller/BaseMarshaller.java 31 jobs-service/jobs-service-infinispan/src/main/java/org/kie/kogito/jobs/service/repository/infinispan/marshaller/JobDetailsMarshaller.java 82 jobs-service/jobs-service-infinispan/src/main/java/org/kie/kogito/jobs/service/repository/infinispan/marshaller/MarshallersProducer.java 26 jobs-service/jobs-service-infinispan/src/main/java/org/kie/kogito/jobs/service/repository/infinispan/marshaller/TriggerMarshaller.java 99 jobs-service/jobs-service-infinispan/src/main/resources/META-INF/library.proto 58 jobs-service/jobs-service-inmemory/src/assembly/image-build-zip.xml 15 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/adapter/JobDetailsAdapter.java 200 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/adapter/ScheduledJobAdapter.java 188 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/exception/JobExecutionException.java 15 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/exception/JobServiceException.java 9 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/executor/JobExecutor.java 12 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/executor/JobExecutorResolver.java 5 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/model/JobDetails.java 125 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/model/JobDetailsBuilder.java 113 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/model/JobDetailsContext.java 24 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/model/JobExecutionResponse.java 89 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/model/JobServiceManagementInfo.java 51 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/model/JobStatus.java 8 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/model/ManageableJobHandle.java 39 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/model/Recipient.java 5 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/model/RecipientInstance.java 34 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/model/ScheduledJob.java 191 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/utils/DateUtil.java 38 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/utils/ModelUtil.java 37 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/validation/RecipientValidator.java 6 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/validation/ValidationException.java 9 jobs-service/jobs-service-internal-api/src/main/java/org/kie/kogito/jobs/service/validation/ValidatorContext.java 14 jobs-service/jobs-service-messaging-http/src/main/java/org/kie/kogito/jobs/service/messaging/http/CloudEventConverter.java 35 jobs-service/jobs-service-messaging-http/src/main/java/org/kie/kogito/jobs/service/messaging/http/HttpReactiveMessagingEventConsumer.java 30 jobs-service/jobs-service-messaging-http/src/main/java/org/kie/kogito/jobs/service/messaging/http/health/knative/KSinkInjectionHealthCheck.java 64 jobs-service/jobs-service-messaging-http/src/main/java/org/kie/kogito/jobs/service/messaging/http/stream/HttpJobStreams.java 51 jobs-service/jobs-service-messaging-http/src/main/java/org/kie/kogito/jobs/service/messaging/http/v2/HttpReactiveMessagingEventConsumer.java 29 jobs-service/jobs-service-messaging-http/src/main/resources/META-INF/beans.xml 1 jobs-service/jobs-service-messaging-kafka/src/main/java/org/kie/kogito/jobs/service/messaging/kafka/CloudEventDeserializer.java 8 jobs-service/jobs-service-messaging-kafka/src/main/java/org/kie/kogito/jobs/service/messaging/kafka/KafkaMessagingHandler.java 29 jobs-service/jobs-service-messaging-kafka/src/main/java/org/kie/kogito/jobs/service/messaging/kafka/KafkaReactiveMessagingEventConsumer.java 30 jobs-service/jobs-service-messaging-kafka/src/main/java/org/kie/kogito/jobs/service/messaging/kafka/stream/KafkaConfiguration.java 60 jobs-service/jobs-service-messaging-kafka/src/main/java/org/kie/kogito/jobs/service/messaging/kafka/stream/KafkaJobStreams.java 38 jobs-service/jobs-service-messaging-kafka/src/main/java/org/kie/kogito/jobs/service/messaging/kafka/v2/KafkaReactiveMessagingEventConsumer.java 30 jobs-service/jobs-service-messaging-kafka/src/main/resources/META-INF/beans.xml 1 jobs-service/jobs-service-mongodb/src/main/java/org/kie/kogito/jobs/service/repository/mongodb/MongoDBJobRepository.java 168 jobs-service/jobs-service-mongodb/src/main/java/org/kie/kogito/jobs/service/repository/mongodb/marshaller/MongoDBJobDetailsMarshaller.java 24 jobs-service/jobs-service-postgresql-common/src/main/java/org/kie/kogito/jobs/service/repository/postgresql/PostgreSqlJobRepository.java 166 jobs-service/jobs-service-postgresql-common/src/main/java/org/kie/kogito/jobs/service/repository/postgresql/PostgreSqlJobServiceManagementRepository.java 80 jobs-service/jobs-service-postgresql-common/src/main/resources/META-INF/beans.xml 1 jobs-service/jobs-service-postgresql-common/src/main/resources/kie-flyway/db/jobs-service/postgresql/V2.0.0__Create_Table.sql 32 jobs-service/jobs-service-postgresql-common/src/main/resources/kie-flyway/db/jobs-service/postgresql/V2.0.1__job_details_increase_job_id_size.sql 4 jobs-service/jobs-service-postgresql-common/src/main/resources/kie-flyway/db/jobs-service/postgresql/V2.0.2__job_details_add_fire_time_col.sql 4 jobs-service/jobs-service-postgresql-common/src/main/resources/kie-flyway/db/jobs-service/postgresql/V2.0.3__Create_Table_Management.sql 6 jobs-service/jobs-service-postgresql-common/src/main/resources/kie-flyway/db/jobs-service/postgresql/V3.0.0__Create_Jobs_Table_V2.sql 20 jobs-service/jobs-service-postgresql-common/src/main/resources/kie-flyway/db/jobs-service/postgresql/V3.0.1__Migrate_Jobs_v1_to_v2_Table.sql 20 jobs-service/jobs-service-postgresql-common/src/main/resources/kie-flyway/db/jobs-service/postgresql/V3.0.2__Add_Execution_Timeout_Col.sql 4 jobs-service/jobs-service-postgresql-common/src/main/resources/kie-flyway/db/jobs-service/postgresql/V3.0.3__Add_Created_Col.sql 7 jobs-service/jobs-service-postgresql/src/assembly/image-build-zip.xml 15 jobs-service/jobs-service-postgresql/src/main/resources/META-INF/beans.xml 1 jobs-service/jobs-service-storage-jpa/src/main/java/org/kie/kogito/jobs/service/repository/jpa/JPAReactiveJobRepository.java 164 jobs-service/jobs-service-storage-jpa/src/main/java/org/kie/kogito/jobs/service/repository/jpa/JPAReactiveJobServiceManagementRepository.java 99 jobs-service/jobs-service-storage-jpa/src/main/java/org/kie/kogito/jobs/service/repository/jpa/converter/JsonBinaryConverter.java 24 jobs-service/jobs-service-storage-jpa/src/main/java/org/kie/kogito/jobs/service/repository/jpa/model/JobDetailsEntity.java 124 jobs-service/jobs-service-storage-jpa/src/main/java/org/kie/kogito/jobs/service/repository/jpa/model/JobServiceManagementEntity.java 35 jobs-service/jobs-service-storage-jpa/src/main/java/org/kie/kogito/jobs/service/repository/jpa/repository/JobDetailsEntityRepository.java 7 jobs-service/jobs-service-storage-jpa/src/main/java/org/kie/kogito/jobs/service/repository/jpa/repository/JobServiceManagementEntityRepository.java 7 jobs-service/jobs-service-storage-jpa/src/main/java/org/kie/kogito/jobs/service/repository/jpa/utils/ReactiveRepositoryHelper.java 23 jobs-service/jobs-service-storage-jpa/src/main/resources/META-INF/beans.xml 1 jobs-service/jobs-service-storage-jpa/src/main/resources/kie-flyway/db/jobs-service/ansi/V2.0.0__Create_Tables.sql 25 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs-service-embedded/deployment/src/main/java/org/kie/kogito/addons/quarkus/jobs/service/embedded/deployment/KogitoAddonsQuarkusJobsServiceEmbeddedProcessor.java 66 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs-service-embedded/runtime/src/main/java/org/kie/kogito/addons/quarkus/jobs/service/embedded/KogitoAddonsQuarkusJobsServiceEmbeddedConfigSource.java 38 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs-service-embedded/runtime/src/main/java/org/kie/kogito/addons/quarkus/jobs/service/embedded/KogitoAddonsQuarkusJobsServiceEmbeddedRuntimeConfig.java 25 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs-service-embedded/runtime/src/main/java/org/kie/kogito/addons/quarkus/jobs/service/embedded/stream/EventPublisherJobStreams.java 77 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs-service-embedded/runtime/src/main/resources/META-INF/beans.xml 1 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs-service-embedded/runtime/src/main/resources/META-INF/quarkus-extension.yaml 15 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/EmbeddedJobExecutor.java 113 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/EmbeddedJobServiceEvent.java 11 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/EmbeddedJobsService.java 58 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/InVMPayloadData.java 25 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/InVMRecipient.java 24 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/JobInVMEventPublisher.java 92 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/resources/META-INF/beans.xml 1