AwsProductReceiverTest

all > gov.usgs.earthquake.aws > AwsProductReceiverTest
14

tests
0

failures
0

ignored
5.566s

duration
100%

successful

Tests

Test Duration Result
testBroadcastInOrder() 0.086s passed
testBroadcastOutOfOrder() 0.104s passed
testCatchUpWhenCreatedTimesSame() 0.114s passed
testClearLastBroadcastWhenReconnected() 0.090s passed
testDuplicateProductIdSent() 0.089s passed
testIgnoresBroadcastWhenInCatchupMode() 0.089s passed
testInitialConnection() 4.270s passed
testOnCloseClearsLastBroadcast() 0.031s passed
testOnOpenClearsLastBroadcast() 0.047s passed
testOnReconnectFail() 0.179s passed
testStartCatchUpWhenConnected() 0.084s passed
testStartCatchUpWhenReconnected() 0.042s passed
testSwitchToBroadcast() 0.181s passed
testThrottleQueue() 0.160s passed

Standard error

Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:49.187296940Z
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=59 ms, count=0
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:49 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:49.530361753Z
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:49.565930539Z
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2025-09-18T21:19:49.610180008Z
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:49.617679437Z
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,Closing] 2025-09-18T21:19:49.668512133Z
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onReconnectFail
INFO: [null] onReconnectFail 2025-09-18T21:19:49.835457583Z
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:49.871680369Z
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=4 ms, count=0
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:49 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:49 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:49 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:49 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:49 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:49 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:49.993897037Z
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=337 bytes, duration=0 ms, count=1
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:50.098041455Z
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:50.286128078Z
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:50.365251296Z
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] queueing throttled until below 2500 (size=5001, remaining=?)
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] done throttling (size = 2499)
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:50.572905778Z
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2025-09-18T21:19:50.611780193Z
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:50.614331936Z
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:50.660821828Z
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onBroadcast
INFO: [null] broadcast ids out of sequence (at urn:usgs-product:source_3:type_3:code_3:1758230390714, received urn:usgs-product:source_2:type_2:code_2:1758230390714), switching to catch up mode
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-18T21:19:50.798164715Z
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 18, 2025 9:19:50 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast