AwsProductReceiverTest

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

tests
0

failures
0

ignored
5.401s

duration
100%

successful

Tests

Test Duration Result
testBroadcastInOrder() 0.082s passed
testBroadcastOutOfOrder() 0.046s passed
testCatchUpWhenCreatedTimesSame() 0.071s passed
testClearLastBroadcastWhenReconnected() 0.128s passed
testDuplicateProductIdSent() 0.129s passed
testIgnoresBroadcastWhenInCatchupMode() 0.075s passed
testInitialConnection() 4.477s passed
testOnCloseClearsLastBroadcast() 0.024s passed
testOnOpenClearsLastBroadcast() 0.061s passed
testStartCatchUpWhenConnected() 0.018s passed
testStartCatchUpWhenReconnected() 0.044s passed
testSwitchToBroadcast() 0.092s passed
testThrottleQueue() 0.154s passed

Standard error

Jul 30, 2025 9:44:40 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:40.533840062Z
Jul 30, 2025 9:44:40 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:40 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=74 ms, count=0
Jul 30, 2025 9:44:40 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:40 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.031989494Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.083074900Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2025-07-30T21:44:41.160739707Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.167140320Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,Closing] 2025-07-30T21:44:41.203625096Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.239678259Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.377148969Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=337 bytes, duration=0 ms, count=1
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.435680480Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.533202839Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=2 ms, count=0
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.640397074Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] queueing throttled until below 2500 (size=5001, remaining=?)
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] done throttling (size = 2499)
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.826643552Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2025-07-30T21:44:41.849924171Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.854112467Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=2 ms, count=0
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.896787234Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.util.CryptoUtils$Version fromString
WARNING: Using deprecated signature version v1, consider updating to v2
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onBroadcast
INFO: [null] broadcast ids out of sequence (at urn:usgs-product:source_3:type_3:code_3:1753911881926, received urn:usgs-product:source_2:type_2:code_2:1753911881926), switching to catch up mode
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-07-30T21:44:41.939510974Z
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jul 30, 2025 9:44:41 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast