Benutzer:MovGP0/ActiveMQ
Zur Navigation springen
Zur Suche springen
MovGP0 | Über mich | Hilfen | Artikel | Weblinks | Literatur | Zitate | Notizen | Programmierung | MSCert | Physik |
NMS API[Bearbeiten | Quelltext bearbeiten].Net Message Service API (NMS API) provides connectivity to[1]
NMS API WCF-Bindings[Bearbeiten | Quelltext bearbeiten]
JMS Message[Bearbeiten | Quelltext bearbeiten]
NMS API Consumer[Bearbeiten | Quelltext bearbeiten]using System;
using Apache.NMS;
using Apache.NMS.Util;
using Apache.NMS.ActiveMQ;
namespace MyApp
{
public class Consumer
{
public static void Main()
{
var nmsFactory = new NMSConnectionFactory("tcp://localhost:61616");
IConnection connection = nmsFactory.CreateConnection();
ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge);
IDestination destination = session.GetTopic("STOCKS.JAVA");
IMessageConsumer consumer = session.CreateConsumer(destination);
consumer.Listener += new MessageListener(OnMessage);
connection.Start();
Console.WriteLine("Press any key to quit.");
Console.ReadKey();
}
protected static void OnMessage(IMessage message)
{
var TextMessage = message as ITextMessage;
Console.WriteLine(TextMessage.Text);
}
}
}
Internetquellen[Bearbeiten | Quelltext bearbeiten]
Referenzen[Bearbeiten | Quelltext bearbeiten]
|