Using the Metric Streaming Message Bus (MSMB)

Structure of message received from the MSMB

{
    "eTag": null,
    "resourceUri": "/rest/enclosures/09SGH100X6J1",
    "changeType": "Updated",
    "newState": null,
    "newSubState": null,
    "associatedTask": null,
    "userInitiatedTask": false,
    "changedAttributes": null,
    "data": null,
    "resource": {
        "type": "MetricData",
        "resourceType": "enclosures",
        "resourceDataList": [
            {
                "metricSampleList": [
                    {
                        "valueArray": [
                            null
                        ],
                        "name": "RatedCapacity"
                    },
                    {
                        "valueArray": [
                            523
                        ],
                        "name": "AveragePower"
                    },
                    {
                        "valueArray": [
                            573
                        ],
                        "name": "PeakPower"
                    },
                    {
                        "valueArray": [
                            null
                        ],
                        "name": "PowerCap"
                    },
                    {
                        "valueArray": [
                            23
                        ],
                        "name": "AmbientTemperature"
                    },
                    {
                        "valueArray": [
                            null
                        ],
                        "name": "DeratedCapacity"
                    }
                ],
                "resourceId": "09SGH100X6J1"
            }
        ],
        "numberOfSamples": 1,
        "sampleIntervalInSeconds": 300,
        "startTime": "2014-09-17T08:43:36.294Z",
        "eTag": null,
        "modified": null,
        "created": null,
        "category": "enclosures",
        "uri": "/rest/enclosures/09SGH100X6J1"
    },
    "timestamp": "2014-09-17T08:48:36.819Z"
}

Using .Net C# to directly reference client certificate

Convert the client certificate and private key to PKCS format for .Net.

openssl.exe pkcs12 -passout pass:default -export -in msmb.crt -out msmb.p12

Example 

  public void Connect()
        {
            string exchangeName = "msmb";
            string hostName = "OneView.domain";
            string queueName = "";
            string routingKey = "msmb.#";

            ConnectionFactory factory = new ConnectionFactory();
            factory.AuthMechanisms = new RabbitMQ.Client.AuthMechanismFactory[] { new ExternalMechanismFactory() };
            factory.HostName = hostname;
            factory.Port = 5671;
            factory.Ssl.CertPath = @".\msmb.p12";
            factory.Ssl.CertPassphrase = "default";
            factory.Ssl.ServerName = hostname;
            factory.Ssl.Enabled = true;

            IConnection connection = factory.CreateConnection();
            IModel model = connection.CreateModel();

            queueName = model.QueueDeclare(queueName, false, false, false, null);
            model.QueueBind(queueName, exchangeName, routingKey, null);

            using (Subscription sub = new Subscription(model, queueName))
            {
                foreach (BasicDeliverEventArgs ev in sub)
                { 
                    DoSomethingWithMessage(ev);
                    sub.Ack();
                }
            }
        }

Using .Net C# to import certificate to Microsoft Windows certificate store

Import the msmb.crt into your preferred Windows certificate store.

Example 

public void Connect()
        {
            string exchangeName = "msmb";
            string hostName = "OneView.domain";
            string queueName = "";
            string routingKey = "msmb.#";
            string userName = "rabbitmq_readonly";

            X509Store store = new X509Store(StoreName.Root, StoreLocation.LocalMachine);
            store.Open(OpenFlags.ReadWrite);

            X509Certificate cert = store.Certificates
                 .Find(X509FindType.FindBySubjectName, userName, false)
                 .OfType<X509Certificate>()
                 .First();

            ConnectionFactory factory = new ConnectionFactory();
            factory.AuthMechanisms = new RabbitMQ.Client.AuthMechanismFactory[] { new ExternalMechanismFactory() };
            factory.HostName = hostname;
            factory.Port = 5671;
            factory.Ssl.Certs = new X509CertificateCollection(new X509Certificate[] { cert });
            factory.Ssl.ServerName = hostname;
            factory.Ssl.Enabled = true;

            IConnection connection = factory.CreateConnection();
            IModel model = connection.CreateModel();

            queueName = model.QueueDeclare(queueName, false, false, false, null);
            model.QueueBind(queueName, exchangeName, routingKey, null);

            using (Subscription sub = new Subscription(model, queueName))
            {
                foreach (BasicDeliverEventArgs ev in sub)
                { 
                    DoSomethingWithMessage(ev);
                    sub.Ack();
                }
            }
        }

Example to connect and subscribe to MSMB using Java

//c://MyKeyStore contains client certificate and private key. Load it into Java Keystore
final char[] keyPassphrase = "MyKeyStorePassword".toCharArray();
final KeyStore ks = KeyStore.getInstance("jks");
ks.load(new FileInputStream("c://MyKeyStore"), keyPassphrase);
final KeyManagerFactory kmf = KeyManagerFactory.getInstance("SunX509");
kmf.init(ks, keyPassphrase);
 
//c://MyTrustStore contains CA certificate. Load it into Java Trust Store
final char[] trustPassphrase = "MyTrustStorePassword".toCharArray();
final KeyStore ks = KeyStore.getInstance("jks");
tks.load(new FileInputStream("c:\\MyTrustStore"), trustPassphrase);
final TrustManagerFactory tmf = TrustManagerFactory.getInstance("SunX509");
tmf.init(tks);
 
 
//load SSLContext with keystore and truststore.
final SSLContext c = SSLContext.getInstance("SSL");
c.init(kmf.getKeyManagers(), tmf.getTrustManagers(), new SecureRandom());
 
final ConnectionFactory factory = new ConnectionFactory();
factory.setHost("192.168.2.144");
 
//Set Auth mechanism to "EXTERNAL" so that commonName of the client certificate is mapped to AMQP user name. Hence, No need to set userId/Password here. 
factory.setSaslConfig(DefaultSaslConfig.EXTERNAL);
factory.setPort(5671);
factory.useSslProtocol(c);
 
final Connection conn = factory.newConnection();
final Channel channel = conn.createChannel();

//do not specify queue name. AMQP will create a queue with random name starting with amq.gen* e.g. amq.gen-32sfQz95QJ85K_lMBhU6HA
final DeclareOk queue = channel.queueDeclare("", true, false, true, null);
 
//Now get the queue name from above call and bind it to required Exchange with required routing key.
channel.queueBind(queue.getQueue(), "msmb", "msmb.#");
 
//Now you should be able to receive messages from queue
final GetResponse chResponse = channel.basicGet(queue.getQueue(), false);
if (chResponse == null)
{
    System.out.println("No message retrieved");
}
else
{
    final byte[] body = chResponse.getBody();
    System.out.println("Received: " + new String(body));
}
 
channel.close();
conn.close();