qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gordon Sim <g...@redhat.com>
Subject Re: how to resolve Enqueue capacity threshold exceeded error
Date Wed, 15 Apr 2009 08:44:34 GMT
qpid_user wrote:
> please let me know what is incorrect in  the following declare_queues.cpp code:
>                   :
>                   :
>     FieldTable pers;
>     pers.setInt("file_size", 128);
>     pers.setInt("file_count", 64);

I believe this should be:


      pers.setInt("qpid.file_size", 128);
      pers.setInt("qpid.file_count", 64);

>     try {
>       connection.open(host, port);
>       Session session =  connection.newSession();
>       session.queueDeclare(arg::queue="message_queue", arg::durable=true, arg::arguments=pers);
>                    :
>                    :
> I execute broker with  following command
> ./qpidd -p 5004 --auth no --default-queue-limit 0 --load-module msgstore.so
> and producer sends 100000 persistent messages, each msg being 2720Bytes size.

I.e. you need at least 272,000,000 bytes capacity. The default 'page 
size' is 32k so each file will be 128*32k=4096k, and 64 files of that 
size would give you 262,144,000. I think you may run out of space even 
with those settings.

> producer throws error:
> 2009-apr-15 10:58:35 warning Broker closed connection: 501, Enqueue capacity threshold
exceeded on queue "message_queue". (JournalImpl.cpp:575)
> framing-error: Enqueue capacity threshold exceeded on queue "message_queue". (JournalImpl.cpp:575)
> 
> Thanks
> 
> 
> 
> The two agrs are  "qpid.file_count"  & "qpid.file_size"  used on queue 
> declare.
> 
> Carl.


---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org


Mime
View raw message