mirror of
https://github.com/dotnet/MQTTnet.git
synced 2026-10-15 08:33:01 +08:00
40 lines
1.6 KiB
C#
40 lines
1.6 KiB
C#
// Licensed to the .NET Foundation under one or more agreements.
|
|
// The .NET Foundation licenses this file to you under the MIT license.
|
|
// See the LICENSE file in the project root for more information.
|
|
|
|
using MQTTnet.Formatter;
|
|
|
|
namespace MQTTnet.Tests.Server;
|
|
|
|
// ReSharper disable InconsistentNaming
|
|
[TestClass]
|
|
public sealed class Wildcard_Subscription_Available_Tests : BaseTestClass
|
|
{
|
|
[TestMethod]
|
|
public async Task Server_Reports_Wildcard_Subscription_Available_Tests_Supported_V3()
|
|
{
|
|
using var testEnvironment = CreateTestEnvironment();
|
|
await testEnvironment.StartServer();
|
|
|
|
var client = testEnvironment.CreateClient();
|
|
var connectResult = await client.ConnectAsync(testEnvironment.ClientFactory.CreateClientOptionsBuilder()
|
|
.WithProtocolVersion(MqttProtocolVersion.V311)
|
|
.WithTcpServer("127.0.0.1", testEnvironment.ServerPort).Build());
|
|
|
|
Assert.IsTrue(connectResult.WildcardSubscriptionAvailable);
|
|
}
|
|
|
|
[TestMethod]
|
|
public async Task Server_Reports_Wildcard_Subscription_Available_Tests_Supported_V5()
|
|
{
|
|
using var testEnvironment = CreateTestEnvironment(MqttProtocolVersion.V500);
|
|
await testEnvironment.StartServer();
|
|
|
|
var client = testEnvironment.CreateClient();
|
|
var connectResult = await client.ConnectAsync(testEnvironment.ClientFactory.CreateClientOptionsBuilder()
|
|
.WithProtocolVersion(MqttProtocolVersion.V500)
|
|
.WithTcpServer("127.0.0.1", testEnvironment.ServerPort).Build());
|
|
|
|
Assert.IsTrue(connectResult.WildcardSubscriptionAvailable);
|
|
}
|
|
} |