AwsProductReceiverTest

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

tests
0

failures
0

ignored
4.076s

duration
100%

successful

Tests

Test Duration Result
testBroadcastInOrder() 0.042s passed
testBroadcastOutOfOrder() 0.060s passed
testCatchUpWhenCreatedTimesSame() 0.071s passed
testClearLastBroadcastWhenReconnected() 0.080s passed
testDuplicateProductIdSent() 0.080s passed
testIgnoresBroadcastWhenInCatchupMode() 0.098s passed
testInitialConnection() 3.275s passed
testOnCloseClearsLastBroadcast() 0.011s passed
testOnOpenClearsLastBroadcast() 0.025s passed
testOnReconnectFail() 0.067s passed
testStartCatchUpWhenConnected() 0.035s passed
testStartCatchUpWhenReconnected() 0.037s passed
testSwitchToBroadcast() 0.065s passed
testThrottleQueue() 0.130s passed

Standard error

Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:33.165927017Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=57 ms, count=0
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:33.503877886Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:33 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:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:33.535520493Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:33 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:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2025-12-19T20:53:33.580372979Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:33.585116866Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,Closing] 2025-12-19T20:53:33.612401598Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onReconnectFail
INFO: [null] onReconnectFail 2025-12-19T20:53:33.674554617Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:33.697259651Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:33 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:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:33.796913714Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:33 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:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:33.854949420Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:33 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:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:33.918678387Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:33 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:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:33.964238510Z
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:33 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] queueing throttled until below 2500 (size=5001, remaining=?)
Dec 19, 2025 8:53:34 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] done throttling (size = 2499)
Dec 19, 2025 8:53:34 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:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:34.168465597Z
Dec 19, 2025 8:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2025-12-19T20:53:34.200008743Z
Dec 19, 2025 8:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:34.204216202Z
Dec 19, 2025 8:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:34 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:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:34.237138067Z
Dec 19, 2025 8:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:34 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:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onBroadcast
INFO: [null] broadcast ids out of sequence (at urn:usgs-product:source_3:type_3:code_3:1766177614266, received urn:usgs-product:source_2:type_2:code_2:1766177614266), switching to catch up mode
Dec 19, 2025 8:53:34 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:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Dec 19, 2025 8:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-12-19T20:53:34.307899426Z
Dec 19, 2025 8:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Dec 19, 2025 8:53:34 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:53:34 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast