activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hiram Chirino (JIRA)" <j...@apache.org>
Subject [jira] Updated: (AMQ-275) Could not enqueue message and Too many open files
Date Thu, 15 Jun 2006 03:30:51 GMT
     [ https://issues.apache.org/activemq/browse/AMQ-275?page=all ]

Hiram Chirino updated AMQ-275:
------------------------------

    Fix Version: 3.2.5
                     (was: 3.2.4)

> 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.5
>  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


Mime
View raw message