AwsProductReceiverTest

9

tests

0

failures

0

ignored

5.608s

duration

100%

successful

Tests

Test Duration Result
testBroadcastInOrder() 0.072s passed
testBroadcastOutOfOrder() 0.067s passed
testDuplicateProductIdSent() 0.129s passed
testIgnoresBroadcastWhenInCatchupMode() 0.135s passed
testInitialConnection() 4.833s passed
testStartCatchUpWhenConnected() 0.027s passed
testStartCatchUpWhenReconnected() 0.050s passed
testSwitchToBroadcast() 0.131s passed
testThrottleQueue() 0.164s passed

Standard error

May 01, 2025 3:44:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-05-01T15:44:27.909161574Z
May 01, 2025 3:44:27 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=74 ms, count=0
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-05-01T15:44:28.403968502Z
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-05-01T15:44:28.534608554Z
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-05-01T15:44:28.666844218Z
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-05-01T15:44:28.750783950Z
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
May 01, 2025 3:44:28 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] queueing throttled until below 2500 (size=5001, remaining=?)
May 01, 2025 3:44:28 PM gov.usgs.earthquake.distribution.ExecutorListenerNotifier throttleQueues
INFO: [null] done throttling (size = 2499)
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
May 01, 2025 3:44:28 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-05-01T15:44:29.003687515Z
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onClose
INFO: [null] onClose CloseReason[1001,test going away] 2025-05-01T15:44:29.067373213Z
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-05-01T15:44:29.080523317Z
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-05-01T15:44:29.105175033Z
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=1 ms, count=0
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
May 01, 2025 3:44: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:1746114269135, received urn:usgs-product:source_2:type_2:code_2:1746114269135), switching to catch up mode
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] onOpen connection_id=test session 2025-05-01T15:44:29.175321126Z
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onOpen
INFO: [null] Starting catch up
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.ProductsCreatedAfterClient onResponse
INFO: [PCATask] Received products_create_after payload, size=20 bytes, duration=0 ms, count=0
May 01, 2025 3:44:29 PM gov.usgs.earthquake.aws.AwsProductReceiver onProductsCreatedAfter
INFO: [null] Caught up, switching to broadcast