You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Hiram Chirino (JIRA)" <ji...@apache.org> on 2006/06/12 22:35:51 UTC
[jira] Updated: (AMQ-275) Could not enqueue message and Too many
open files
[ https://issues.apache.org/activemq/browse/AMQ-275?page=all ]
Hiram Chirino updated AMQ-275:
------------------------------
Fix Version: 3.2.4
(was: 3.1)
> Could not enqueue message and Too many open files
> -------------------------------------------------
>
> Key: AMQ-275
> URL: https://issues.apache.org/activemq/browse/AMQ-275
> Project: ActiveMQ
> Type: Bug
> Components: Broker
> Versions: 3.0
> Environment: Windows 2000/XP SP2
> Reporter: Glen Klyuzner
> Fix For: 3.2.4
> Attachments: patchfile.txt
>
>
> Relaited to slow consumer condition.
> WARN 2005-06-22 12:55:44,135 - Queue is full, waiting for it to be dequeued.
> 2005-06-22 11:51:09,678 [ocalport=61616]] WARN BrokerClientImpl - Connection: ID:ny-cap-33-2024-1119453996333-6:0 is a slow consumer
> 2005-06-22 11:51:09,678 [ocalport=61616]] WARN BrokerClientImpl - Connection: ID:ny-cap-33-2024-1119453996333-6:0 is a slow consumer
> 2005-06-22 11:51:09,694 [ocalport=61616]] INFO DataContainer - making directory for temporary spooled data: ActiveMQTemp
> 2005-06-22 11:51:11,069 [ocalport=61616]] WARN BrokerClientImpl - Connection: ID:ny-cap-33-2005-1119453893347-6:0 is a slow consumer
> 2005-06-22 11:51:11,069 [ocalport=61616]] WARN BrokerClientImpl - Connection: ID:ny-cap-33-2005-1119453893347-6:0 is a slow consumer
> 2005-06-22 11:51:17,288 [ocalport=61616]] DEBUG ientTopicBoundedMessageManager - Adding consumer: CONSUMER_INFO: id = 336 ConsumerInfo{ browser = false, destination = ActiveMQ.Advisory.TempDestinations.temp-queue.TemporaryQueue-{TD{ID:ny-cap-33-2150-1119455437835-16:0}TD}ID:ny-cap-33-2150-1119455437835-23:0, consumerIdentifier = 'ID:ny-cap-33-2024-1119453996333-16:0.27.53' , clientId = 'ID:ny-cap-33-2024-1119453996333-16:0' , sessionId = '27' , consumerName = '' , selector = '' , startTime = 1119455477008, started = true, consumerNo = 53, noLocal = false, prefetchNumber = 1000, consumerKey = '[ID:ny-cap-33-2024-1119453996333-16:0:]' }
> 2005-06-22 11:51:54,773 [ocalport=61616]] ERROR BrokerClientImpl - Could not enqueue message ACTIVEMQ_OBJECT_MESSAGE: id = 0 ActiveMQMessage{ , jmsMessageID = ID:ny-cap-33-2005-1119453893347-68:121589, bodyAsBytes = org.activemq.io.util.ByteArray@1f07377, readOnlyMessage = false, jmsClientID = 'ID:ny-cap-33-2005-1119453893347-6:0' , jmsCorrelationID = 'null' , jmsDestination = Topic.sds.PropertyTemplatePublisher, jmsReplyTo = null, jmsDeliveryMode = 2, jmsRedelivered = false, jmsType = 'null' , jmsExpiration = 1119455573508, jmsPriority = 4, jmsTimestamp = 1119455513508, properties = null, readOnlyProperties = false, entryBrokerName = 'ID:nyotc023-2882-1119382254093-0:0' , entryClusterName = 'default' , consumerNos = [I@12cb4ae, transactionId = 'null' , xaTransacted = false, consumerIdentifer = 'null' , messageConsumed = false, transientConsumed = false, sequenceNumber = 121589, deliveryCount = 1, dispatchedFromDLQ = false, messageAcknowledge = null, jmsMessageIdentity = null, producerKey = ID:ny-cap-33-2005-1119453893347-68: } ActiveMQObjectMessage{ object = null } to SpooledBoundedQueue for this slow consumer
> javax.jms.JMSException: enqueNoBlock failed: Too many open files
> at org.activemq.io.util.SpooledBoundedActiveMQMessageQueue.enqueueNoBlock(SpooledBoundedActiveMQMessageQueue.java:121)
> at org.activemq.io.util.SpooledBoundedActiveMQMessageQueue.enqueue(SpooledBoundedActiveMQMessageQueue.java:91)
> at org.activemq.broker.impl.BrokerClientImpl.dispatch(BrokerClientImpl.java:198)
> at org.activemq.service.boundedvm.TransientTopicBoundedMessageContainer.dispatchToQueue(TransientTopicBoundedMessageContainer.java:223)
> at org.activemq.service.boundedvm.TransientTopicBoundedMessageContainer.targetAndDispatch(TransientTopicBoundedMessageContainer.java:155)
> at org.activemq.service.boundedvm.TransientTopicBoundedMessageManager.doSendMessage(TransientTopicBoundedMessageManager.java:225)
> at org.activemq.service.boundedvm.TransientTopicBoundedMessageManager.sendMessage(TransientTopicBoundedMessageManager.java:204)
> at org.activemq.broker.impl.DefaultBroker.doMessageSend(DefaultBroker.java:563)
> at org.activemq.broker.impl.DefaultBroker.sendMessage(DefaultBroker.java:305)
> at org.activemq.broker.impl.BrokerContainerImpl.sendMessage(BrokerContainerImpl.java:462)
> at org.activemq.broker.impl.BrokerConnectorImpl.sendMessage(BrokerConnectorImpl.java:271)
> at org.activemq.broker.impl.BrokerClientImpl.consumeActiveMQMessage(BrokerClientImpl.java:706)
> at org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:310)
> at org.activemq.transport.TransportChannelSupport.doConsumePacket(TransportChannelSupport.java:374)
> at org.activemq.transport.TransportChannelSupport.doConsumePacket(TransportChannelSupport.java:368)
> at org.activemq.transport.tcp.TcpTransportChannel.run(TcpTransportChannel.java:311)
> at java.lang.Thread.run(Thread.java:534)
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see:
http://www.atlassian.com/software/jira