|
4 | 4 | import com.uid2.shared.cloud.ICloudStorage; |
5 | 5 | import com.uid2.shared.optout.OptOutCollection; |
6 | 6 | import com.uid2.shared.optout.OptOutEntry; |
| 7 | +import com.uid2.optout.sqs.SqsMessageOperations; |
7 | 8 | import com.uid2.optout.Const; |
8 | 9 | import io.vertx.core.json.JsonArray; |
9 | 10 | import io.vertx.core.json.JsonObject; |
@@ -1538,8 +1539,8 @@ void testCalculateStatus_delayedProcessingFromQueueAttributesOnly() throws Excep |
1538 | 1539 | // QueueAttributes: 0 visible, 600 invisible (other consumers), 0 delayed |
1539 | 1540 | // Since we read 1 message, otherConsumers = 600 - 1 = 599 |
1540 | 1541 | // Total = 10 (delta) + 1 (our message) + 599 (other consumers) = 610 >= 500 threshold |
1541 | | - com.uid2.optout.sqs.SqsMessageOperations.QueueAttributes queueAttributes = |
1542 | | - new com.uid2.optout.sqs.SqsMessageOperations.QueueAttributes(0, 600, 0); |
| 1542 | + SqsMessageOperations.QueueAttributes queueAttributes = |
| 1543 | + new SqsMessageOperations.QueueAttributes(0, 600, 0); |
1543 | 1544 |
|
1544 | 1545 | OptOutTrafficCalculator.TrafficStatus status = calculator.calculateStatus(sqsMessages, queueAttributes); |
1545 | 1546 |
|
@@ -1578,8 +1579,8 @@ void testCalculateStatus_delayedProcessingFromBothQueueAndMessages() throws Exce |
1578 | 1579 | // QueueAttributes: 0 visible, 450 invisible (200 ours + 250 others), 0 delayed |
1579 | 1580 | // otherConsumers = 450 - 200 = 250 |
1580 | 1581 | // Total = 100 (delta) + 200 (our messages) + 250 (other consumers) = 550 >= 500 threshold |
1581 | | - com.uid2.optout.sqs.SqsMessageOperations.QueueAttributes queueAttributes = |
1582 | | - new com.uid2.optout.sqs.SqsMessageOperations.QueueAttributes(0, 450, 0); |
| 1582 | + SqsMessageOperations.QueueAttributes queueAttributes = |
| 1583 | + new SqsMessageOperations.QueueAttributes(0, 450, 0); |
1583 | 1584 |
|
1584 | 1585 | OptOutTrafficCalculator.TrafficStatus status = calculator.calculateStatus(sqsMessages, queueAttributes); |
1585 | 1586 |
|
|
0 commit comments