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 <[EMAIL PROTECTED]> 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. > >
