@@ -73,6 +73,7 @@ public class OptOutServiceVerticle extends AbstractVerticle {
7373 private final String sqsQueueUrl ;
7474 private final boolean sqsEnabled ;
7575 private final int sqsMaxQueueSize ;
76+ private final String podName ;
7677
7778 public OptOutServiceVerticle (Vertx vertx ,
7879 IAuthorizableProvider clientKeyProvider ,
@@ -122,6 +123,7 @@ public OptOutServiceVerticle(Vertx vertx,
122123 this .sqsEnabled = jsonConfig .getBoolean (Const .Config .OptOutSqsEnabledProp , false );
123124 this .sqsQueueUrl = jsonConfig .getString (Const .Config .OptOutSqsQueueUrlProp );
124125 this .sqsMaxQueueSize = jsonConfig .getInteger (Const .Config .OptOutSqsMaxQueueSizeProp , 0 ); // 0 = no limit
126+ this .podName = jsonConfig .getString ("POD_NAME" );
125127
126128 SqsClient tempSqsClient = null ;
127129 if (this .sqsEnabled ) {
@@ -296,6 +298,9 @@ private void handleReplicate(RoutingContext routingContext) {
296298 }
297299
298300 HttpServerRequest req = routingContext .request ();
301+
302+ LOGGER .info ("recieved replicate request, replica={}, traceId={}" , this .podName , req .getHeader (UID_TRACE_ID ));
303+
299304 MultiMap params = req .params ();
300305 String identityHash = req .getParam (IDENTITY_HASH );
301306 String advertisingId = req .getParam (ADVERTISING_ID );
@@ -318,6 +323,7 @@ private void handleReplicate(RoutingContext routingContext) {
318323 }
319324 else {
320325 try {
326+ LOGGER .info ("pod {} sending optout/write to remote endpoints" , this .podName );
321327 this .replicaWriteClient .get (r -> {
322328 r .setQueryParam (IDENTITY_HASH , identityHash );
323329 r .setQueryParam (ADVERTISING_ID , advertisingId );
0 commit comments