usaguerrilla opened a new issue #55:
URL: https://github.com/apache/pulsar-dotpulsar/issues/55
Producer Executor object gets killed because exception is thrown which isn't
handled by Handle method. This is happening when server gets disconnected.
After it happens producer won't reconnect after service become available again.
Exception:
```
{Name = "PersistenceException" FullName =
"DotPulsar.Exceptions.PersistenceException"}
```
Stack trace:
```
DotPulsar.dll!DotPulsar.Internal.Executor.Execute<DotPulsar.Internal.PulsarApi.CommandSendReceipt>(System.Func<System.Threading.Tasks.Task<DotPulsar.Internal.PulsarApi.CommandSendReceipt>>
func, System.Threading.CancellationToken cancellationToken) Line 123 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.PulsarApi.CommandSendReceipt>.AsyncStateMachineBox<DotPulsar.Internal.Executor.<Execute>d__8<DotPulsar.Internal.PulsarApi.CommandSendReceipt>>.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.FinishSlow(bool
userDelegateExecute) Unknown
System.Private.CoreLib.dll!System.Threading.Tasks.Task.TrySetException(object
exceptionObject) Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.AsyncTaskMethodBuilder<DotPulsar.Internal.PulsarApi.CommandSendReceipt>.SetException(System.Exception
exception) Unknown
[Completed]
DotPulsar.dll!DotPulsar.Internal.ProducerChannel.SendPackage(DotPulsar.Internal.PulsarApi.MessageMetadata
metadata, System.Buffers.ReadOnlySequence<byte> payload,
System.Threading.CancellationToken cancellationToken) Line 109 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<DotPulsar.Internal.PulsarApi.CommandSendReceipt>.AsyncStateMachineBox<DotPulsar.Internal.ProducerChannel.<SendPackage>d__9>.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.__Canon>.TrySetResult(System.__Canon
result) Unknown
System.Private.CoreLib.dll!System.Runtime.CompilerServices.AsyncTaskMethodBuilder<DotPulsar.Internal.PulsarApi.BaseCommand>.SetResult(DotPulsar.Internal.PulsarApi.BaseCommand
result) Unknown
[Completed]
DotPulsar.dll!DotPulsar.Internal.Connection.Send(DotPulsar.Internal.SendPackage
command, System.Threading.CancellationToken cancellationToken) Line 194 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<DotPulsar.Internal.PulsarApi.BaseCommand>.AsyncStateMachineBox<DotPulsar.Internal.Connection.<Send>d__23>.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.System.Threading.IThreadPoolWorkItem.Execute()
Unknown
System.Private.CoreLib.dll!System.Threading.ThreadPoolWorkQueue.Dispatch()
Unknown
[Async Call Stack]
> [Async]
DotPulsar.dll!DotPulsar.Internal.Producer.Send(DotPulsar.MessageMetadata
metadata, System.Buffers.ReadOnlySequence<byte> data,
System.Threading.CancellationToken cancellationToken) Line 117 C#
[Async]
DotPulsar.dll!DotPulsar.Internal.MessageBuilder.Send(System.ReadOnlyMemory<byte>
data, System.Threading.CancellationToken cancellationToken) Line 89 C#
[Async]
PulsarTest.dll!PulsarTest.DotPulsarTest.Send(DotPulsar.Abstractions.IProducer
publisher, int messageSize, long index) Line 199 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:
us...@infra.apache.org
