activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: No Exception thrown when KahaDB is FULL
Date Thu, 11 Jul 2013 13:28:33 GMT
use sendFailIfNoSpace see:
http://activemq.apache.org/producer-flow-control.html#ProducerFlowControl-ConfigureClientSideExceptions

On 11 July 2013 12:28, Gangadhar Rao <gangadhar.rao@netcracker.com> wrote:
> I am trying to test the below scenario where I am not seeing the expected
> result using the activemq CMS CPP library with persistence turned ON at the
> activemq broker level.
>
> *Scenario: *
> To test the behavior in sending a message to an activemq broker (persistance
> turned ON) with KahaDB being FULL (Reached its MAX limit)
>
> *Expected behavior:* We are expecting that the producer should receive an
> error while trying to send the message to the broker when the KahaDB is
> full.
>
> Steps:
> Configure an activemq broker with persistance turned ON at the broker level.
>
> Sent some messages to the queue configured on the broker. The messages are
> sent till the KahaDB is FULL.
>
> Once the KahaDB is full (Reached its MAX limit), the producer stopped
> sending the messages and was waiting in definitely to send the message which
> can be seen from the below logs.
>
> pstack of the Producer
> ----------------------
> #0  0x0000003f7020aee9 in pthread_cond_wait@@GLIBC_2.3.2 () from
> /lib64/libpthread.so.0
> #1  0x00002b22c052a027 in
> *decaf::internal::util::concurrent::ConditionImpl::wait(decaf::util::concurrent::ConditionHandle*)
> () from
> /tools/apache-activemq/activemq-cpp-library-3.4.5/lib/libactivemq-cpp.so.14*
> #2  0x00002b22c058c155 in decaf::util::concurrent::CountDownLatch::await()
> () from
> /tools/apache-activemq/activemq-cpp-library-3.4.5/lib/libactivemq-cpp.so.14
> #3  0x00002b22c040aacd in
> activemq::transport::correlator::FutureResponse::getResponse() () from
> /tools/apache-activemq/activemq-cpp-library-3.4.5/lib/libactivemq-cpp.so.14
> #4  0x00002b22c0409d33 in
> activemq::transport::correlator::ResponseCorrelator::request(decaf::lang::Pointer<activemq::commands::Command,
> decaf::util::concurrent::atomic::AtomicRefCounter> const&) () from
> /tools/apache-activemq/activemq-cpp-library-3.4.5/lib/libactivemq-cpp.so.14
> #5  0x00002b22c0347473 in
> activemq::core::ActiveMQConnection::syncRequest(decaf::lang::Pointer<activemq::commands::Command,
> decaf::util::concurrent::atomic::AtomicRefCounter>, unsigned int) () from
> /tools/apache-activemq/activemq-cpp-library-3.4.5/lib/libactivemq-cpp.so.14
> #6  0x00002b22c039378b in
> activemq::core::ActiveMQSession::send(cms::Message*,
> activemq::core::ActiveMQProducer*, activemq::util::Usage*) () from
> /tools/apache-activemq/activemq-cpp-library-3.4.5/lib/libactivemq-cpp.so.14
> #7  0x00002b22c038102d in
> activemq::core::ActiveMQProducer::send(cms::Destination const*,
> cms::Message*, int, int, long long) () from
> /tools/apache-activemq/activemq-cpp-library-3.4.5/lib/libactivemq-cpp.so.14
> #8  0x00002b22c0381bbb in
> activemq::core::ActiveMQProducer::send(cms::Destination const*,
> cms::Message*) () from
> /tools/apache-activemq/activemq-cpp-library-3.4.5/lib/libactivemq-cpp.so.14
> #9  0x00002b22c0382bae in
> activemq::core::ActiveMQProducer::send(cms::Message*) () from
> /tools/apache-activemq/activemq-cpp-library-3.4.5/lib/libactivemq-cpp.so.14
>
> Activemq Logs
> -----------------
> 2013-07-11 11:32:29,264 | INFO  |
> Usage(default:store:queue://Realtime_Q:store) percentUsage=99%,
> usage=1089068, limit=1048576,
> percentUsageMinDelta=1%;Parent:Usage(default:store) percentUsage=103%,
> usage=1089068, limit=1048576, percentUsageMinDelta=1%: *Persistent store is
> Full, 100% of 1048576*. Stopping producer
> (ID:hornbeam-42586-1373538545071-0:1:0:0) to prevent flooding
> queue://Realtime_Q. See
> http://activemq.apache.org/producer-flow-control.html for more info
> (blocking for: 185s) | org.apache.activemq.broker.region.Queue | ActiveMQ
> Transport: tcp:///10.29.9.86:53002@8058
>
> Activemq broker Configuration
> persistent="true"  at the broker level
> broker connect string is of the below format:
> tcp://hostname:port
>
> Question: Can any one tell whether the producer would receive any error
> while sending the message to the broker when the KahaDB is full. And also in
> order to receive the error for the scenario which I have mentioned above
> what configuration changes I need to do.
>
>
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/No-Exception-thrown-when-KahaDB-is-FULL-tp4669128.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.



-- 
http://redhat.com
http://blog.garytully.com

Mime
View raw message