from: mantis-source-jobs
to: mantis-connectors
evidence:
 - file: "mantis-source-jobs/mantis-source-job-publish/src/main/java/io/mantisrx/sourcejobs/publish/PushRequestEventSourceJob.java"
   contains "import io.mantisrx.connector.publish.core.QueryRegistry;"

from: mantis-source-jobs
to: mantis-connectors
evidence:
 - file: "mantis-source-jobs/mantis-source-job-publish/src/main/java/io/mantisrx/sourcejobs/publish/core/RequestPreProcessor.java"
   contains "import io.mantisrx.connector.publish.core.QueryRegistry;"

from: mantis-source-jobs
to: mantis-connectors
evidence:
 - file: "mantis-source-jobs/mantis-source-job-publish/src/main/java/io/mantisrx/sourcejobs/publish/core/RequestPostProcessor.java"
   contains "import io.mantisrx.connector.publish.core.QueryRegistry;"

from: mantis-source-jobs
to: mantis-connectors
evidence:
 - file: "mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/QueryableKafkaSourceJob.java"
   contains "import io.mantisrx.connector.kafka.KafkaSourceParameters;"

from: mantis-source-jobs
to: mantis-connectors
evidence:
 - file: "mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/AbstractAckableTaggingStage.java"
   contains "import io.mantisrx.connector.kafka.KafkaAckable;"

from: mantis-source-jobs
to: mantis-connectors
evidence:
 - file: "mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/CustomizedAutoAckTaggingStage.java"
   contains "import io.mantisrx.connector.kafka.KafkaAckable;"

from: mantis-source-jobs
to: mantis-connectors
evidence:
 - file: "mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/AutoAckTaggingStage.java"
   contains "import io.mantisrx.connector.kafka.KafkaAckable;"