@@ -4,6 +4,7 @@ using System.Linq; using System.Text; using IServiceOriented.ServiceBus; +using IServiceOriented.ServiceBus.Services; namespace IServiceOriented.ServiceBus.ConsoleUtility { IServiceOriented.ServiceBus.ConsoleUtility/Program.cs @@ -45,7 +45,7 @@ <endpoint name="ChatClientOut" contract="IServiceOriented.ServiceBus.Samples.Chat.IChatService" binding="wsHttpBinding" bindingConfiguration="wsHttpWithUserName" address="http://localhost/chatServer" behaviorConfiguration="client"></endpoint> - <endpoint contract="IServiceOriented.ServiceBus.IServiceBusManagementService" binding="wsHttpBinding" bindingConfiguration="wsHttp" address="http://localhost/serviceBusManagement" behaviorConfiguration="client" /> + <endpoint contract="IServiceOriented.ServiceBus.Services.IServiceBusManagementService" binding="wsHttpBinding" bindingConfiguration="wsHttp" address="http://localhost/serviceBusManagement" behaviorConfiguration="client" /> </client> <services> <service name="ChatServer" behaviorConfiguration="esbListener" > @@ -55,8 +55,8 @@ <endpoint name="wsHttp" contract="IServiceOriented.ServiceBus.Samples.Chat.IChatService" binding="wsHttpBinding" bindingConfiguration="wsHttpWithUserName" address="send" /> </service> - <service name="IServiceOriented.ServiceBus.ServiceBusManagementService"> - <endpoint contract="IServiceOriented.ServiceBus.IServiceBusManagementService" binding="wsHttpBinding" bindingConfiguration="wsHttp" address="http://localhost/serviceBusManagement" /> + <service name="IServiceOriented.ServiceBus.Services.ServiceBusManagementService"> + <endpoint contract="IServiceOriented.ServiceBus.Services.IServiceBusManagementService" binding="wsHttpBinding" bindingConfiguration="wsHttp" address="http://localhost/serviceBusManagement" /> </service> </services> IServiceOriented.ServiceBus.Samples.Chat/App.config @@ -4,6 +4,10 @@ using System.Linq; using System.Text; using IServiceOriented.ServiceBus.Collections; +using IServiceOriented.ServiceBus.Delivery; +using IServiceOriented.ServiceBus.Services; +using IServiceOriented.ServiceBus.Listeners; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus.Samples.Chat { @@ -11,7 +15,7 @@ namespace IServiceOriented.ServiceBus.Samples.Chat { public ChatServer() { - _serviceBus = new ServiceBusRuntime(SimpleServiceLocator.With(new QueuedDeliveryCore(new MsmqMessageDeliveryQueue(".\\private$\\chat_deliver", true), new MsmqMessageDeliveryQueue(".\\private$\\chat_retry", true), new MsmqMessageDeliveryQueue(".\\private$\\chat_fail", true)), new WcfManagementService())); + _serviceBus = new ServiceBusRuntime(new QueuedDeliveryCore(new MsmqMessageDeliveryQueue(".\\private$\\chat_deliver", true), new MsmqMessageDeliveryQueue(".\\private$\\chat_retry", true), new MsmqMessageDeliveryQueue(".\\private$\\chat_fail", true)), new WcfManagementService()); _serviceBus.AddListener(new ListenerEndpoint(Guid.NewGuid(), "Chat Service", "ChatServer", "http://localhost/chatServer", typeof(IChatService), new WcfListener())); _serviceBus.Subscribe(new SubscriptionEndpoint(Guid.NewGuid(), "No subscribers", "ChatClient", "", typeof(IChatService), new MethodDispatcher(new UnhandledReplyHandler(_serviceBus)), new UnhandledMessageFilter(typeof(SendMessageRequest)))); _serviceBus.UnhandledException+= (o, ex) => IServiceOriented.ServiceBus.Samples.Chat/ChatServer.cs @@ -2,6 +2,7 @@ using System.Collections.Generic; using System.Linq; using System.Text; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus.Samples.Chat { IServiceOriented.ServiceBus.Samples.Chat/WcfDispatcherWithUsernameCredentials.cs @@ -6,6 +6,8 @@ using System.Collections.Generic; using NUnit.Framework; using IServiceOriented.ServiceBus.UnitTests; +using IServiceOriented.ServiceBus.Delivery; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus.Scripting.UnitTests { @@ -38,7 +40,7 @@ def Execute(): bool success = false; - ServiceBusRuntime runtime = new ServiceBusRuntime(SimpleServiceLocator.With(new QueuedDeliveryCore( new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue() ))); + ServiceBusRuntime runtime = new ServiceBusRuntime(new QueuedDeliveryCore( new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue() )); runtime.Subscribe(new SubscriptionEndpoint(Guid.NewGuid(), "Tranformation", null, null, typeof(void), dispatcher, new TypedMessageFilter(typeof(BeforeTransformation)))); runtime.Subscribe(new SubscriptionEndpoint(Guid.NewGuid(), "AfterTransformation", null, null, typeof(void), new ActionDispatcher( (subscription, md) => { IServiceOriented.ServiceBus.Scripting.UnitTests/ScriptTransformationDispatcherTest.cs @@ -4,6 +4,7 @@ using System.Text; using System.Runtime.Serialization; using Microsoft.Scripting; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus.Scripting { IServiceOriented.ServiceBus.Scripting/ScriptTransformationDispatcher.cs @@ -35,7 +35,7 @@ </behaviors> <client> <endpoint name="NamedPipeClient" contract="IServiceOriented.ServiceBus.UnitTests.IContract" binding="netNamedPipeBinding" bindingConfiguration="namedPipe" address="net.pipe://localhost/remotehello" /> - <endpoint contract="IServiceOriented.ServiceBus.IServiceBusManagementService" binding="netNamedPipeBinding" bindingConfiguration="namedPipe" address="net.pipe://localhost/serviceBusManagement" /> + <endpoint contract="IServiceOriented.ServiceBus.Services.IServiceBusManagementService" binding="netNamedPipeBinding" bindingConfiguration="namedPipe" address="net.pipe://localhost/serviceBusManagement" /> </client> <services> <service name="NamedPipeListener" behaviorConfiguration="debug" > @@ -44,8 +44,8 @@ <service name="IServiceOriented.ServiceBus.UnitTests.ContractImplementation" behaviorConfiguration="debug" > <endpoint name="NamedPipe" contract="IServiceOriented.ServiceBus.UnitTests.IContract" binding="netNamedPipeBinding" bindingConfiguration="namedPipe" address="net.pipe://localhost/remotehello" /> </service> - <service name="IServiceOriented.ServiceBus.ServiceBusManagementService" behaviorConfiguration="debug"> - <endpoint contract="IServiceOriented.ServiceBus.IServiceBusManagementService" binding="netNamedPipeBinding" bindingConfiguration="namedPipe" address="net.pipe://localhost/serviceBusManagement" /> + <service name="IServiceOriented.ServiceBus.Services.ServiceBusManagementService" behaviorConfiguration="debug"> + <endpoint contract="IServiceOriented.ServiceBus.Services.IServiceBusManagementService" binding="netNamedPipeBinding" bindingConfiguration="namedPipe" address="net.pipe://localhost/serviceBusManagement" /> </service> </services> IServiceOriented.ServiceBus.UnitTests/App.config @@ -2,6 +2,7 @@ using System.Collections.Generic; using System.Linq; using System.Text; +using IServiceOriented.ServiceBus.Delivery; namespace IServiceOriented.ServiceBus.UnitTests { @@ -9,7 +10,7 @@ namespace IServiceOriented.ServiceBus.UnitTests { public static ServiceBusRuntime MemoryQueueRuntime() { - ServiceBusRuntime runtime = new ServiceBusRuntime(SimpleServiceLocator.With(new QueuedDeliveryCore(new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue()))); + ServiceBusRuntime runtime = new ServiceBusRuntime(new QueuedDeliveryCore(new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue())); return runtime; } @@ -38,7 +39,7 @@ namespace IServiceOriented.ServiceBus.UnitTests MsmqMessageDeliveryQueue retryQueue = new MsmqMessageDeliveryQueue(_retryQueuePath); MsmqMessageDeliveryQueue failQueue = new MsmqMessageDeliveryQueue(_failQueuePath); - return new ServiceBusRuntime(SimpleServiceLocator.With(new QueuedDeliveryCore(testQueue, retryQueue, failQueue))); + return new ServiceBusRuntime(new QueuedDeliveryCore(testQueue, retryQueue, failQueue)); } const string _testQueuePath = ".\\private$\\esb_test_queue"; IServiceOriented.ServiceBus.UnitTests/Create.cs @@ -2,6 +2,7 @@ using System.Collections.Generic; using System.Linq; using System.Text; +using IServiceOriented.ServiceBus.Delivery; namespace IServiceOriented.ServiceBus.UnitTests { IServiceOriented.ServiceBus.UnitTests/NonTransactionalMemoryQueue.cs @@ -2,6 +2,7 @@ using System.Collections.Generic; using System.Linq; using System.Text; +using IServiceOriented.ServiceBus.Delivery; namespace IServiceOriented.ServiceBus.UnitTests { IServiceOriented.ServiceBus.UnitTests/NullMessageDeliveryQueue.cs @@ -4,6 +4,7 @@ using System.Text; using System.Collections.Generic; using System.Linq; using NUnit.Framework; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus.UnitTests { IServiceOriented.ServiceBus.UnitTests/TestMessageFilters.cs @@ -10,6 +10,8 @@ using IServiceOriented.ServiceBus.Collections; using System.ServiceModel; using IServiceOriented.ServiceBus.Formatters; +using IServiceOriented.ServiceBus.Delivery; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus.UnitTests { IServiceOriented.ServiceBus.UnitTests/TestMsmqMessageDeliveryQueue.cs @@ -3,6 +3,8 @@ using System.Text; using System.Collections.Generic; using System.Linq; using NUnit.Framework; +using IServiceOriented.ServiceBus.Delivery; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus.UnitTests { @@ -17,7 +19,7 @@ namespace IServiceOriented.ServiceBus.UnitTests [Test] public void Echo() { - using (ServiceBusRuntime runtime = new ServiceBusRuntime(SimpleServiceLocator.With(new QueuedDeliveryCore(new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue())))) + using (ServiceBusRuntime runtime = new ServiceBusRuntime(new QueuedDeliveryCore(new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue(), new NonTransactionalMemoryQueue()))) { CEcho echo = new CEcho(); IServiceOriented.ServiceBus.UnitTests/TestRequestResponse.cs @@ -6,6 +6,10 @@ using System.Text; using System.Collections.Generic; using System.Linq; using NUnit.Framework; +using IServiceOriented.ServiceBus.Delivery; +using IServiceOriented.ServiceBus.Services; +using IServiceOriented.ServiceBus.Listeners; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus.UnitTests { @@ -19,7 +23,7 @@ namespace IServiceOriented.ServiceBus.UnitTests [Test] public void CanAddAndRemoveSubscription() { - using(ServiceBusRuntime runtime = new ServiceBusRuntime(SimpleServiceLocator.With(new DirectDeliveryCore(), new WcfManagementService()))) + using(ServiceBusRuntime runtime = new ServiceBusRuntime(new DirectDeliveryCore(), new WcfManagementService())) { ServiceBusTest tester = new ServiceBusTest(runtime); tester.StartAndStop(() => @@ -42,7 +46,7 @@ namespace IServiceOriented.ServiceBus.UnitTests [Test] public void CanAddAndRemoveListener() { - using (ServiceBusRuntime runtime = new ServiceBusRuntime(SimpleServiceLocator.With(new DirectDeliveryCore(), new WcfManagementService()))) + using (ServiceBusRuntime runtime = new ServiceBusRuntime(new DirectDeliveryCore(), new WcfManagementService())) { MessageDelivery.RegisterKnownType(typeof(PassThroughMessageFilter)); IServiceOriented.ServiceBus.UnitTests/TestServiceBusManagement.cs @@ -7,6 +7,10 @@ using System.Threading; using IServiceOriented.ServiceBus.Threading; using System.Collections.ObjectModel; +using IServiceOriented.ServiceBus.Delivery; +using IServiceOriented.ServiceBus.Listeners; +using IServiceOriented.ServiceBus.Dispatchers; + namespace IServiceOriented.ServiceBus.UnitTests { @@ -122,6 +126,7 @@ namespace IServiceOriented.ServiceBus.UnitTests { public TestServiceBusRuntime() { + } IServiceOriented.ServiceBus.UnitTests/TestServiceBusRuntime.cs @@ -5,6 +5,8 @@ using System.Linq; using NUnit.Framework; using IServiceOriented.ServiceBus.Data; +using IServiceOriented.ServiceBus.Listeners; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus.UnitTests { IServiceOriented.ServiceBus.UnitTests/TestSqlSubscriptionDb.cs @@ -4,6 +4,7 @@ using System.Text; using System.Collections.Generic; using System.Linq; using NUnit.Framework; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus.UnitTests { @@ -26,8 +27,8 @@ namespace IServiceOriented.ServiceBus.UnitTests string message = "blah blah test test"; - WcfDispatcher contractDispatcher = new WcfDispatcher(); - contractDispatcher.Dispatch(endpoint, new MessageDelivery(endpoint.Id, typeof(IContract), "PublishThis", message, 3, new MessageDeliveryContext())); + WcfDispatcher contractDispatcher = new WcfDispatcher(endpoint); + contractDispatcher.Dispatch(new MessageDelivery(endpoint.Id, typeof(IContract), "PublishThis", message, 3, new MessageDeliveryContext())); Assert.AreEqual(1, ci.PublishedCount); Assert.AreEqual(message, ci.PublishedMessages[0]); IServiceOriented.ServiceBus.UnitTests/TestWcfDispatcher.cs @@ -6,6 +6,8 @@ using System.Text; using System.ServiceModel; using System.ServiceModel.Dispatcher; using System.ServiceModel.Description; +using IServiceOriented.ServiceBus.Services; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus { IServiceOriented.ServiceBus/AutoSubscribeBehavior.cs @@ -18,6 +18,13 @@ namespace IServiceOriented.ServiceBus [DataContract] public abstract class Dispatcher : IDisposable { + protected Dispatcher() + { + } + protected Dispatcher(SubscriptionEndpoint endpoint) + { + _endpoint = endpoint; + } [NonSerialized] ServiceBusRuntime _runtime; /// <summary> @@ -35,6 +42,23 @@ namespace IServiceOriented.ServiceBus } } + [NonSerialized] + SubscriptionEndpoint _endpoint; + /// <summary> + /// Gets the subscription endpoint associated with this dispatcher. + /// </summary> + public SubscriptionEndpoint Endpoint + { + get + { + return _endpoint; + } + internal set + { + _endpoint = value; + } + } + internal void StartInternal() { OnStart(); @@ -65,7 +89,7 @@ namespace IServiceOriented.ServiceBus /// <summary> /// Handles sending a message to a subscriber endpoint. /// </summary> - public abstract void Dispatch(SubscriptionEndpoint endpoint, MessageDelivery messageDelivery); + public abstract void Dispatch(MessageDelivery messageDelivery); /// <summary> /// Dispose any resources held by this dispatcher. IServiceOriented.ServiceBus/Dispatcher.cs @@ -85,14 +85,14 @@ <Reference Include="System.Xml" /> </ItemGroup> <ItemGroup> - <Compile Include="ActionDispatcher.cs" /> - <Compile Include="DirectDeliveryCore.cs" /> + <Compile Include="Dispatchers\ActionDispatcher.cs" /> + <Compile Include="Delivery\DirectDeliveryCore.cs" /> <Compile Include="Formatters\MessageDeliveryConverter.cs" /> <Compile Include="Formatters\MessageDeliveryMessageContractFormatter.cs" /> <Compile Include="MessageDeliveryContext.cs" /> <Compile Include="AutoSubscribeBehavior.cs" /> <Compile Include="Threading\CountdownLatch.cs" /> - <Compile Include="DeliveryCore.cs" /> + <Compile Include="Delivery\DeliveryCore.cs" /> <Compile Include="Dispatcher.cs" /> <Compile Include="DuplicateIdentifierException.cs" /> <Compile Include="Endpoint.cs" /> @@ -102,29 +102,29 @@ <Compile Include="Threading\ILockedObject.cs" /> <Compile Include="InvalidContractException.cs" /> <Compile Include="ListenerEndpoint.cs" /> - <Compile Include="IMessageDeliveryQueue.cs" /> + <Compile Include="Delivery\IMessageDeliveryQueue.cs" /> <Compile Include="ListenerEndpointCollection.cs" /> <Compile Include="PublishRequest.cs" /> - <Compile Include="QueuedDeliveryCore.cs" /> + <Compile Include="Delivery\QueuedDeliveryCore.cs" /> <Compile Include="Collections\ReadOnlyDictionary.cs" /> - <Compile Include="CorrelationMessageFilter.cs" /> + <Compile Include="Delivery\CorrelationMessageFilter.cs" /> <Compile Include="SimpleServiceLocator.cs" /> <Compile Include="Data\SqlSubscriptionDB.cs" /> - <Compile Include="SqlSubscriptionPersistenceService.cs"> + <Compile Include="Services\SqlSubscriptionPersistenceService.cs"> <SubType>Code</SubType> </Compile> <Compile Include="SubscriptionEndpointCollection.cs" /> - <Compile Include="TransformationDispatcher.cs" /> + <Compile Include="Dispatchers\TransformationDispatcher.cs" /> <Compile Include="Threading\ReaderWriterLockedObject.cs" /> <Compile Include="UnhandledMessageFilter.cs" /> - <Compile Include="PerformanceMonitorRuntimeService.cs" /> + <Compile Include="Services\PerformanceMonitorRuntimeService.cs" /> <Compile Include="RuntimeService.cs" /> <Compile Include="ListenerNotFoundException.cs" /> <Compile Include="MessageDelivery.cs" /> <Compile Include="MessageFilter.cs" /> - <Compile Include="MethodDispatcher.cs" /> - <Compile Include="MsmqMessageDeliveryQueue.cs" /> - <Compile Include="PoisonMessageException.cs" /> + <Compile Include="Dispatchers\MethodDispatcher.cs" /> + <Compile Include="Delivery\MsmqMessageDeliveryQueue.cs" /> + <Compile Include="Delivery\PoisonMessageException.cs" /> <Compile Include="Properties\AssemblyInfo.cs" /> <Compile Include="Service.cs" /> <Compile Include="ServiceBusRuntime.cs" /> @@ -132,10 +132,10 @@ <Compile Include="SubscriptionNotFoundException.cs" /> <Compile Include="SubscriptionPersistenceService.cs" /> <Compile Include="TypedMessageFilter.cs" /> - <Compile Include="WcfDispatcher.cs" /> - <Compile Include="WcfListener.cs" /> - <Compile Include="WcfServiceHostFactory.cs" /> - <Compile Include="WcfManagementService.cs" /> + <Compile Include="Dispatchers\WcfDispatcher.cs" /> + <Compile Include="Listeners\WcfListener.cs" /> + <Compile Include="Listeners\WcfServiceHostFactory.cs" /> + <Compile Include="Services\WcfManagementService.cs" /> </ItemGroup> <ItemGroup> <None Include="ClassDiagram.cd" /> IServiceOriented.ServiceBus/IServiceOriented.ServiceBus.csproj @@ -9,6 +9,7 @@ using IServiceOriented.ServiceBus.Threading; using IServiceOriented.ServiceBus.Collections; using System.Collections.ObjectModel; using System.ServiceModel.Channels; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus @@ -56,7 +57,7 @@ namespace IServiceOriented.ServiceBus } } - static List<Type> _knownTypes = new List<Type>(new Type[] { typeof(UnhandledMessageFilter), typeof(WcfListener), typeof(WcfDispatcher), typeof(TypedMessageFilter), typeof(ReadOnlyCollection<string>), typeof(ReadOnlyCollection<short>), typeof(ReadOnlyCollection<int>), typeof(ReadOnlyCollection<bool>), typeof(ReadOnlyCollection<decimal>), typeof(ReadOnlyCollection<float>), typeof(ReadOnlyCollection<double>), typeof(ReadOnlyCollection<long>), typeof(ReadOnlyCollection<Guid>), typeof(MessageDeliveryContext) }); + static List<Type> _knownTypes = new List<Type>(new Type[] { typeof(UnhandledMessageFilter), typeof(Listeners.WcfListener), typeof(WcfDispatcher), typeof(TypedMessageFilter), typeof(ReadOnlyCollection<string>), typeof(ReadOnlyCollection<short>), typeof(ReadOnlyCollection<int>), typeof(ReadOnlyCollection<bool>), typeof(ReadOnlyCollection<decimal>), typeof(ReadOnlyCollection<float>), typeof(ReadOnlyCollection<double>), typeof(ReadOnlyCollection<long>), typeof(ReadOnlyCollection<Guid>), typeof(MessageDeliveryContext) }); /// <summary> /// Clears the list of types registered for message delivery. /// </summary> IServiceOriented.ServiceBus/MessageDelivery.cs @@ -12,6 +12,8 @@ using System.Globalization; using Microsoft.Practices.ServiceLocation; using IServiceOriented.ServiceBus.Threading; using IServiceOriented.ServiceBus.Collections; +using IServiceOriented.ServiceBus.Delivery; +using IServiceOriented.ServiceBus.Dispatchers; namespace IServiceOriented.ServiceBus { @@ -29,13 +31,17 @@ namespace IServiceOriented.ServiceBus if (serviceLocator == null) { - serviceLocator = SimpleServiceLocator.With(new DirectDeliveryCore()); // default to simple service locator with direct message delivery + serviceLocator = SimpleServiceLocator.With(new Delivery.DirectDeliveryCore()); // default to simple service locator with direct message delivery } _serviceLocator = serviceLocator; } - public ServiceBusRuntime() : this(null) + + public ServiceBusRuntime(params RuntimeService[] runtimeServices) : this(SimpleServiceLocator.With(runtimeServices)) + { + } + public ServiceBusRuntime() : this((IServiceLocator)null) { } IServiceOriented.ServiceBus/ServiceBusRuntime.cs @@ -6,7 +6,7 @@ using Microsoft.Practices.ServiceLocation; namespace IServiceOriented.ServiceBus { - public class SimpleServiceLocator : IServiceLocator + internal class SimpleServiceLocator : IServiceLocator { public SimpleServiceLocator() { IServiceOriented.ServiceBus/SimpleServiceLocator.cs @@ -14,13 +14,6 @@ namespace IServiceOriented.ServiceBus [DataContract] public sealed class SubscriptionEndpoint : Endpoint { - public SubscriptionEndpoint(string name, string configurationName, string address, Type contractType, Dispatcher dispatcher, MessageFilter filter) - : base(Guid.NewGuid(), name, configurationName, address, contractType) - { - Filter = filter; - Dispatcher = dispatcher; - } - public SubscriptionEndpoint(Guid id, string name, string configurationName, string address, Type contractType, Dispatcher dispatcher, MessageFilter filter) : base(id, name, configurationName, address, contractType) { @@ -72,8 +65,17 @@ namespace IServiceOriented.ServiceBus return _dispatcher; } private set - { - _dispatcher = value; + { + if (value != null && value.Endpoint != null) + { + throw new InvalidOperationException("Endpoint is attached to another dispatcher"); + } + if (_dispatcher != null) + { + _dispatcher.Endpoint = null; + } + _dispatcher = value; + if (value != null) value.Endpoint = this; } } } IServiceOriented.ServiceBus/SubscriptionEndpoint.cs IServiceOriented.ServiceBus/ActionDispatcher.cs IServiceOriented.ServiceBus/CorrelationMessageFilter.cs IServiceOriented.ServiceBus/DeliveryCore.cs IServiceOriented.ServiceBus/DirectDeliveryCore.cs IServiceOriented.ServiceBus/IMessageDeliveryQueue.cs IServiceOriented.ServiceBus/MethodDispatcher.cs IServiceOriented.ServiceBus/MsmqMessageDeliveryQueue.cs IServiceOriented.ServiceBus/PerformanceMonitorRuntimeService.cs IServiceOriented.ServiceBus/PoisonMessageException.cs IServiceOriented.ServiceBus/QueuedDeliveryCore.cs IServiceOriented.ServiceBus/SqlSubscriptionPersistenceService.cs IServiceOriented.ServiceBus/TransformationDispatcher.cs IServiceOriented.ServiceBus/WcfDispatcher.cs IServiceOriented.ServiceBus/WcfListener.cs IServiceOriented.ServiceBus/WcfManagementService.cs IServiceOriented.ServiceBus/WcfServiceHostFactory.cs 18b399562073fba19631f844245ed2a228631f0d jezell jezell@gmail.com http://github.com/jezell/iserviceoriented/commit/619da2047a742f9dfef2c9320fccd00dad7b6e39 619da2047a742f9dfef2c9320fccd00dad7b6e39 2008-10-09T10:14:07-07:00 2008-10-09T10:14:07-07:00 API usability/discoverability refactoring 3952f70be00cc45995b43116dcfcd4796761f7ed jezell jezell@gmail.com