Hi Chuck, unfortunately the erros all occur localhost under Win XP 32bit with qpid 0.10 as c# client AND 0.10 c++ broker.
I try to install qpid under linux ... although i think there must be another problem. Joe -------- Original-Nachricht -------- > Datum: Tue, 7 Jun 2011 09:37:50 -0400 (EDT) > Von: Chuck Rolke <[email protected]> > An: [email protected] > Betreff: Re: Qpid c# client - 500 connections problem > Hi Joe, > > I think this issue is actually with the broker and not with the client. I > had the same issue when running against a 0.8 windows broker; the issue > does not exist for 0.8 linux brokers. See issue > https://issues.apache.org/jira/browse/QPID-2967 > > The fix for this was checked in after the 0.8 release and is in 0.10. You > can try running a 0.10 broker or running against a linux broker. > > Another test to prove this theory is to run 500 connections on the client > and then pause. Restart the broker and resume the client and it should do > another 500 connections. > > -Chuck > > ----- Original Message ----- > > From: [email protected] > > To: [email protected] > > Sent: Tuesday, June 7, 2011 5:14:38 AM > > Subject: Qpid c# client - 500 connections problem > > Hi dear qpid-users, > > > > i'm new to qpid and tried to access qpid over c#. I copied the c# > > sample > > from the qpid-doc and tried to send over 1000 messages - after 500 > > messages > > i always get a "Client max connection count limit exceeded: 500 > > connection > > refused". > > I'm using qpid 0.10 32bit in c# 3.5. Can anybody help me - where is > > the > > mistake? > > > > Here is my sample code > > (from > > > http://qpid.apache.org/books/0.8/Programming-In-Apache-Qpid/pdf/Programming-In-Apache-Qpid.pdf > > - example 2.3 on page 5) > > > > using System; > > using System.Collections.Generic; > > using System.Linq; > > using System.Text; > > using Org.Apache.Qpid.Messaging; > > namespace Qpid500Test > > { > > class Program > > { > > static void Main(string[] args) > > { > > for (int i = 0; i < 1000; i++) > > { > > String broker = args.Length > 0 ? args[0] : "localhost:5672"; > > String address = args.Length > 1 ? args[1] : "amq.topic"; > > Connection connection = null; > > try > > { > > connection = new Connection(broker); > > connection.Open(); > > Session session = connection.CreateSession(); > > Receiver receiver = session.CreateReceiver(address); > > Sender sender = session.CreateSender(address); > > sender.Send(new Message("Hello world!")); > > Message message = new Message(); > > message = receiver.Fetch(DurationConstants.SECOND * 1); > > Console.WriteLine("{0}", message.GetContent()); > > session.Acknowledge(); > > connection.Close(); > > } > > catch (Exception e) > > { > > Console.WriteLine("Exception {0}.", e); > > if (null != connection) connection.Close(); > > } > > } > > } > > } > > > > Thanks in advance, > > > > Yours > > Joe > > > > -- > > > > > > NEU: FreePhone - kostenlos mobil telefonieren! > > Jetzt informieren: http://www.gmx.net/de/go/freephone > > --------------------------------------------------------------------- > Apache Qpid - AMQP Messaging Implementation > Project: http://qpid.apache.org > Use/Interact: mailto:[email protected] > -- NEU: FreePhone - kostenlos mobil telefonieren! Jetzt informieren: http://www.gmx.net/de/go/freephone --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected]
