A connection will hold on to messages that's trying to deliver to it's
client until the broker detects that the connection has failed.
In the last case is you main thread blocked somewhere?
On Thu, Aug 14, 2008 at 8:07 AM, SebastianR.
<[EMAIL PROTECTED]> wrote:
>
> Hello,
>
> First of all my setup:
> NMS: Yesterdays HEAD SVN revision
> Broker: external broker running on ActiveMQ 4.1.1
> .Net Framework: 2.0
> IDE: MS Visual Studio 2008 with C# as programming language
>
> I recognize very strange behaviour when it comes to a connection failure. To
> show this I wrote a little test program, which reproduces this behaviour.
> The code is the following:
>
> using System;
> using System.Collections.Generic;
> using System.Text;
> using Apache.NMS;
> using Apache.NMS.ActiveMQ;
>
> namespace ExceptionTest
> {
> class Program
> {
> static private IConnectionFactory m_Factory;
> static private IConnection m_Connection;
> static private ISession m_SenderSession;
> static private ISession m_ReceiverSession;
> static private IDestination m_SenderQueue;
> static private IDestination m_ReceiverQueue;
> static private IMessageProducer m_Producer;
> static private IMessageConsumer m_Receiver;
>
> static void Main(string[] args)
> {
> Init();
> try
> {
> for (int i = 1; i <= 50; i++)
> {
> ITextMessage msg =
> m_SenderSession.CreateTextMessage(i.ToString());
>
> Console.WriteLine("Before Sending: " + i.ToString());
> m_Producer.Send(msg);
> Console.WriteLine("After Senden: " + i.ToString());
> }
> }
> catch (Exception e)
> {
> Console.WriteLine(e.ToString());
> }
>
> Console.ReadLine(); // Here I plug in the network cable
>
> //Optional Re-Connect (refered to as variant 1)
> //m_Connection.Stop();
> //m_ReceiverSession.Dispose();
> //m_SenderSession.Dispose();
> //m_Connection.Dispose();
> //Init();
>
> while (true)
> {
> ITextMessage msg = (ITextMessage) m_Receiver.Receive(new
> TimeSpan(0,0,0,2));
> m_ReceiverSession.Commit();
>
> if(msg != null)
> {
> Console.WriteLine("Message: " + msg.Text);
> }
> else
> {
> Console.WriteLine("No Message available !");
> break;
> }
> }
> Console.ReadLine();
> }
>
> static private void Init()
> {
> try
> {
> m_Factory = new ConnectionFactory(new
> Uri("tcp://192.168.3.79:61616"));
> m_Connection = m_Factory.CreateConnection("de", "power");
> m_ReceiverSession =
> m_Connection.CreateSession(AcknowledgementMode.Transactional);
> m_SenderSession =
> m_Connection.CreateSession(AcknowledgementMode.AutoAcknowledge);
> m_SenderQueue = m_SenderSession.GetQueue("outbound");
> m_ReceiverQueue = m_ReceiverSession.GetQueue("outbound");
> m_Producer = m_SenderSession.CreateProducer(m_SenderQueue);
> m_Receiver =
> m_ReceiverSession.CreateConsumer(m_ReceiverQueue);
> m_Connection.Start();
> }
> catch (Exception e)
> {
> Console.WriteLine(e.ToString());
> }
> }
> }
> }
>
>
> Basically the program's application flow is the following:
> 1. Initiate NMS components
> 2. Send or better try to send 50 messages --> here is where I pull the
> network plug to abort the connection
> 3. OPTIONAL (variant 1, commented out in the code above): Close the
> connection and re-connect (initialize again)
> 4. Receive as many messages as possible
>
> The important things are logged to the console (sending and receiving
> messages, exceptions).
>
> Now there are the following testcases:
>
> Without step 3. and without manual connection abort, everything is fine.
>
> Without step 3. and with manual connection abort by pulling the network
> plug, I receive an exception (as expected). After going on with the receive
> part (without any reconnecting method, as said before), I receive all
> messages until the connection abort, even the message on which the exception
> (an Apache.NMS.ActiveMQ.BrokerException) is thrown. So although the program
> only reaches the "Before Sending .."-statement, I receive this message -->
> very strange
>
> With step 3. and without manual connection abort, everything is fine.
>
> With step 3. and with manual connection abort, I receive no message at all,
> although some have been send correctly to the queue before connection abort.
> Actually I know they are in the queue, because I wrote a separate Java
> programm, a queuebrowser, which lists all correctly sent messages (also
> again including the message the exception was thrown on). --> very strange
> I recognized however, if I send a message into the queue before the failing
> receive try (but after the re-connect) the queuebrowser lists those messages
> too, but I still can't receive any of them. Only way to get out all the
> messsages in the queue is restarting the program at let it run without any
> connection abort.
>
> Has anyone watched such behavior or knows the reason for this ?
>
> Regards, Sebastian
>
> --
> View this message in context:
> http://www.nabble.com/NMS%3A-Strange-behavior-when-re-connecting-after-connection-abort-tp18980283p18980283.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
Regards,
Hiram
Blog: http://hiramchirino.com
Open Source SOA
http://open.iona.com
