qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From paper...@gmx.at
Subject Qpid c# client - 500 connections problem
Date Tue, 07 Jun 2011 09:14:38 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message