The PurgeInboxModule
may be found in the Shuttle.Esb.Modules
assembly. The module will attach the PurgeInboxObserver
to the OnAfterInitializeQueueFactories
event of the StartupPipeline
and purges the inbox work queue if the relevant queue implementation has implemented the IPurgeQueue
interface. If it hasn’t a warning is logged.
var bus = ServiceBus
.Create(c => c.AddModule(new PurgeInboxModule()))
.Start();