AwsProductReceiverTest

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

tests
0

failures
0

ignored
5.671s

duration
100%

successful

Tests

Test Duration Result
testBroadcastInOrder() 0.043s passed
testBroadcastOutOfOrder() 0.085s passed
testCatchUpWhenCreatedTimesSame() 0.082s passed
testClearLastBroadcastWhenReconnected() 0.103s passed
testDuplicateProductIdSent() 0.114s passed
testIgnoresBroadcastWhenInCatchupMode() 0.184s passed
testInitialConnection() 4.496s passed
testOnCloseClearsLastBroadcast() 0.026s passed
testOnOpenClearsLastBroadcast() 0.078s passed
testOnReconnectFail() 0.128s passed
testStartCatchUpWhenConnected() 0.057s passed
testStartCatchUpWhenReconnected() 0.038s passed
testSwitchToBroadcast() 0.092s passed
testThrottleQueue() 0.145s passed

Standard error

Dec 19, 2025 8:33:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:08.736007488Z
Dec 19, 2025 8:33:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:08 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=91 ms, count=0
Dec 19, 2025 8:33:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:09.146415232Z
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:09.212893696Z
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2025-12-19T20:33:09.264883575Z
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:09.267539083Z
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,Closing] 2025-12-19T20:33:09.310790771Z
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onReconnectFail
INFO: [null] onReconnectFail 2025-12-19T20:33:09.422690943Z
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:09.469435700Z
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:09.583451981Z
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=337 bytes, duration=0 ms, count=1
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:09.662401296Z
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:09.760053367Z
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:09.799372109Z
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] queueing throttled until below 2500 (size=5001, remaining=?)
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] done throttling (size = 2499)
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Dec 19, 2025 8:33:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:10.097171273Z
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2025-12-19T20:33:10.144286512Z
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:10.146657009Z
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:10.184531960Z
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onBroadcast
INFO: [null] broadcast ids out of sequence (at urn:usgs-product:source_3:type_3:code_3:1766176390233, received urn:usgs-product:source_2:type_2:code_2:1766176390233), switching to catch up mode
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:33:10.285433490Z
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Dec 19, 2025 8:33:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast