qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From qpid_user <knitheshshe...@yahoo.com>
Subject Re: how to resolve Enqueue capacity threshold exceeded error
Date Wed, 15 Apr 2009 05:29:01 GMT

hi Carl

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);
    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.

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)


The two agrs are  "qpid.file_count"  & "qpid.file_size"  used on queue 

View this message in context: http://n2.nabble.com/how-to-resolve-Enqueue-capacity-threshold-exceeded-error-tp2626671p2637032.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.

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

View raw message