activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sparky2708 <>
Subject PLEASE ADD BUG: Queue gets clogged in OpenWire.NET when using Listener
Date Mon, 07 Aug 2006 13:10:14 GMT

Updated the client just now. This seems like a confirmed bug in OpenWire.NET
but I can't figure out how to submit this using your bug tracking software.
Please submit this for me. Easiest way to reproduce the bug would be to
start the consumer using the following code and then AFTER the consumer
starts, start some producer (either java or C#) and you will notice that the
consumer will not get any messages (seems like calling Receive() on the
consumer at least once will make you lose a message but the listener will
kick back in):

using System;
using ActiveMQ;
using ActiveMQ.Commands;
using NMS;

namespace JMSClient
    /// <summary>
    /// Summary description for Class1.
    /// </summary>
    class Class1
        /// <summary>
        /// The main entry point for the application.
        /// </summary>
        static void Main(string[] args)
            IConnectionFactory factory = new ConnectionFactory(new
            using (IConnection connection = factory.CreateConnection())
                Console.WriteLine("Created a connection!");

                ISession session = connection.CreateSession();
                IDestination destination =
                Console.WriteLine("Using destination: " + destination);

                // lets create a consumer and producer
                IMessageConsumer consumer =
                consumer.Listener += new MessageListener(consumer_Listener);

                while (true);

        static void consumer_Listener(IMessage message)
            if (message == null)
                Console.WriteLine("No message received!");
                Console.WriteLine("Received message with text: " +

View this message in context:
Sent from the ActiveMQ - User forum at

View raw message