AwsProductReceiverTest

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

tests
0

failures
0

ignored
6.154s

duration
100%

successful

Tests

Test Duration Result
testBroadcastInOrder() 0.052s passed
testBroadcastOutOfOrder() 0.162s passed
testCatchUpWhenCreatedTimesSame() 0.071s passed
testClearLastBroadcastWhenReconnected() 0.097s passed
testDuplicateProductIdSent() 0.105s passed
testIgnoresBroadcastWhenInCatchupMode() 0.263s passed
testInitialConnection() 4.749s passed
testOnCloseClearsLastBroadcast() 0.027s passed
testOnOpenClearsLastBroadcast() 0.059s passed
testOnReconnectFail() 0.141s passed
testStartCatchUpWhenConnected() 0.033s passed
testStartCatchUpWhenReconnected() 0.110s passed
testSwitchToBroadcast() 0.109s passed
testThrottleQueue() 0.176s passed

Standard error

Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:27.416669211Z
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=97 ms, count=0
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:27.865100711Z
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:27.913246292Z
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2026-01-13T21:36:27.957131702Z
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:27.965185032Z
Jan 13, 2026 9:36:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,Closing] 2026-01-13T21:36:28.011220300Z
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onReconnectFail
INFO: [null] onReconnectFail 2026-01-13T21:36:28.142872524Z
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:28.187578254Z
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:28.317714289Z
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=337 bytes, duration=1 ms, count=1
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:28.372658375Z
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:28.483761748Z
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:28.551892228Z
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] queueing throttled until below 2500 (size=5001, remaining=?)
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] done throttling (size = 2499)
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:28.923277812Z
Jan 13, 2026 9:36:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2026-01-13T21:36:29.036808881Z
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:29.039952287Z
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:29.120568679Z
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onBroadcast
INFO: [null] broadcast ids out of sequence (at urn:usgs-product:source_3:type_3:code_3:1768340189231, received urn:usgs-product:source_2:type_2:code_2:1768340189231), switching to catch up mode
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2026-01-13T21:36:29.272996667Z
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
Jan 13, 2026 9:36:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast