MQTT Broker not receiving message after certain messages using MQTTnet Client

[ElaJegen]

I am using MQTTnet Client in my .Net Application. and connecting to mosquitto broker version 2.0.12. My client connects using MqttProtocolVersion5.

Here is my MqttClientOptionBuilder: in ConnectAsync():

var messageBuilder = new MqttClientOptionsBuilder()

                        .WithProtocolVersion(MQTTnet.Formatter.MqttProtocolVersion.V500)

                        .WithClientId(ClientId)

                        .WithCredentials(BrokerUserName, BrokerPwd)

                        .WithConnectionUri(_mqttUri)

                        .WithKeepAlivePeriod(TimeSpan.FromSeconds(KeepAlivePeroid))

                        .WithTimeout(TimeSpan.FromSeconds(36000))

                        .WithMaximumPacketSize(UInt32.MaxValue)

                        .WithReceiveMaximum(ushort.MaxValue)                       

                        .WithCleanSession();

await _mqttClient1.ConnectAsync(options);   

My PublishAsycn():

var messageBuilder = new MqttApplicationMessageBuilder()

                        .WithTopic(publishTopic)

                        .WithPayload(payload)

                        .WithQualityOfServiceLevel(MqttQualityOfServiceLevel.AtMostOnce)

                        .WithRetainFlag(retain)

                        .Build();

var result = await _mqttClient1.PublishAsync(messageBuilder);

Issue:

Publish works fine but mosquitto broker does not receive more than 100 messages.

The only mosquitto broker setting I have is:

• listener 1883

• allow_anoymou true
  I am using MQTTnet Client in my .Net Application. and connecting to mosquitto broker version 2.0.15. My client connects using MqttProtocolVersion5.

Here is my MqttClientOptionBuilder: in ConnectAsync():

var messageBuilder = new MqttClientOptionsBuilder()

                    .WithProtocolVersion(MQTTnet.Formatter.MqttProtocolVersion.V500)

                    .WithClientId(ClientId)

                    .WithCredentials(BrokerUserName, BrokerPwd)

                    .WithConnectionUri(_mqttUri)

                    .WithKeepAlivePeriod(TimeSpan.FromSeconds(KeepAlivePeroid))

                    .WithTimeout(TimeSpan.FromSeconds(36000))

                    .WithMaximumPacketSize(UInt32.MaxValue)

                    .WithReceiveMaximum(ushort.MaxValue)                       

                    .WithCleanSession();

await _mqttClient1.ConnectAsync(options);

My PublishAsycn():

var messageBuilder = new MqttApplicationMessageBuilder()

                    .WithTopic(publishTopic)

                    .WithPayload(payload)

                    .WithQualityOfServiceLevel(MqttQualityOfServiceLevel.AtMostOnce)

                    .WithRetainFlag(retain)

                    .Build();

var result = await _mqttClient1.PublishAsync(messageBuilder);

Issue:

Publish works fine but mosquitto broker does not receive more than 100 messages.

The only mosquitto broker setting I have is:

• listener 1883

-allow_anoymou true

I want my broker to receive messages continuously.
Note: I didnt have this issue when I used M2Mqtt library. Having this issue only in MQTTnet Library.
Appreciate any help!
Thanks