Quantcast

[activemq-user] What is the best way to manage a slow consumer condition and prev ent ActiveMQ droping messages?

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

[activemq-user] What is the best way to manage a slow consumer condition and prev ent ActiveMQ droping messages?

gklyuzner
What is the best way to manage a slow consumer condition and prevent
ActiveMQ droping messages?
I am asking about something less obvious than slow down the producer with
sleep , ect.


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-3
3-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(Spool
edBoundedActiveMQMessageQueue.java:121)
        at
org.activemq.io.util.SpooledBoundedActiveMQMessageQueue.enqueue(SpooledBound
edActiveMQMessageQueue.java:91)
        at
org.activemq.broker.impl.BrokerClientImpl.dispatch(BrokerClientImpl.java:198
)
        at
org.activemq.service.boundedvm.TransientTopicBoundedMessageContainer.dispatc
hToQueue(TransientTopicBoundedMessageContainer.java:223)
        at
org.activemq.service.boundedvm.TransientTopicBoundedMessageContainer.targetA
ndDispatch(TransientTopicBoundedMessageContainer.java:155)
        at
org.activemq.service.boundedvm.TransientTopicBoundedMessageManager.doSendMes
sage(TransientTopicBoundedMessageManager.java:225)
        at
org.activemq.service.boundedvm.TransientTopicBoundedMessageManager.sendMessa
ge(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(BrokerClien
tImpl.java:706)
        at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:310)
        at
org.activemq.transport.TransportChannelSupport.doConsumePacket(TransportChan
nelSupport.java:374)
        at
org.activemq.transport.TransportChannelSupport.doConsumePacket(TransportChan
nelSupport.java:368)
        at
org.activemq.transport.tcp.TcpTransportChannel.run(TcpTransportChannel.java:
311)
        at java.lang.Thread.run(Thread.java:534)
2005-06-22 11:51:54,914 [ocalport=61616]] DEBUG BrokerConnectorImpl
- Client leaving client: brokerConnector-client:(17899489)
ID:ny-cap-33-2024-1119453996333-6:0: TcpTransportChannel:
Socket[addr=/170.198.120.104,port=2025,localport=61616]


----------------------------------------------------------------------------
----------------------------------------------------------------------------
-------------------------
The information contained in this email is confidential and may also contain
privileged information. Sender does not waive confidentiality or legal
privilege. If you are not the intended recipient please notify the sender
immediately; you should not retain this message or disclose its content to
anyone.
Internet communications are not secure or error free and the sender does not
accept any liability for the content of the email. Although emails are
routinely screened for viruses, the sender does not accept responsibility
for any damage caused. Replies to this email may be monitored.
For more information about the Collins Stewart Tullett group of companies
please visit the following web site: www.cstplc.com
----------------------------------------------------------------------------
----------------------------------------------------------------------------
--------------------------

Loading...