Я пытаюсь сделать простой pub/sub с ActiveMq. Я могу заставить все это работать нормально, но абонент отключается примерно через 30 секунд. Я искал значение типа тайм-аута, которое я могу изменить, но, похоже, ничего не работает. Вот подписчик:
using System;
using Apache.NMS;
using Apache.NMS.ActiveMQ;
using Apache.NMS.ActiveMQ.Commands;
namespace ActiveMQCatcher
{
internal class Program
{
private static void Main(string[] args)
{
IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616/");
using (IConnection connection = factory.CreateConnection())
{
connection.ClientId = "MYID";
connection.Start();
using (ISession session = connection.CreateSession())
{
IMessageConsumer consumer = session.CreateConsumer(new ActiveMQTopic("MYTOPIC"), null, false);
consumer.Listener += consumer_Listener;
Console.ReadLine();
}
connection.Stop();
}
}
private static void consumer_Listener(IMessage message)
{
Console.WriteLine("Got: " + ((ITextMessage) message).Text);
}
}
}
Я пробовал это:
connection.RequestTimeout = TimeSpan.MaxValue;
Но, похоже, это ничего не изменило.
Чтобы получить проблему, просто запустите программу и ждите около 30 секунд. Вы можете увидеть исчезновение соединения в консоли ActiveMQ (http://localhost:8161/admin/connections.jsp по умолчанию)
Есть идеи?
