Hi,
i forgot to paste the output of the test earlier, as you can see the
test fails when checking the prefetch size for
the reconnected subscriber.
Best regards
Andreas
Discovery starting.
Discovery completed in 374 milliseconds.
Run starting. Expected test count is: 1
PrefetchSizeSpec:
2014-10-01 18:25:13,887 |
de.woq.test.amq.PrefetchSizeSpec | INFO
| Starting Active MQ broker
2014-10-01 18:25:14,114 |
org.apache.activemq.broker.BrokerService | INFO
| Using Persistence Adapter: MemoryPersistenceAdapter
2014-10-01 18:25:14,115 |
org.apache.activemq.broker.jmx.ManagementContext | INFO
| JMX consoles can connect to
service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
2014-10-01 18:25:14,261 |
org.apache.activemq.broker.BrokerService | INFO
| Apache ActiveMQ 5.10.0 (prefetchTest,
ID:woqlinux.wayofquality.de-60625-1412180714126-0:1) is starting
2014-10-01 18:25:14,265 |
org.apache.activemq.broker.BrokerService | INFO
| Apache ActiveMQ 5.10.0 (prefetchTest,
ID:woqlinux.wayofquality.de-60625-1412180714126-0:1) started
2014-10-01 18:25:14,265 |
org.apache.activemq.broker.BrokerService | INFO
| For help or more information please see: http://activemq.apache.org
2014-10-01 18:25:14,289 |
de.woq.test.amq.PrefetchSizeSpec | INFO
| ActiveMQ broker started
A Durable subscription
2014-10-01 18:25:14,318 |
org.apache.activemq.broker.TransportConnector | INFO
| Connector vm://prefetchTest started
2014-10-01 18:25:14,372 |
de.woq.test.amq.PrefetchSizeSpec | INFO
| Creating durable subscriber and checking prefetch size...
2014-10-01 18:25:14,469 |
org.apache.activemq.broker.TransportConnector | INFO
| Connector vm://prefetchTest stopped
2014-10-01 18:25:14,469 |
org.apache.activemq.broker.TransportConnector | INFO
| Connector vm://prefetchTest started
2014-10-01 18:25:14,478 |
de.woq.test.amq.PrefetchSizeSpec | INFO
| Creating durable subscriber and checking prefetch size...
- should honor the broker defined prefetch size on reconnect *** FAILED ***
1000 was not equal to 5 (PrefetchSizeSpec.scala:93)
2014-10-01 18:25:14,508 |
org.apache.activemq.broker.BrokerService | INFO
| Apache ActiveMQ 5.10.0 (prefetchTest,
ID:woqlinux.wayofquality.de-60625-1412180714126-0:1) is shutting down
2014-10-01 18:25:14,511 |
org.apache.activemq.broker.TransportConnector | INFO
| Connector vm://prefetchTest stopped
2014-10-01 18:25:14,521 |
org.apache.activemq.broker.BrokerService | INFO
| Apache ActiveMQ 5.10.0 (prefetchTest,
ID:woqlinux.wayofquality.de-60625-1412180714126-0:1) uptime 0.567 seconds
2014-10-01 18:25:14,521 |
org.apache.activemq.broker.BrokerService | INFO
| Apache ActiveMQ 5.10.0 (prefetchTest,
ID:woqlinux.wayofquality.de-60625-1412180714126-0:1) is shutdown
2014-10-01 18:25:14,521 |
de.woq.test.amq.PrefetchSizeSpec | INFO
| ActiveMQ broker stopped.
Run completed in 1 second, 56 milliseconds.
Total number of tests run: 1
Suites: completed 2, aborted 0
Tests: succeeded 0, failed 1, canceled 0, ignored 0, pending 0
*** 1 TEST FAILED ***
On 01/10/14 17:09, Andreas Gies wrote:
Hello,
I am using Active MQ 5.10 within a Karaf based application and have
spent the last couple of days
investigating an OOM Exception we were getting occasionally.
It turned out, that the OOM happens occasionallly when we reconnect a
durable subscriber that
would have a large amount of data in it even though we have specified
a rather small prefetch
size for durable subscribers (5) within the broker configuration.
Further analysis showed that after closing and reconnecting the same
subscriber it has a prefetch
size of 1000 (the default value). That would cause an OOM if those
1000 messages exceed the
JVM heap size.
Specifying the prefetch size within the broker url from the client
side works fine, but we would like
to keep the setiing on the broker side as not all clients are our
development responsibility.
I have attached a test case that demonstrates this observation.
Is this a know issue or should I create a JIRA ticket for this ?
Thanks and best regards
Andreas
--
Andreas Gies
WoQ – Way of Quality GmbH
Geschäftsführer & CTO
/eMail:/andr...@wayofquality.de <mailto:andr...@wayofquality.de>
/Tel:/ +49 151 23470823
/Fax:/ +49 1805 006534 2114
/Twitter:/ andreasgies /Skype:/ giessonic
/LinkedIn:/ <http://de.linkedin.com/pub/andreas-gies/0/594/aa5/>
(http://de.linkedin.com/pub/andreas-gies/0/594/aa5/)
/Xing:/ <http://www.xing.com/profile/Andreas_Gies>
(http://www.xing.com/profile/Andreas_Gies)
/Blog:/ <http://www.wayofquality.de/index.php/en/blog>
(http://www.wayofquality.de/index.php/en/blog)
/Github:/ <https://github.com/atooni> (https://github.com/atooni)
/Amtsgericht Landshut:/HRB 8352//
//
/Ust.-Id.:/ DE274771254
Haftungsausschluss
Diese Email kann vertrauliche und/oder rechtlich geschützte
Informationen enthalten und ist ausschließlich für den/die benannten
Adressaten bestimmt. Sollten Sie nicht der beabsichtigte Empfänger
sein oder diese Email irrtümlich erhalten haben, ist es Ihnen nicht
gestattet diese Mail oder einen Teil davon ohne unsere Erlaubnis zu
verbreiten, zu kopieren, unbefugt weiterzuleiten oder zu behalten.
Informieren Sie bitte sofort den Absender telefonisch oder per Email
und löschen Sie diese Email und alle Kopien aus Ihrem System. Wir
haften nicht für die Unversehrtheit von Emails, nachdem sie unseren
Einflussbereich verlassen haben.
Disclaimer
This email may contain confidential and/or privileged information and
is intended solely for the attention and use of the named
addressee(s). If you are not the intended recipient, or a person
responsible for delivering it to the intended recipient, you are not
authorized to and must not disclose, copy, distribute, or retain this
message or any part of it without our authority. Please contact the
sender by call or reply email immediately and destroy all copies and
the original message. We are not responsible for the integrity of
emails after they have left our sphere of control.
//
--
Andreas Gies
WoQ – Way of Quality GmbH
Geschäftsführer & CTO
/eMail:/andr...@wayofquality.de <mailto:andr...@wayofquality.de>
/Tel:/ +49 151 23470823
/Fax:/ +49 1805 006534 2114
/Twitter:/ andreasgies /Skype:/ giessonic
/LinkedIn:/ <http://de.linkedin.com/pub/andreas-gies/0/594/aa5/>
(http://de.linkedin.com/pub/andreas-gies/0/594/aa5/)
/Xing:/ <http://www.xing.com/profile/Andreas_Gies>
(http://www.xing.com/profile/Andreas_Gies)
/Blog:/ <http://www.wayofquality.de/index.php/en/blog>
(http://www.wayofquality.de/index.php/en/blog)
/Github:/ <https://github.com/atooni> (https://github.com/atooni)
/Amtsgericht Landshut:/HRB 8352//
//
/Ust.-Id.:/ DE274771254
Haftungsausschluss
Diese Email kann vertrauliche und/oder rechtlich geschützte
Informationen enthalten und ist ausschließlich für den/die benannten
Adressaten bestimmt. Sollten Sie nicht der beabsichtigte Empfänger sein
oder diese Email irrtümlich erhalten haben, ist es Ihnen nicht gestattet
diese Mail oder einen Teil davon ohne unsere Erlaubnis zu verbreiten, zu
kopieren, unbefugt weiterzuleiten oder zu behalten. Informieren Sie
bitte sofort den Absender telefonisch oder per Email und löschen Sie
diese Email und alle Kopien aus Ihrem System. Wir haften nicht für die
Unversehrtheit von Emails, nachdem sie unseren Einflussbereich verlassen
haben.
Disclaimer
This email may contain confidential and/or privileged information and is
intended solely for the attention and use of the named addressee(s). If
you are not the intended recipient, or a person responsible for
delivering it to the intended recipient, you are not authorized to and
must not disclose, copy, distribute, or retain this message or any part
of it without our authority. Please contact the sender by call or reply
email immediately and destroy all copies and the original message. We
are not responsible for the integrity of emails after they have left our
sphere of control.
//
