Queue Fill Up

[sub3 <st...@subwest.com>]

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 =
org.apache.activemq.util.ByteSequence@196f4b5, 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.

Re: Queue Fill Up

[mcarter <mc...@funnelback.com>]

I get exactly the same issue. The only way I've found to get rid of it is to
not use the fileQueueCursor pendingQueuePolicy

-- 
View this message in context: http://www.nabble.com/Queue-Fill-Up-tp15917723p21907015.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.