AwsProductReceiverTest

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

tests
0

failures
0

ignored
5.810s

duration
100%

successful

Tests

Test Duration Result
testBroadcastInOrder() 0.047s passed
testBroadcastOutOfOrder() 0.076s passed
testCatchUpWhenCreatedTimesSame() 0.056s passed
testClearLastBroadcastWhenReconnected() 0.131s passed
testDuplicateProductIdSent() 0.111s passed
testIgnoresBroadcastWhenInCatchupMode() 0.095s passed
testInitialConnection() 4.734s passed
testOnCloseClearsLastBroadcast() 0.022s passed
testOnOpenClearsLastBroadcast() 0.062s passed
testOnReconnectFail() 0.156s passed
testStartCatchUpWhenConnected() 0.028s passed
testStartCatchUpWhenReconnected() 0.039s passed
testSwitchToBroadcast() 0.093s passed
testThrottleQueue() 0.160s passed

Standard error

Feb 23, 2026 4:04:18 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:18.894033440Z
Feb 23, 2026 4:04:18 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=80 ms, count=0
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:19.359072124Z
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:19.395417527Z
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2026-02-23T16:04:19.474042970Z
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:19.482795103Z
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,Closing] 2026-02-23T16:04:19.529455365Z
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onReconnectFail
INFO: [null] onReconnectFail 2026-02-23T16:04:19.677103688Z
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:19.709609363Z
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:19.832815922Z
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=337 bytes, duration=1 ms, count=1
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:19.882958560Z
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:19.984121467Z
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Feb 23, 2026 4:04:19 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:20.031187686Z
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] queueing throttled until below 2500 (size=5001, remaining=?)
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] done throttling (size = 2499)
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:20.263084483Z
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2026-02-23T16:04:20.293590019Z
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:20.297229400Z
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:20.329966614Z
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onBroadcast
INFO: [null] broadcast ids out of sequence (at urn:usgs-product:source_3:type_3:code_3:1771862660373, received urn:usgs-product:source_2:type_2:code_2:1771862660373), switching to catch up mode
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-02-23T16:04:20.410229620Z
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Feb 23, 2026 4:04:20 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast