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]
