C Sharp Examples

Apache NMS
This code will connect to the TRAIN_MVT_ALL_TOC topic and display all messages. For more details on this client, see Gavin's blog.

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.IO; using Apache.NMS;

namespace ApacheNMS {   class Program {       static void Main(string[] args) {           IConnectionFactory factory = new NMSConnectionFactory(new Uri("stomp:tcp://datafeeds.networkrail.co.uk:61618"));

IConnection connection = factory.CreateConnection("username", "password"); ISession session = connection.CreateSession;

IDestination destination = session.GetDestination("topic://" + "TRAIN_MVT_ALL_TOC"); IMessageConsumer consumer = session.CreateConsumer(destination);

connection.Start; consumer.Listener += new MessageListener(OnMessage); Console.WriteLine("Consumer started, waiting for messages... (Press ENTER to stop.)");

Console.ReadLine; connection.Close; }

private static void OnMessage(IMessage message) {           try {               Console.WriteLine("Median-Server (.NET): Message received");

ITextMessage msg = (ITextMessage)message; message.Acknowledge;

Console.WriteLine(msg.Text); }           catch (Exception ex) {               Console.WriteLine(ex.Message); Console.WriteLine("---"); Console.WriteLine(ex.InnerException); Console.WriteLine("---"); Console.WriteLine(ex.InnerException.Message); }       }    } }