IProducer.SendAsync method behavior when there is no permission to SEND.

[yashakapkov]

Description

We encountered a situation when a user lost his permision(or hasn't been received yet) to send to a queue.
So, if connection

• is auto recoverable (AutomaticRecoveryEnabled=true, default value) the producer's method SendAsync just capture the current thread indefinetely,
• is not auto recoverable the producer's method SendAsync throws an exception with "The Producer was closed." message, but without any clue of why has it happened. The reason was found in a field ((ActiveMQ.Artemis.Client.ProducerBase)producer)._senderLink.Error.Description

Expected behavior

In both cases it would be great to have an exception with clear reason why this producer cannot be used.

ArtemisNetClient nuget version is 2.15.0

[yashakapkov]

One more suggestion. If something happened in sending or consuming process, if connection in default(AutomaticRecoveryEnabled=true) mode, it would be great have warnigns in logs.

[Havret]

Hi @yashakapkov,

1. Please check version 2.16.0. It was fixed as part of issue Unauthorized Producer Creation Attempts Cause Log Flooding and Unresponsiveness #477.
2. We have some logs, but most of them use the trace log level, which is probably why you didn't see it. I think it makes sense to increase the logging level to info for events like these:
   

   dotnet-activemq-artemis-client/src/ArtemisNetClient/AutoRecovering/AutoRecoveringConsumer.cs

   Lines 161 to 181 in 746f82e

   	private static class Log
   	{
   	private static readonly Action<ILogger, Exception> _retryingConsumeAsync = LoggerMessage.Define(
   	LogLevel.Trace,
   	0,
   	"Retrying receive after Consumer reestablished.");
   	private static readonly Action<ILogger, Exception> _consumerRecovered = LoggerMessage.Define(
   	LogLevel.Trace,
   	0,
   	"Consumer recovered.");
   	private static readonly Action<ILogger, Exception> _consumerSuspended = LoggerMessage.Define(
   	LogLevel.Trace,
   	0,
   	"Consumer suspended.");
   	private static readonly Action<ILogger, Exception> _consumerResumed = LoggerMessage.Define(
   	LogLevel.Trace,
   	0,
   	"Consumer resumed.");

I've extended logging in 2.17.0-preview1. Please let me know if you need anything else.

Best regards,
Havret

[yashakapkov]

Hello, @Havret.

I should have tried with newer version before creating the issue. With 2.16.0 it works as we expect.
Sorry for taking your time and thanks.

Sincerely,
Yakov Kapkov