Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: neutral (nike.apache.org: 216.139.250.139 is neither permitted
 nor denied by domain of zzuzack1@gmail.com)
Date: Mon, 27 Aug 2012 12:48:06 -0700 (PDT)
From: TrainTime <zzuzack1@gmail.com>
To: users@activemq.apache.org
Message-ID: <1346096886327-4655632.post@n4.nabble.com>
Subject: C# Consumers Disconnecting
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

            I've been trying to figure out this problem I've been having with
apache NMS for at least a week now, so I decided maybe I would try to post
here and see if anyone has experienced similar issues.  In my situation, we
have about 5-7 producers all producing to one topic, and then we have one
consumer consuming data from the same topic.  However, this singular
consumer will suddenly disconnect from the broker with no indication to me
(that i've been able to find) and stop receiving anything, the only way to
tell is by checking the broker and seeing that the topic has no consumers. I
have been searching around these forums for a solution and here's a few
things I tried that didn't seem to make any difference:

         1. Set ?wireFormat.maxInactivityDuration=0 on my openWire transport
connector
         2. Set my IConnection and ISession to be auto acknowledge
         3. Changed the memory limit of topics to 100mb from 1 mb
         4. Call IMessage.Acknowledge after receiving a message
         5. Changed IConnection and ISession to be persistent object along
with the consumer

      I'm not sure what else at this point I have to try.  I'm using
activeMQ 5.6 SNAPSHOT which runs as a service, Apache.NMS 1.5.1.2739, and
Apache.NMS.ActiveMQ 1.5.6.2746.  Also one last thing, here's how I'm
creating my consumer in the C# code:

 //setup jms
                        IConnectionFactory factory = new
ConnectionFactory(_connectURI);

                        _connection = factory.CreateConnection();
                        _connection.AcknowledgementMode =
AcknowledgementMode.AutoAcknowledge;
                        _connection.ConnectionInterruptedListener +=
ConnectionLost;

                        _connection.Start();
                        _session =
_connection.CreateSession(AcknowledgementMode.AutoAcknowledge);

                        _consumer = _session.CreateConsumer(new
Apache.NMS.ActiveMQ.Commands.ActiveMQTopic(_topicName));
                        _consumer.Listener += ProcessItem;

                        _status.Status = ConnectorStatus.Running;
                        _status.Details = "JMS Connector is running";


And here's what the consumer listener function looks like:

public void ProcessItem(IMessage message)
        {
            message.Acknowledge();
             /*  code */
         }


I also tried looking at Apache logging a bit, but it didn't seem to output
anything useful.  I think I need to change what its logging, is ERROR the
correct syntax for the sl4j logging properties file?  Thanks in advance for
any help anyone can offer, this has been driving me nuts ><


--
View this message in context: http://activemq.2283324.n4.nabble.com/C-Consumers-Disconnecting-tp4655632.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.