MQTTnet.AspNetCore.AttributeRouting 0.1.0

This is a support library to integrate AttributeRouting into MQTTnet with AspNetCore.

Easily create Controllers and Actions to process incoming MQTT messages using attribute-based routing against the incoming message topic.

Install-Package MQTTnet.AspNetCore.AttributeRouting -Version 0.1.0

dotnet add package MQTTnet.AspNetCore.AttributeRouting --version 0.1.0

<PackageReference Include="MQTTnet.AspNetCore.AttributeRouting" Version="0.1.0" />

paket add MQTTnet.AspNetCore.AttributeRouting --version 0.1.0

#r "nuget: MQTTnet.AspNetCore.AttributeRouting, 0.1.0"

public void ConfigureServices(IServiceCollection services)
{
	// ... All your other configuration ...

	// Identify and build routes for the current assembly
	services.AddMqttControllers();

	services
		.AddHostedMqttServerWithServices(s =>
		{
			// Optionally set server options here
			s.WithoutDefaultEndpoint();

			// Enable Attribute routing
			s.WithAttributeRouting();
		})
		.AddMqttConnectionHandler()
		.AddConnections();
}

[MqttController]
[MqttRoute("[controller]")] // Optional route prefix
public class MqttWeatherForecastController : MqttBaseController
{
	private readonly ILogger<MqttWeatherForecastController> _logger;

	// Controllers have full support for dependency injection just like AspNetCore controllers
	public MqttWeatherForecastController(ILogger<MqttWeatherForecastController> logger)
	{
		_logger = logger;
	}

	// Supports template routing with typed constraints just like AspNetCore
	// Action routes compose together with the route prefix on the controller level
	[MqttRoute("{zipCode:int}/temperature")]
	public async Task WeatherReport(int zipCode)
	{
		// We have access to the MqttContext
		if (zipCode != 90210) { MqttContext.CloseConnection = true; }

		// We have access to the raw message
		var temperature = BitConverter.ToDouble(Message.Payload);

		_logger.LogInformation($"It's {temperature} degrees in Hollywood");

		if (temperature <= 0 && temperature >= 130)
		{
			// Example validation
			MqttContext.AcceptPublish = false;
		}
	}
}

public void ConfigureServices(IServiceCollection services)
{
	// ... All your other configuration ...

	// Identify and build routes for the current assembly
	services.AddMqttControllers();

	services
		.AddHostedMqttServerWithServices(s =>
		{
			// Optionally set server options here
			s.WithoutDefaultEndpoint();

			// Enable Attribute routing
			s.WithAttributeRouting();
		})
		.AddMqttConnectionHandler()
		.AddConnections();
}

[MqttController]
[MqttRoute("[controller]")] // Optional route prefix
public class MqttWeatherForecastController : MqttBaseController
{
	private readonly ILogger<MqttWeatherForecastController> _logger;

	// Controllers have full support for dependency injection just like AspNetCore controllers
	public MqttWeatherForecastController(ILogger<MqttWeatherForecastController> logger)
	{
		_logger = logger;
	}

	// Supports template routing with typed constraints just like AspNetCore
	// Action routes compose together with the route prefix on the controller level
	[MqttRoute("{zipCode:int}/temperature")]
	public async Task WeatherReport(int zipCode)
	{
		// We have access to the MqttContext
		if (zipCode != 90210) { MqttContext.CloseConnection = true; }

		// We have access to the raw message
		var temperature = BitConverter.ToDouble(Message.Payload);

		_logger.LogInformation($"It's {temperature} degrees in Hollywood");

		if (temperature <= 0 && temperature >= 130)
		{
			// Example validation
			MqttContext.AcceptPublish = false;
		}
	}
}

Release Notes

Beta release

Dependencies

• .NETCoreApp 3.1

  • Microsoft.AspNetCore.Mvc.Core (>= 2.2.5)
  • Microsoft.Bcl.HashCode (>= 1.1.0)
  • MQTTnet (>= 3.0.12)
  • MQTTnet.AspNetCore (>= 3.0.12)

• .NETStandard 2.0

  • Microsoft.AspNetCore.Http.Connections (>= 1.1.0)
  • Microsoft.AspNetCore.Mvc.Core (>= 2.2.5)
  • Microsoft.Bcl.HashCode (>= 1.1.0)
  • MQTTnet (>= 3.0.12)
  • MQTTnet.AspNetCore (>= 3.0.12)

Used By

Version History