Hi,
I am using VirtualTopics and when I start nailing the system with messages,
ActiveMQ starts to throw null pointers. Since I am putting out a lot of
messages, I am assuming some internal queue if filling up. Is that right?
I though ActiveMQ would slow down in this instance. Is there a parameter I
need to use to enforce this?
I am using a Snapshot from 2/28. (Newer snapshot complains about Virtual
Topics 'The subscription does not exist' so I can't see if it is a code
issue).
Thanks for any help you can give.
272972 ERROR [ActiveMQ Transport: tcp:///127.0.0.1:55246]
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor - Caught
an Exception adding a message: ActiveMQObjectMessage {commandId = 1928,
responseRequired = false, messageId =
ID:norfolk.atl.lmco.com-55237-1204992725457-0:2:1:1:1924,
originalDestination = null, originalTransactionId = null, producerId =
ID:norfolk-55237-1204992725457-0:2:1:1, destination =
topic://VirtualTopic.trackUpdate, transactionId = null, expiration = 0,
timestamp = 1204992751142, arrival = 0, brokerInTime = 1204992751142,
brokerOutTime = 0, correlationId = null, replyTo = null, persistent = false,
type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
[EMAIL PROTECTED], marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 15619, properties =
null, readOnlyProperties = false, readOnlyBody = false, droppable = false}
first to FilePendingMessageCursor
java.lang.NullPointerException
at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.getDiskList(FilePendingMessageCursor.java:379)
at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.addMessageLast(FilePendingMessageCursor.java:190)
at
org.apache.activemq.broker.region.cursors.StoreQueueCursor.addMessageLast(StoreQueueCursor.java:94)
at
org.apache.activemq.broker.region.Queue.sendMessage(Queue.java:945)
at
org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:458)
at org.apache.activemq.broker.region.Queue.send(Queue.java:406)
at
org.apache.activemq.broker.region.DestinationFilter.send(DestinationFilter.java:118)
at
org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor.send(VirtualTopicInterceptor.java:45)
at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:331)
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:436)
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:135)
at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:434)
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:623)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:170)
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:619)
--
View this message in context:
http://www.nabble.com/Queue-Fill-Up-tp15917723s2354p15917723.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
