Skip to content

Commit 7e9efd9

Browse files
committed
udate event notification
1 parent 840ed8f commit 7e9efd9

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/main/java/com/uid2/optout/Main.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -323,7 +323,8 @@ public void run(String[] args) throws IOException {
323323
ICloudStorage fsSqsDroppedRequests = CloudUtils.createStorage(optoutBucketDroppedRequests, this.config);
324324

325325
// deploy sqs log producer
326-
OptOutSqsLogProducer sqsLogProducer = new OptOutSqsLogProducer(this.config, fsSqs, fsSqsDroppedRequests, sqsCs, Const.Event.DeltaProduce, null);
326+
// fires DeltaProduced (notification) not DeltaProduce (trigger) to avoid triggering old producer
327+
OptOutSqsLogProducer sqsLogProducer = new OptOutSqsLogProducer(this.config, fsSqs, fsSqsDroppedRequests, sqsCs, Const.Event.DeltaProduced, null);
327328
futs.add(this.deploySingleInstance(sqsLogProducer));
328329

329330
LOGGER.info("sqs log producer deployed, bucket={}, folder={}",
@@ -366,7 +367,7 @@ public void run(String[] args) throws IOException {
366367
});
367368
}
368369

369-
370+
370371
private Future uploadLastDelta(OptOutCloudSync cs, OptOutCloudSync uploadCs, OptOutLogProducer logProducer, String eventRefresh) {
371372
final String deltaLocalPath;
372373
try {

0 commit comments

Comments
 (0)