https://github.com/gbif/pipelines/issues/1078

moving data warehouse message to postal service
gbif · Sep 26, 2024 · f464cb0 · f464cb0
1 parent 5bf7233
commit f464cb0
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 37 deletions.
diff --git a/...dinator/tasks/src/main/java/org/gbif/pipelines/common/messaging/DataWarehouseMessage.java b/...dinator/tasks/src/main/java/org/gbif/pipelines/common/messaging/DataWarehouseMessage.java
diff --git a/gbif/coordinator/tasks/src/main/java/org/gbif/pipelines/tasks/balancer/BalancerCallback.java b/gbif/coordinator/tasks/src/main/java/org/gbif/pipelines/tasks/balancer/BalancerCallback.java
@@ -6,19 +6,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.gbif.common.messaging.AbstractMessageCallback;
 import org.gbif.common.messaging.api.MessagePublisher;
-import org.gbif.common.messaging.api.messages.PipelinesAbcdMessage;
-import org.gbif.common.messaging.api.messages.PipelinesBalancerMessage;
-import org.gbif.common.messaging.api.messages.PipelinesDwcaMessage;
-import org.gbif.common.messaging.api.messages.PipelinesEventsHdfsViewMessage;
-import org.gbif.common.messaging.api.messages.PipelinesEventsIndexedMessage;
-import org.gbif.common.messaging.api.messages.PipelinesEventsInterpretedMessage;
-import org.gbif.common.messaging.api.messages.PipelinesFragmenterMessage;
-import org.gbif.common.messaging.api.messages.PipelinesHdfsViewMessage;
-import org.gbif.common.messaging.api.messages.PipelinesIndexedMessage;
-import org.gbif.common.messaging.api.messages.PipelinesInterpretedMessage;
-import org.gbif.common.messaging.api.messages.PipelinesVerbatimMessage;
-import org.gbif.common.messaging.api.messages.PipelinesXmlMessage;
-import org.gbif.pipelines.common.messaging.DataWarehouseMessage;
+import org.gbif.common.messaging.api.messages.*;
 import org.gbif.pipelines.tasks.balancer.handler.*;
 
 /**

diff --git a/...main/java/org/gbif/pipelines/tasks/balancer/handler/PipelinesWarehouseMessageHandler.java b/...main/java/org/gbif/pipelines/tasks/balancer/handler/PipelinesWarehouseMessageHandler.java
@@ -6,8 +6,8 @@
 import lombok.NoArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.gbif.common.messaging.api.MessagePublisher;
+import org.gbif.common.messaging.api.messages.DataWarehouseMessage;
 import org.gbif.common.messaging.api.messages.PipelinesBalancerMessage;
-import org.gbif.pipelines.common.messaging.DataWarehouseMessage;
 
 /**
  * Populates and sends the {@link Pipelines} message, the main method is {@link

diff --git a/...s/src/main/java/org/gbif/pipelines/tasks/occurrences/warehouse/DataWarehouseCallback.java b/...s/src/main/java/org/gbif/pipelines/tasks/occurrences/warehouse/DataWarehouseCallback.java
@@ -6,11 +6,11 @@
 import lombok.extern.slf4j.Slf4j;
 import org.gbif.common.messaging.AbstractMessageCallback;
 import org.gbif.common.messaging.api.MessagePublisher;
+import org.gbif.common.messaging.api.messages.DataWarehouseMessage;
 import org.gbif.common.messaging.api.messages.PipelinesHdfsViewMessage;
 import org.gbif.common.messaging.api.messages.PipelinesInterpretationMessage;
 import org.gbif.pipelines.common.PipelinesVariables;
 import org.gbif.pipelines.common.airflow.AppName;
-import org.gbif.pipelines.common.messaging.DataWarehouseMessage;
 import org.gbif.pipelines.common.process.AirflowSparkLauncher;
 import org.gbif.pipelines.common.process.BeamParametersBuilder;
 import org.gbif.pipelines.common.process.RecordCountReader;