Gc rework consumers
parent
417c93ef
No related branches found
No related tags found
Showing
- NOTICE 4 additions, 0 deletionsNOTICE
- provider/indexer-gc/docs/gc/README.md 50 additions, 24 deletionsprovider/indexer-gc/docs/gc/README.md
- provider/indexer-gc/pom.xml 1 addition, 1 deletionprovider/indexer-gc/pom.xml
- provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/common/publish/JobStatusJsonSerializer.java 41 additions, 0 deletions.../provider/gcp/common/publish/JobStatusJsonSerializer.java
- provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/common/publish/ReprocessingTaskPublisher.java 74 additions, 58 deletions...rovider/gcp/common/publish/ReprocessingTaskPublisher.java
- provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/common/publish/StatusPublisherImpl.java 11 additions, 12 deletions...exer/provider/gcp/common/publish/StatusPublisherImpl.java
- provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/IndexerOqmMessageReceiver.java 35 additions, 63 deletions...er/gcp/indexing/processing/IndexerOqmMessageReceiver.java
- provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/OqmSubscriberManager.java 3 additions, 1 deletion...rovider/gcp/indexing/processing/OqmSubscriberManager.java
- provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/RecordsChangedMessageReceiver.java 58 additions, 0 deletions...cp/indexing/processing/RecordsChangedMessageReceiver.java
- provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/RecordsChangedSubscriptionConsumer.java 0 additions, 109 deletions...dexing/processing/RecordsChangedSubscriptionConsumer.java
- provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/RepressorMessageReceiver.java 52 additions, 0 deletions...der/gcp/indexing/processing/RepressorMessageReceiver.java
- provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/SchemaChangedMessageReceiver.java 59 additions, 0 deletions...gcp/indexing/processing/SchemaChangedMessageReceiver.java
- provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/TenantSubscriberConfiguration.java 27 additions, 9 deletions...cp/indexing/processing/TenantSubscriberConfiguration.java
- provider/indexer-gc/src/main/java/org/opengroup/osdu/indexer/provider/gcp/indexing/thread/ThreadScope.java 49 additions, 5 deletions...sdu/indexer/provider/gcp/indexing/thread/ThreadScope.java
- provider/indexer-gc/src/main/resources/application.properties 1 addition, 1 deletion...ider/indexer-gc/src/main/resources/application.properties
- provider/indexer-gc/src/main/resources/logback.xml 1 addition, 1 deletionprovider/indexer-gc/src/main/resources/logback.xml
- provider/indexer-gc/src/test/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/IndexerOqmMessageReceiverTest.java 19 additions, 56 deletions...cp/indexing/processing/IndexerOqmMessageReceiverTest.java
- provider/indexer-gc/src/test/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/ReadFromFileUtil.java 38 additions, 0 deletions...er/provider/gcp/indexing/processing/ReadFromFileUtil.java
- provider/indexer-gc/src/test/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/RecordsChangedMessageReceiverTest.java 69 additions, 0 deletions...ndexing/processing/RecordsChangedMessageReceiverTest.java
- provider/indexer-gc/src/test/java/org/opengroup/osdu/indexer/provider/gcp/indexing/processing/RecordsChangedSubscriptionConsumerTest.java 0 additions, 103 deletions...ng/processing/RecordsChangedSubscriptionConsumerTest.java
Loading
Please register or sign in to comment