Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Message-ID: <17905477.post@talk.nabble.com>
Date: Tue, 17 Jun 2008 06:56:55 -0700 (PDT)
From: neowill <usddkk@gmail.com>
To: users@activemq.apache.org
Subject: how many topics can I create in a broker before getting
 OutOfMemoryError: Java heap space
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit


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.