shared-dg05-coffeeQuokka/hgzero
1
0
Fork 0
mirror of https://github.com/hwanny1128/HGZero.git synced 2026-06-13 00:09:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

resolve conflict

Browse Source
This commit is contained in:
djeon
2025-10-24 09:40:26 +09:00
parent 3d7844f758 fea95e8ed7
commit d2a92bcc20
45 changed files with 9189 additions and 3002 deletions
Download Patch File Download Diff File Expand all files Collapse all files
notification/bin/main/com/unicorn/hgzero/notification/config/BlobStorageConfig.class
BIN
View File
Binary file not shown.
notification/bin/main/com/unicorn/hgzero/notification/config/EventHubConfig.class
BIN
View File
Binary file not shown.
notification/bin/main/com/unicorn/hgzero/notification/config/RetryConfig.class
BIN
View File
Binary file not shown.
notification/bin/main/com/unicorn/hgzero/notification/dto/response/NotificationResponse$RecipientInfo$RecipientInfoBuilder.class
BIN
View File
Binary file not shown.
notification/bin/main/com/unicorn/hgzero/notification/dto/response/NotificationResponse$RecipientInfo.class
BIN
View File
Binary file not shown.
notification/bin/main/com/unicorn/hgzero/notification/dto/response/NotificationResponse.class
BIN
View File
Binary file not shown.
notification/bin/main/com/unicorn/hgzero/notification/event/EventHandler.class
BIN
View File
Binary file not shown.
notification/bin/main/com/unicorn/hgzero/notification/event/processor/EventProcessorService.class
BIN
View File
Binary file not shown.
notification/bin/main/com/unicorn/hgzero/notification/service/EmailClient.class
BIN
View File
Binary file not shown.
notification/logs/notification-service.log
+135
View File
@@ -2827,3 +2827,138 @@ Time:2025-10-24T00:38:00.5177911Z</Message></Error>"
2025-10-24 09:38:00 [reactor-executor-4] INFO c.a.m.e.i.ManagementChannel - Management endpoint state: ACTIVE
2025-10-24 09:38:00 [reactor-executor-4] INFO c.a.c.a.i.AmqpChannelProcessor - {"az.sdk.message":"Channel is now active.","connectionId":"MF_ce2579_1761266220542","entityPath":"$management"}
2025-10-24 09:38:00 [reactor-executor-4] INFO c.a.c.a.i.h.ReceiveLinkHandler2 - {"az.sdk.message":"onLinkRemoteOpen","connectionId":"MF_ce2579_1761266220542","entityPath":"$management","linkName":"mgmt:receiver","remoteSource":"Source{address='$management', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=null, capabilities=null}"}
2025-10-24 09:38:30 [pool-3-thread-1] INFO c.a.m.e.PartitionBasedLoadBalancer - {"az.sdk.message":"Starting load balancer.","ownerId":"a1d4531a-9fcd-478a-9b21-71eadf7b8e16"}
2025-10-24 09:38:30 [pool-3-thread-1] INFO c.a.m.e.PartitionBasedLoadBalancer - {"az.sdk.message":"Getting partitions from Event Hubs service.","entityPath":"notification-events"}
2025-10-24 09:38:30 [reactor-http-nio-1] WARN c.a.m.e.PartitionBasedLoadBalancer - Load balancing for event processor failed.
Status code 404, "<?xml version="1.0" encoding="utf-8"?><Error><Code>ContainerNotFound</Code><Message>The specified container does not exist.
RequestId:3c797c91-e01e-0048-727e-44bd09000000
Time:2025-10-24T00:38:30.5182879Z</Message></Error>"
2025-10-24 09:38:30 [reactor-http-nio-1] ERROR c.u.h.n.config.EventHubConfig - 이벤트 처리 오류 발생 - PartitionId: NONE, ErrorType: BlobStorageException
com.azure.storage.blob.models.BlobStorageException: Status code 404, "<?xml version="1.0" encoding="utf-8"?><Error><Code>ContainerNotFound</Code><Message>The specified container does not exist.
RequestId:3c797c91-e01e-0048-727e-44bd09000000
Time:2025-10-24T00:38:30.5182879Z</Message></Error>"
at java.base/java.lang.invoke.MethodHandle.invokeWithArguments(MethodHandle.java:733)
at com.azure.core.implementation.MethodHandleReflectiveInvoker.invokeWithArguments(MethodHandleReflectiveInvoker.java:39)
at com.azure.core.implementation.http.rest.ResponseExceptionConstructorCache.invoke(ResponseExceptionConstructorCache.java:53)
at com.azure.core.implementation.http.rest.RestProxyBase.instantiateUnexpectedException(RestProxyBase.java:411)
at com.azure.core.implementation.http.rest.AsyncRestProxy.lambda$ensureExpectedStatus$1(AsyncRestProxy.java:132)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:113)
at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2571)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:171)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2367)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2241)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:96)
at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:55)
at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129)
at reactor.core.publisher.FluxHide$SuppressFuseableSubscriber.onNext(FluxHide.java:137)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129)
at reactor.core.publisher.FluxHide$SuppressFuseableSubscriber.onNext(FluxHide.java:137)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:158)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:158)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:158)
at reactor.core.publisher.Operators$MonoInnerProducerBase.complete(Operators.java:2864)
at reactor.core.publisher.MonoSingle$SingleSubscriber.onComplete(MonoSingle.java:180)
at reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onComplete(MonoFlatMapMany.java:261)
at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126)
at reactor.core.publisher.MonoUsing$MonoUsingSubscriber.onNext(MonoUsing.java:232)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74)
at reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:129)
at reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:224)
at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onNext(FluxDoFinally.java:113)
at reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onNext(FluxHandleFuseable.java:194)
at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107)
at reactor.core.publisher.Operators$BaseFluxToMonoOperator.completePossiblyEmpty(Operators.java:2097)
at reactor.core.publisher.MonoCollectList$MonoCollectListSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260)
at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
at reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:415)
at reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:446)
at reactor.netty.channel.ChannelOperations.terminate(ChannelOperations.java:500)
at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:793)
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:114)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at com.azure.core.http.netty.implementation.AzureSdkHandler.channelRead(AzureSdkHandler.java:224)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1475)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1338)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1387)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:530)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:469)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:290)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1407)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:918)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:1583)
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.SendLinkHandler - {"az.sdk.message":"onLinkRemoteClose","connectionId":"MF_ce2579_1761266220542","errorCondition":"amqp:connection:forced","errorDescription":"The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30","linkName":"mgmt:sender","entityPath":"$management"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.SendLinkHandler - {"az.sdk.message":"Local link state is not closed.","connectionId":"MF_ce2579_1761266220542","linkName":"mgmt:sender","entityPath":"$management","state":"ACTIVE"}
2025-10-24 09:38:30 [reactor-executor-4] WARN c.a.c.a.i.RequestResponseChannel - {"az.sdk.message":"Error in SendLinkHandler. Disposing unconfirmed sends.","exception":"The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30, errorContext[NAMESPACE: hgzero-eventhub-ns.servicebus.windows.net. ERROR CONTEXT: N/A, PATH: $management, REFERENCE_ID: mgmt:sender, LINK_CREDIT: 99]","connectionId":"MF_ce2579_1761266220542","linkName":"mgmt"}
2025-10-24 09:38:30 [reactor-executor-4] ERROR c.a.m.e.i.ManagementChannel - Exception occurred:
The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30, errorContext[NAMESPACE: hgzero-eventhub-ns.servicebus.windows.net. ERROR CONTEXT: N/A, PATH: $management, REFERENCE_ID: mgmt:sender, LINK_CREDIT: 99]
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.AmqpChannelProcessor - {"az.sdk.message":"Upstream connection publisher was completed. Terminating processor.","connectionId":"MF_ce2579_1761266220542","entityPath":"$management"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.AmqpChannelProcessor - {"az.sdk.message":"Transient error occurred. Retrying.","exception":"The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30, errorContext[NAMESPACE: hgzero-eventhub-ns.servicebus.windows.net. ERROR CONTEXT: N/A, PATH: $management, REFERENCE_ID: mgmt:sender, LINK_CREDIT: 99]","connectionId":"MF_ce2579_1761266220542","entityPath":"$management","tryCount":0,"intervalMs":1800}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.h.ReceiveLinkHandler2 - {"az.sdk.message":"onLinkRemoteClose","connectionId":"MF_ce2579_1761266220542","errorCondition":"amqp:connection:forced","errorDescription":"The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30","linkName":"mgmt:receiver","entityPath":"$management"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.h.ReceiveLinkHandler2 - {"az.sdk.message":"Local link state is not closed.","connectionId":"MF_ce2579_1761266220542","linkName":"mgmt:receiver","entityPath":"$management","state":"ACTIVE"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.SessionHandler - {"az.sdk.message":"onSessionRemoteClose","connectionId":"MF_ce2579_1761266220542","errorCondition":"amqp:connection:forced","errorDescription":"The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30","sessionName":"mgmt-session"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.SessionHandler - {"az.sdk.message":"onSessionRemoteClose closing a local session.","connectionId":"MF_ce2579_1761266220542","errorCondition":"amqp:connection:forced","errorDescription":"The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30","sessionName":"mgmt-session"}
2025-10-24 09:38:30 [reactor-executor-4] ERROR reactor.core.publisher.Operators - Operator called default onErrorDropped
reactor.core.Exceptions$ErrorCallbackNotImplemented: com.azure.core.amqp.exception.AmqpException: onSessionRemoteClose connectionId[MF_ce2579_1761266220542], entityName[mgmt-session] condition[Error{condition=amqp:connection:forced, description='The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30', info=null}], errorContext[NAMESPACE: hgzero-eventhub-ns.servicebus.windows.net. ERROR CONTEXT: N/A, PATH: mgmt-session]
Caused by: com.azure.core.amqp.exception.AmqpException: onSessionRemoteClose connectionId[MF_ce2579_1761266220542], entityName[mgmt-session] condition[Error{condition=amqp:connection:forced, description='The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30', info=null}], errorContext[NAMESPACE: hgzero-eventhub-ns.servicebus.windows.net. ERROR CONTEXT: N/A, PATH: mgmt-session]
at com.azure.core.amqp.implementation.ExceptionUtil.toException(ExceptionUtil.java:90)
at com.azure.core.amqp.implementation.handler.SessionHandler.onSessionRemoteClose(SessionHandler.java:157)
at org.apache.qpid.proton.engine.BaseHandler.handle(BaseHandler.java:152)
at org.apache.qpid.proton.engine.impl.EventImpl.dispatch(EventImpl.java:108)
at org.apache.qpid.proton.reactor.impl.ReactorImpl.dispatch(ReactorImpl.java:324)
at org.apache.qpid.proton.reactor.impl.ReactorImpl.process(ReactorImpl.java:291)
at com.azure.core.amqp.implementation.ReactorExecutor.run(ReactorExecutor.java:91)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1583)
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.ReactorConnection - {"az.sdk.message":"Error occurred. Removing and disposing session","exception":"onSessionRemoteClose connectionId[MF_ce2579_1761266220542], entityName[mgmt-session] condition[Error{condition=amqp:connection:forced, description='The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30', info=null}], errorContext[NAMESPACE: hgzero-eventhub-ns.servicebus.windows.net. ERROR CONTEXT: N/A, PATH: mgmt-session]","connectionId":"MF_ce2579_1761266220542","sessionName":"mgmt-session"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.ConnectionHandler - {"az.sdk.message":"onConnectionRemoteClose","connectionId":"MF_ce2579_1761266220542","errorCondition":"amqp:connection:forced","errorDescription":"The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30","hostName":"hgzero-eventhub-ns.servicebus.windows.net"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.ConnectionHandler - {"az.sdk.message":"onTransportClosed","connectionId":"MF_ce2579_1761266220542","hostName":"hgzero-eventhub-ns.servicebus.windows.net"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.GlobalIOHandler - {"az.sdk.message":"onTransportClosed","connectionId":"MF_ce2579_1761266220542","hostName":"hgzero-eventhub-ns.servicebus.windows.net"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.ConnectionHandler - {"az.sdk.message":"onConnectionLocalClose","connectionId":"MF_ce2579_1761266220542","hostName":"hgzero-eventhub-ns.servicebus.windows.net"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.ConnectionHandler - {"az.sdk.message":"onConnectionUnbound","connectionId":"MF_ce2579_1761266220542","hostName":"hgzero-eventhub-ns.servicebus.windows.net","state":"CLOSED","remoteState":"CLOSED"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.ReactorConnection - {"az.sdk.message":"Disposing of ReactorConnection.","connectionId":"MF_ce2579_1761266220542","isTransient":false,"isInitiatedByClient":false,"shutdownMessage":"Connection handler closed."}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.m.e.i.EventHubConnectionProcessor - {"az.sdk.message":"Channel is closed. Requesting upstream.","entityPath":"notification-events"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.m.e.i.EventHubConnectionProcessor - {"az.sdk.message":"Connection not requested, yet. Requesting one.","entityPath":"notification-events"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.m.e.EventHubClientBuilder - {"az.sdk.message":"Emitting a single connection.","connectionId":"MF_a542ff_1761266310622"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.m.e.i.EventHubConnectionProcessor - {"az.sdk.message":"Setting next AMQP channel.","entityPath":"notification-events"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.SendLinkHandler - {"az.sdk.message":"onLinkFinal","connectionId":"MF_ce2579_1761266220542","linkName":"mgmt:sender","entityPath":"$management"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.h.ReceiveLinkHandler2 - {"az.sdk.message":"onLinkFinal","connectionId":"MF_ce2579_1761266220542","linkName":"mgmt:receiver","entityPath":"$management"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.SessionHandler - {"az.sdk.message":"onSessionFinal.","connectionId":"MF_ce2579_1761266220542","errorCondition":"amqp:connection:forced","errorDescription":"The connection was closed by container '59380e37ef814b1a82372fe5b86fd2ec_G26' because it did not have any active links in the past 60000 milliseconds. TrackingId:59380e37ef814b1a82372fe5b86fd2ec_G26, SystemTracker:gateway5, Timestamp:2025-10-24T00:38:30","sessionName":"mgmt-session"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.handler.ConnectionHandler - {"az.sdk.message":"onConnectionFinal","connectionId":"MF_ce2579_1761266220542","hostName":"hgzero-eventhub-ns.servicebus.windows.net"}
2025-10-24 09:38:30 [reactor-executor-4] INFO c.a.c.a.i.ReactorConnection - {"az.sdk.message":"Closing executor.","connectionId":"MF_ce2579_1761266220542"}