ServiceBusService Class

[ServiceBehaviorAttribute(InstanceContextMode = InstanceContextMode.Single, UseSynchronizationContext = false)]
public class ServiceBusService : SelfHostingService, 
	IServiceBusService, ISelfHostingService, IAdapter, ISupportLifecycle, IDisposable, 
	IProvideStatus, IPersistSettings

<ServiceBehaviorAttribute(InstanceContextMode := InstanceContextMode.Single, UseSynchronizationContext := false)>
Public Class ServiceBusService
	Inherits SelfHostingService
	Implements IServiceBusService, ISelfHostingService, IAdapter, ISupportLifecycle, 
	IDisposable, IProvideStatus, IPersistSettings

[ServiceBehaviorAttribute(InstanceContextMode = InstanceContextMode::Single, UseSynchronizationContext = false)]
public ref class ServiceBusService : public SelfHostingService, 
	IServiceBusService, ISelfHostingService, IAdapter, ISupportLifecycle, IDisposable, 
	IProvideStatus, IPersistSettings

[<ServiceBehaviorAttribute(InstanceContextMode = InstanceContextMode.Single, UseSynchronizationContext = false)>]
type ServiceBusService = 
    class
        inherit SelfHostingService
        interface IServiceBusService
        interface ISelfHostingService
        interface IAdapter
        interface ISupportLifecycle
        interface IDisposable
        interface IProvideStatus
        interface IPersistSettings
    end

GSF.ServiceBus.ServiceBusService = function();

Type.createClass(
	'GSF.ServiceBus.ServiceBusService',
	GSF.ServiceModel.SelfHostingService,
	GSF.ServiceBus.IServiceBusService,
	GSF.ServiceModel.ISelfHostingService,
	GSF.Adapters.IAdapter,
	GSF.ISupportLifecycle,
	IDisposable,
	GSF.IProvideStatus,
	GSF.Configuration.IPersistSettings);

using System;
using System.ServiceModel;
using System.ServiceModel.Description;
using System.Threading;
using GSF;
using GSF.ServiceBus;

class Program
{
    static void Main(string[] args)
    {
        // Prompt for security option.
        Console.Write("Enable security (Y/N): ");
        bool enableSecurity = Console.ReadLine().ParseBoolean();

        // Initialize service bus.
        ServiceBusService service = new ServiceBusService();
        service.Singleton = true;
        service.PublishMetadata = true;
        service.PersistSettings = false;
        service.Endpoints = "http.duplex://localhost:4501; net.tcp://locahost:4502";
        if (enableSecurity)
            service.SecurityPolicy = typeof(ServiceBusSecurityPolicy).FullName;
        service.Initialize();

        // Show service bus status.
        if (service.ServiceHost.State == CommunicationState.Opened)
        {
            Console.WriteLine("\r\n{0} is running:", service.GetType().Name);
            foreach (ServiceEndpoint endpoint in service.ServiceHost.Description.Endpoints)
            {
                Console.WriteLine("- {0} ({1})", endpoint.Address, endpoint.Binding.GetType().Name);
            }

            new Thread(delegate() 
                {
                    while (service.ServiceHost.State == CommunicationState.Opened)
                    {
                        Console.WriteLine();
                        Console.WriteLine();
                        Console.WriteLine("Status of {0}:", service.Name);
                        Console.WriteLine(service.Status);
                        Console.Write("Press Enter key to stop...");

                        Thread.Sleep(5000);
                    }
                }).Start();
        }
        else
        {
            Console.WriteLine("\r\n{0} could not be started", service.GetType().Name);
        }

        // Shutdown.
        Console.ReadLine();
        service.Dispose();
    }
}

<?xml version="1.0"?>
<configuration>
  <configSections>
    <section name="categorizedSettings" type="GSF.Configuration.CategorizedSettingsSection, GSF.Core" />
  </configSections>
  <categorizedSettings>
    <serviceBusService>
      <add name="Endpoints" value="" description="Semicolon delimited list of URIs where the web service can be accessed."
        encrypted="false" />
      <add name="Contract" value="GSF.ServiceBus.IServiceBusService, GSF.ServiceBus"
        description="Assembly qualified name of the contract interface implemented by the web service."
        encrypted="false" />
      <add name="Singleton" value="True" description="True if the web service is singleton; otherwise False."
        encrypted="false" />
      <add name="SecurityPolicy" value="" description="Assembly qualified name of the authorization policy to be used for securing the web service."
        encrypted="false" />
      <add name="PublishMetadata" value="True" description="True if the web service metadata is to be published at all the endpoints; otherwise False."
        encrypted="false" />
      <add name="BufferThreshold" value="-1" description="Maximum number of messages that can be queued for distribution before the oldest ones are discarded."
        encrypted="false" />
      <add name="ProcessingMode" value="Sequential" description="Processing mode (Parallel; Sequential) to be used for the distribution of messages."
        encrypted="false" />
    </serviceBusService>
  </categorizedSettings>
  <system.serviceModel>
    <services>
      <service name="GSF.ServiceBus.ServiceBusService">
        <endpoint address="" contract="GSF.ServiceBus.IServiceBusService" binding="wsDualHttpBinding" />
      </service>
    </services>
    <behaviors>
      <serviceBehaviors>
        <behavior>
          <serviceMetadata httpGetEnabled="true" />
          <serviceDebug includeExceptionDetailInFaults="false" />
        </behavior>
      </serviceBehaviors>
    </behaviors>
    <serviceHostingEnvironment multipleSiteBindingsEnabled="true">
      <serviceActivations>
        <add relativeAddress="ServiceBusService.svc" service="GSF.ServiceBus.ServiceBusService, GSF.ServiceBus" />
      </serviceActivations>
    </serviceHostingEnvironment>
  </system.serviceModel>
</configuration>

using System;
using System.ServiceModel;
using System.Threading;

class Program : IServiceBusServiceCallback
{
    static void Main(string[] args)
    {
        // NOTE: Service reference to the service bus service must be added to generate the service proxy.

        // Initialize auto-generated service bus service proxy.
        InstanceContext callbackContext = new InstanceContext(new Program());
        ServiceBusServiceClient serviceBusService = new ServiceBusServiceClient(callbackContext, "NetTcpBinding_IServiceBusService");

        // Create registration request for publishing messages.
        RegistrationRequest registration = new RegistrationRequest();
        registration.MessageType = MessageType.Topic;
        registration.MessageName = "Topic.Frequency";
        registration.RegistrationType = RegistrationType.Produce;
        serviceBusService.Register(registration);

        // Start publishing messages to the bus asynchronously.
        new Thread(delegate() 
            {
                Message message = new Message();
                message.Type = registration.MessageType;
                message.Name = registration.MessageName;
                message.Format = "application/octet-stream";

                Random random = new Random(59);
                while (serviceBusService.State == CommunicationState.Opened)
                {
                    message.Time = DateTime.UtcNow;
                    message.Content = BitConverter.GetBytes(random.Next(61));
                    serviceBusService.Publish(message);

                    Thread.Sleep(5000);
                }
            }).Start();

        // Shutdown.
        Console.Write("Press Enter key to stop...");
        Console.ReadLine();
        serviceBusService.Close();
    }

    public void ProcessMessage(Message message)
    {
        // This method will not be invoked since we are not consuming messages.
        throw new NotSupportedException();
    }
}

using System;
using System.ServiceModel;

class Program : IServiceBusServiceCallback
{
    static void Main(string[] args)
    {
        // NOTE: Service reference to the service bus service must be added to generate the service proxy.

        // Initialize auto-generated service bus service proxy.
        InstanceContext callbackContext = new InstanceContext(new Program());
        ServiceBusServiceClient serviceBusService = new ServiceBusServiceClient(callbackContext, "NetTcpBinding_IServiceBusService");

        // Subscribe with service bus service to receive messages.
        RegistrationRequest registration = new RegistrationRequest();
        registration.MessageType = MessageType.Topic;
        registration.MessageName = "Topic.Frequency";
        registration.RegistrationType = RegistrationType.Consume;
        serviceBusService.Register(registration);

        // Shutdown.
        Console.WriteLine("Press Enter key to stop...");
        Console.WriteLine();
        Console.ReadLine();
        serviceBusService.Close();
    }

    public void ProcessMessage(Message message)
    {
        if (message.Format != "application/octet-stream")
            Console.WriteLine("Message format '{0}' is not supported", message.Format);
        else
            Console.WriteLine("Message received: {0} Hz", BitConverter.ToInt32(message.Content, 0));
    }
}

using System;
using System.ServiceModel;
using System.Threading;
using GSF;

class Program : IServiceBusServiceCallback
{
    static void Main(string[] args)
    {
        // NOTE: Service reference to the service bus service must be added to generate the service proxy.

        // Initialize auto-generated service bus service proxy.
        InstanceContext callbackContext = new InstanceContext(new Program());
        ServiceBusServiceClient serviceBusService = new ServiceBusServiceClient(callbackContext, "NetTcpBinding_IServiceBusService");
        serviceBusService.ChannelFactory.Open();

        // Start querying service bus service status asynchronously.
        new Thread(delegate()
        {
            while (serviceBusService.State == CommunicationState.Opened)
            {
                Console.Clear();
                Console.WriteLine(new string('-', 79));
                Console.WriteLine("|" + "Service Bus Status".CenterText(77) + "|");
                Console.WriteLine(new string('-', 79));
                Console.WriteLine();

                // Show clients.
                Console.Write("Client ID".PadRight(25));
                Console.Write(" ");
                Console.Write("Connected".PadRight(21));
                Console.Write(" ");
                Console.Write("Msg. Produced".PadRight(15));
                Console.Write(" ");
                Console.Write("Msg. Consumed".PadRight(15));
                Console.WriteLine();
                Console.Write(new string('-', 25));
                Console.Write(" ");
                Console.Write(new string('-', 21));
                Console.Write(" ");
                Console.Write(new string('-', 15));
                Console.Write(" ");
                Console.Write(new string('-', 15));
                Console.WriteLine();
                foreach (ClientInfo client in serviceBusService.GetClients())
                {
                    Console.Write(client.SessionId.TruncateRight(25).PadRight(25));
                    Console.Write(" ");
                    Console.Write(client.ConnectedAt.ToString("MM/dd/yy hh:mm:ss tt").PadRight(21));
                    Console.Write(" ");
                    Console.Write(client.MessagesProduced.ToString().PadRight(15));
                    Console.Write(" ");
                    Console.Write(client.MessagesConsumed.ToString().PadRight(15));
                    Console.WriteLine();
                }
                Console.WriteLine();

                // Show queues.
                Console.Write("Queue Name".PadRight(25));
                Console.Write(" ");
                Console.Write("Producers".PadRight(10));
                Console.Write(" ");
                Console.Write("Consumers".PadRight(10));
                Console.Write(" ");
                Console.Write("Msg. Received".PadRight(15));
                Console.Write(" ");
                Console.Write("Msg. Processed".PadRight(15));
                Console.WriteLine();
                Console.Write(new string('-', 25));
                Console.Write(" ");
                Console.Write(new string('-', 10));
                Console.Write(" ");
                Console.Write(new string('-', 10));
                Console.Write(" ");
                Console.Write(new string('-', 15));
                Console.Write(" ");
                Console.Write(new string('-', 15));
                Console.WriteLine();
                foreach (RegistrationInfo queue in serviceBusService.GetQueues())
                {
                    Console.Write(queue.MessageName.PadRight(25));
                    Console.Write(" ");
                    Console.Write(queue.Producers.Length.ToString().PadRight(15));
                    Console.Write(" ");
                    Console.Write(queue.Consumers.Length.ToString().PadRight(15));
                    Console.Write(" ");
                    Console.Write(queue.MessagesReceived.ToString().PadRight(15));
                    Console.Write(" ");
                    Console.Write(queue.MessagesProcessed.ToString().PadRight(15));
                    Console.WriteLine();
                }
                Console.WriteLine();

                // Show topics.
                Console.Write("Topic Name".PadRight(25));
                Console.Write(" ");
                Console.Write("Producers".PadRight(10));
                Console.Write(" ");
                Console.Write("Consumers".PadRight(10));
                Console.Write(" ");
                Console.Write("Msg. Received".PadRight(15));
                Console.Write(" ");
                Console.Write("Msg. Processed".PadRight(15));
                Console.WriteLine();
                Console.Write(new string('-', 25));
                Console.Write(" ");
                Console.Write(new string('-', 10));
                Console.Write(" ");
                Console.Write(new string('-', 10));
                Console.Write(" ");
                Console.Write(new string('-', 15));
                Console.Write(" ");
                Console.Write(new string('-', 15));
                Console.WriteLine();
                foreach (RegistrationInfo topic in serviceBusService.GetTopics())
                {
                    Console.Write(topic.MessageName.PadRight(25));
                    Console.Write(" ");
                    Console.Write(topic.Producers.Length.ToString().PadRight(15));
                    Console.Write(" ");
                    Console.Write(topic.Consumers.Length.ToString().PadRight(15));
                    Console.Write(" ");
                    Console.Write(topic.MessagesReceived.ToString().PadRight(15));
                    Console.Write(" ");
                    Console.Write(topic.MessagesProcessed.ToString().PadRight(15));
                    Console.WriteLine();
                }
                Console.WriteLine();
                Console.Write("Press Enter key to stop...");

                Thread.Sleep(5000);
            }
        }).Start();

        // Shutdown.
        Console.ReadLine();
        serviceBusService.Close();
    }

    public void ProcessMessage(Message message)
    {
        // This method will not be invoked since we are not consuming messages.
        throw new NotSupportedException();
    }
}