Skip to content

Instantly share code, notes, and snippets.

public class PerformanceMonitorRuntimeService : RuntimeService
{
public PerformanceMonitorRuntimeService() : this (null, null)
{
}
public PerformanceMonitorRuntimeService(string instanceName, string categoryName)
{
if (instanceName == null)
{
instanceName = "Default Instance";
public abstract class SubscriptionPersistenceService : RuntimeService
{
protected override void OnStart()
{
foreach (Endpoint e in LoadEndpoints())
{
ListenerEndpoint le = e as ListenerEndpoint;
SubscriptionEndpoint se = e as SubscriptionEndpoint;
public interface ISubscriptionDB
{
void CreateListener(ListenerEndpoint endpoint);
void CreateSubscription(SubscriptionEndpoint subscription);
void DeleteListener(Guid endpointId);
void DeleteSubscription(Guid id);
System.Collections.Generic.IEnumerable<ListenerEndpoint> LoadListenerEndpoints();
System.Collections.Generic.IEnumerable<SubscriptionEndpoint> LoadSubscriptionEndpoints();
}
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ServiceModel;
using System.Reflection;
using System.Runtime.Serialization;
namespace IServiceOriented.ServiceBus
using System;
using System.Configuration;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ServiceModel;
using System.Runtime.Serialization;
namespace IServiceOriented.ServiceBus
using System;
using System.Configuration;
using System.ServiceModel.Channels;
using System.ServiceModel.Configuration;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ServiceModel;
using System.Reflection;
using System.Reflection.Emit;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using System.Runtime.Serialization;
using System.Messaging;
namespace IServiceOriented.ServiceBus