From 38c81986186ab768372e38c27be7543f4dcc3736 Mon Sep 17 00:00:00 2001 From: Chris Ortman Date: Tue, 10 Feb 2009 12:34:04 -0600 Subject: [PATCH] Message logging module should create log queue Implement IBusAware on the MessageLoggingModule so that it can create the log queue when the bus is started --- .../MessageModules/MessageLoggingModule.cs | 20 +++++++++++++++++++- 1 files changed, 19 insertions(+), 1 deletions(-) diff --git a/rhino-service.bus/Rhino.ServiceBus/MessageModules/MessageLoggingModule.cs b/rhino-service.bus/Rhino.ServiceBus/MessageModules/MessageLoggingModule.cs index 46cc584..6be41f2 100644 --- a/rhino-service.bus/Rhino.ServiceBus/MessageModules/MessageLoggingModule.cs +++ b/rhino-service.bus/Rhino.ServiceBus/MessageModules/MessageLoggingModule.cs @@ -7,7 +7,7 @@ using Rhino.ServiceBus.Msmq; namespace Rhino.ServiceBus.MessageModules { - public class MessageLoggingModule : IMessageModule + public class MessageLoggingModule : IMessageModule, IServiceBusAware { private readonly IMessageSerializer messageSerializer; private readonly IEndpointRouter endpointRouter; @@ -123,5 +123,23 @@ namespace Rhino.ServiceBus.MessageModules }); return false; } + + public void BusStarting(IServiceBus bus) + { + var endpoint = endpointRouter.GetRoutedEndpoint(logQueue); + MsmqUtil.GetQueuePath(endpoint).Create(); + } + + public void BusStarted(IServiceBus bus) + { + } + + public void BusDisposing(IServiceBus bus) + { + } + + public void BusDisposed(IServiceBus bus) + { + } } } \ No newline at end of file -- 1.6.0.2.1172.ga5ed0