Mark van Renswoude
165680fd38
- This is a breaking change for custom middleware implementations Added validation for return type handling - This may be breaking for incorrect implementations, but highly unlikely
26 lines
635 B
C#
26 lines
635 B
C#
using Messaging.TapetiExample;
|
|
using Tapeti.Annotations;
|
|
|
|
namespace _05_SpeedTest
|
|
{
|
|
[MessageController]
|
|
[DynamicQueue("tapeti.example.05")]
|
|
public class SpeedMessageController
|
|
{
|
|
private readonly IMessageCounter messageCounter;
|
|
|
|
public SpeedMessageController(IMessageCounter messageCounter)
|
|
{
|
|
this.messageCounter = messageCounter;
|
|
}
|
|
|
|
|
|
#pragma warning disable IDE0060 // Remove unused parameter
|
|
public void HandleSpeedTestMessage(SpeedTestMessage message)
|
|
{
|
|
messageCounter.Add();
|
|
}
|
|
#pragma warning restore IDE0060
|
|
}
|
|
}
|