AwsProductReceiverTest

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

tests
0

failures
0

ignored
5.875s

duration
100%

successful

Tests

Test Duration Result
testBroadcastInOrder() 0.065s passed
testBroadcastOutOfOrder() 0.048s passed
testCatchUpWhenCreatedTimesSame() 0.069s passed
testClearLastBroadcastWhenReconnected() 0.112s passed
testDuplicateProductIdSent() 0.128s passed
testIgnoresBroadcastWhenInCatchupMode() 0.194s passed
testInitialConnection() 4.658s passed
testOnCloseClearsLastBroadcast() 0.023s passed
testOnOpenClearsLastBroadcast() 0.082s passed
testOnReconnectFail() 0.158s passed
testStartCatchUpWhenConnected() 0.033s passed
testStartCatchUpWhenReconnected() 0.049s passed
testSwitchToBroadcast() 0.096s passed
testThrottleQueue() 0.160s passed

Standard error

Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:08.419562707Z
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=82 ms, count=0
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:08.861347521Z
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:08.955132245Z
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:08 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2025-09-25T16:32:08.992880819Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:09.004784271Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,Closing] 2025-09-25T16:32:09.054347451Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onReconnectFail
INFO: [null] onReconnectFail 2025-09-25T16:32:09.215471933Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:09.246002169Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:09.390047265Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=337 bytes, duration=0 ms, count=1
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:09.446084867Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:09.543587680Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:09.609740104Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] queueing throttled until below 2500 (size=5001, remaining=?)
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] done throttling (size = 2499)
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:09.930928530Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2025-09-25T16:32:09.978835822Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:09.984763067Z
Sep 25, 2025 4:32:09 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=2 ms, count=0
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:10.025081969Z
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32: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:1758817930048, received urn:usgs-product:source_2:type_2:code_2:1758817930048), switching to catch up mode
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-09-25T16:32:10.068077435Z
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Sep 25, 2025 4:32:10 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast