qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chuck Rolke <cro...@redhat.com>
Subject Re: Qpid c# client - 500 connections problem
Date Tue, 07 Jun 2011 13:37:50 GMT
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: paperman@gmx.at
> To: users@qpid.apache.org
> 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:users-subscribe@qpid.apache.org


Mime
View raw message