activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dave Stanley" <dstanl...@gmail.com>
Subject Re: how many topics can I create in a broker before getting OutOfMemoryError: Java heap space
Date Tue, 17 Jun 2008 14:12:08 GMT
You can change the the maximum heap size for the JVM by tweaking the -Xmx
setting in <ActiveMQ>/bin/activemq.bat. There will be a memory and
processing overhead for each topic you create. Is it possible to reduce the
number of Topics and just send more messages to each Topic?

Regards,
/Dave
On Tue, Jun 17, 2008 at 9:56 AM, neowill <usddkk@gmail.com> wrote:

>
> Hi everyone,
>
> I am hoping someone might give me an idea how to deal with this issue:
>
> I am running ActiveMQ 5.1.0 on a Windows XP desktop, java version 1.5.0,
> default setting from the ActiveMQ download package.
> I change the example source ProducerTool.java from creating one topic and
> send 2000 message to creating 2000 topics and send 1 message for each
> topic.
> And then I got the OOME.
>
> basicly in the producerTool, I have one connection, one session. 2000
> topics..... cannot ActiveMQ support that? How to increase the capability of
> ActiveMQ to create as many topics as I want, like 20,000?
>
> Thanks in advance!!
>
> java.lang.OutOfMemoryError: Java heap space
>        at
>
> org.apache.activemq.util.DataByteArrayOutputStream.<init>(DataByteArrayOutputStream.java:45)
>        at
> org.apache.activemq.kaha.impl.index.hash.HashIndex.load(HashIndex.java:198)
>        at
>
> org.apache.activemq.kaha.impl.container.MapContainerImpl.load(MapContainerImpl.java:103)
>        at
>
> org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter.getSubsMapContainer(KahaPersistenceAdapter.java:222)
>        at
>
> org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter.createTopicReferenceStore(KahaReferenceStoreAdapter.java:169)
>        at
>
> org.apache.activemq.store.amq.AMQPersistenceAdapter.createTopicMessageStore(AMQPersistenceAdapter.java:454)
>        at
>
> org.apache.activemq.broker.region.DestinationFactoryImpl.createDestination(DestinationFactoryImpl.java:94)
>        at
>
> org.apache.activemq.broker.region.AbstractRegion.createDestination(AbstractRegion.java:425)
>        at
>
> org.apache.activemq.broker.jmx.ManagedTopicRegion.createDestination(ManagedTopicRegion.java:56)
>        at
>
> org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:120)
>        at
>
> org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:266)
>        at
>
> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:141)
>        at
>
> org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:147)
>        at
>
> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:141)
>        at
>
> org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:148)
>        at
> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:425)
>        at
>
> org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:224)
>        at
> org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:125)
>        at
>
> org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:95)
>        at
>
> org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:132)
>        at
>
> org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:437)
>        at
> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:624)
>        at
>
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
>        at
>
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:180)
>        at
>
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
>        at
>
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
>        at
>
> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
>        at
>
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
>        at
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:196)
>        at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:183)
>        at java.lang.Thread.run(Thread.java:595)
>
>
> --
> View this message in context:
> http://www.nabble.com/how-many-topics-can-I-create-in-a-broker-before-getting-OutOfMemoryError%3A-Java-heap-space-tp17905477p17905477.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>

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