usaguerrilla commented on issue #56:
URL: https://github.com/apache/pulsar-dotpulsar/issues/56#issuecomment-690628136
So consumer is trying to reconnect during server shutting down (or crash)
and it gets this:
```Unable to read data from the transport connection: An established
connection was aborted by the software in your host machine```
Exception type is: System.IO.IOException
This isn't an action which is started by the client. It is internal code.
This is just an example. Need to think about it.
```
DotPulsar.dll!DotPulsar.Internal.Process.Handle(DotPulsar.Internal.Abstractions.IEvent
e) Line 51 C#
DotPulsar.dll!DotPulsar.Internal.ProcessManager.Register(DotPulsar.Internal.Abstractions.IEvent
e) Line 79 C#
> DotPulsar.dll!DotPulsar.Internal.Executor.Handle(System.Exception
exception, System.Threading.CancellationToken cancellationToken) Line 176 C#
DotPulsar.dll!DotPulsar.Internal.Executor.Execute<DotPulsar.Internal.Abstractions.IConsumerChannel>(System.Func<System.Threading.Tasks.ValueTask<DotPulsar.Internal.Abstractions.IConsumerChannel>>
func, System.Threading.CancellationToken cancellationToken) Line 155 C#
[Resuming Async Method]
System.Private.CoreLib.dll!System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext
executionContext, System.Threading.ContextCallback callback, object state)
Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.AsyncTaskMethodBuilder<DotPulsar.Internal.Abstractions.IConsumerChannel>.AsyncStateMachineBox<DotPulsar.Internal.Executor.<Execute>d__9<DotPulsar.Internal.Abstractions.IConsumerChannel>>.MoveNext(System.Threading.Thread
threadPoolThread) Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.TaskAwaiter.OutputWaitEtwEvents.AnonymousMethod__12_0(System.Action
innerContinuation, System.Threading.Tasks.Task innerTask) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.AwaitTaskContinuation.RunOrScheduleAction(System.Action
action, bool allowInlining) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.Task.RunContinuations(object
continuationObject) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.Task<bool>.TrySetResult(bool
result) Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.AsyncValueTaskMethodBuilder<bool>.SetResult(bool
result) Unknown
[Completed]
DotPulsar.dll!DotPulsar.Internal.Executor.Handle(System.Exception exception,
System.Threading.CancellationToken cancellationToken) Line 181 C#
System.Private.CoreLib.dll!System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext
executionContext, System.Threading.ContextCallback callback, object state)
Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.AsyncTaskMethodBuilder<bool>.AsyncStateMachineBox<DotPulsar.Internal.Executor.<Handle>d__10>.MoveNext(System.Threading.Thread
threadPoolThread) Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.TaskAwaiter.OutputWaitEtwEvents.AnonymousMethod__12_0(System.Action
innerContinuation, System.Threading.Tasks.Task innerTask) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.AwaitTaskContinuation.RunOrScheduleAction(System.Action
action, bool allowInlining) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.Task.RunContinuations(object
continuationObject) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.Task<System.Threading.Tasks.VoidTaskResult>.TrySetResult(System.Threading.Tasks.VoidTaskResult
result) Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.AsyncValueTaskMethodBuilder.SetResult()
Unknown
[Completed]
DotPulsar.dll!DotPulsar.Internal.ExceptionHandlerPipeline.OnException(DotPulsar.ExceptionContext
exceptionContext) Line 38 C#
System.Private.CoreLib.dll!System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext
executionContext, System.Threading.ContextCallback callback, object state)
Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.AsyncTaskMethodBuilder<System.Threading.Tasks.VoidTaskResult>.AsyncStateMachineBox<DotPulsar.Internal.ExceptionHandlerPipeline.<OnException>d__2>.MoveNext(System.Threading.Thread
threadPoolThread) Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.TaskAwaiter.OutputWaitEtwEvents.AnonymousMethod__12_0(System.Action
innerContinuation, System.Threading.Tasks.Task innerTask) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.AwaitTaskContinuation.RunOrScheduleAction(System.Action
action, bool allowInlining) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.Task.RunContinuations(object
continuationObject) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.Task<System.Threading.Tasks.VoidTaskResult>.TrySetResult(System.Threading.Tasks.VoidTaskResult
result) Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.AsyncValueTaskMethodBuilder.SetResult()
Unknown
[Completed]
DotPulsar.dll!DotPulsar.Internal.DefaultExceptionHandler.OnException(DotPulsar.ExceptionContext
exceptionContext) Line 41 C#
System.Private.CoreLib.dll!System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext
executionContext, System.Threading.ContextCallback callback, object state)
Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.AsyncTaskMethodBuilder<System.Threading.Tasks.VoidTaskResult>.AsyncStateMachineBox<DotPulsar.Internal.DefaultExceptionHandler.<OnException>d__2>.MoveNext(System.Threading.Thread
threadPoolThread) Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.TaskAwaiter.OutputWaitEtwEvents.AnonymousMethod__12_0(System.Action
innerContinuation, System.Threading.Tasks.Task innerTask) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.AwaitTaskContinuation.RunOrScheduleAction(System.Action
action, bool allowInlining) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.Task.RunContinuations(object
continuationObject) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.Task.TrySetResult()
Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.Task.DelayPromise.CompleteTimedOut()
Unknown
System.Private.CoreLib.dll!System.Threading.TimerQueueTimer.CallCallback(bool
isThreadPool) Unknown
System.Private.CoreLib.dll!System.Threading.TimerQueueTimer.Fire(bool
isThreadPool) Unknown
System.Private.CoreLib.dll!System.Threading.TimerQueue.FireNextTimers()
Unknown
[Async Call Stack]
[Async]
DotPulsar.dll!DotPulsar.Internal.ConsumerChannelFactory.Create(System.Threading.CancellationToken
cancellationToken) Line 67 C#
[Async] DotPulsar.dll!DotPulsar.Internal.ConsumerProcess.SetupChannel()
Line 87 C#
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
