jezell

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

jezell

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;

jezell

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

jezell

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

jezell

    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();
    }

jezell

    public abstract class SubscriptionPersistenceService : RuntimeService
    {
        protected override void OnStart()
        {

            foreach (Endpoint e in LoadEndpoints())
            {
                ListenerEndpoint le = e as ListenerEndpoint;
                SubscriptionEndpoint se = e as SubscriptionEndpoint;

jezell

    public class PerformanceMonitorRuntimeService : RuntimeService
    {
        public PerformanceMonitorRuntimeService() : this (null, null)
        {
        }
        public PerformanceMonitorRuntimeService(string instanceName, string categoryName)
        {
            if (instanceName == null)
            {
                instanceName = "Default Instance";

jezell

    public class WcfManagementService : RuntimeService
    {        
        protected override void OnStart()
        {
            base.OnStart();

            _host = new ServiceHost(new ServiceBusManagementService(Runtime));
            _host.Open();
            
        }

jezell

    public class SubscriptionExtension : IExtension<ServiceHostBase>
    {
        public SubscriptionExtension(SubscriptionEndpoint subscription)
        {
            Subscription = subscription;
        }

        #region IExtension<ServiceHostBase> Members

        public void Attach(ServiceHostBase owner)

jezell

/**
 * @license wysihtml5 v0.3.0
 * https://github.com/xing/wysihtml5
 *
 * Author: Christopher Blum (https://github.com/tiff)
 *
 * Copyright (C) 2012 XING AG
 * Licensed under the MIT license (MIT)
 *
 */