|
|
| (5 intermediate revisions by 3 users not shown) |
| Line 1: |
Line 1: |
| <code>
| | #REDIRECT [[C_Sharp_Examples]] |
| 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.com: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);
| |
| }
| |
| }
| |
| }
| |
| }
| |
| </code>
| |
| | |
| For a full explanation of the code and how to use it, please see [http://gavincoates.com/c-activemq-stomp Gavins blog]. This code will connect to the Train Movements (All) data feed, and display the messages as they are displayed.
| |
