Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
using Wolverine;
using Xunit;

namespace MessageRoutingTests;

public class publish_message_with_type_parameter : MessageRoutingContext
{
protected override void configure(WolverineOptions opts)
{
opts.PublishMessage(typeof(M1)).ToLocalQueue("blue");
}

[Fact]
public void locally_handled_messages_get_overridden_by_routing()
{
assertRoutesAre<M1>("local://blue");
}
}
18 changes: 14 additions & 4 deletions src/Wolverine/WolverineOptions.Endpoints.cs
Original file line number Diff line number Diff line change
Expand Up @@ -101,14 +101,24 @@ public PublishingExpression Publish()
/// <returns></returns>
public PublishingExpression PublishMessage<TMessageType>()
{
RegisterMessageType(typeof(TMessageType));

return PublishMessage(typeof(TMessageType));
}

/// <summary>
/// Shorthand syntax to route a single message type
/// </summary>
/// <param name="messageType"></param>
/// <returns></returns>
public PublishingExpression PublishMessage(Type messageType)
{
RegisterMessageType(messageType);

var expression = new PublishingExpression(this)
{
AutoAddSubscriptions = true
};

expression.Message<TMessageType>();
expression.Message(messageType);

return expression;
}
Expand Down Expand Up @@ -166,4 +176,4 @@ public void StubAllExternalTransports()
{
ExternalTransportsAreStubbed = true;
}
}
}
Loading