Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
RSB 3.0 Customize outgoing messages by destination
<rhino.esb>
<bus threadCount="1"
numberOfRetries="5"
endpoint="rhino.queues://localhost/test_queue?volatile=true"
queueIsolationLevel="ReadCommitted" />
</rhino.esb>
public class CustomizeForVolatileEndpoints : ICustomizeOutgoingMessages
{
public void Customize(OutgoingMessageInformation messageInformation)
{
if (messageInformation.Destination != null &&
messageInformation.Destination.Uri.Query.ToUpperInvariant().Contains("VOLATILE=TRUE")))
{
messageInformation.MaxAttempts = 2;
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.