3 Replies Latest reply on Mar 18, 2016 3:16 AM by touwang

    Consumer acknowledge take a long time when set blockOnAcknowledge to true

    touwang

      TRACE: Returning ClientMessage[messageID=2147483718, durable=true, address=com.clusterTestAddress,userID=null,properties=TypedProperties[{com.successfactors.hermes.MessageID=36e97ccd-ea32-4649-aae2-1407d72cfe04, _HQ_DUPL_ID=36e97ccd-ea32-4649-aae2-1407d72cfe04}]]

      Mar 14, 2016 3:51:35 PM com.wright.hornetQ.HornetQTest$ConsumerThread run

      INFO: ======================Receive message from TransportConfiguration(name=44a23286-e9b9-11e5-ad2b-71e3fa35717c, factory=org-hornetq-core-remoting-impl-netty-NettyConnectorFactory) ?port=5450&host=10-129-126-85=====================

      Mar 14, 2016 3:51:35 PM com.wright.hornetQ.HornetQTest$ConsumerThread run

      INFO: [Consumer11] message from queue[clusterTestQueue1Slow] = 11

      Mar 14, 2016 3:51:35 PM org.hornetq.core.client.impl.ClientSessionImpl acknowledge

      DEBUG: client ack messageID = 2147483718

      Mar 14, 2016 3:51:35 PM org.hornetq.core.remoting.impl.netty.NettyConnection write

      Mar 14, 2016 3:51:49 PM org.hornetq.core.protocol.core.impl.RemotingConnectionImpl bufferReceived

      TRACE: handling packet PACKET(NullResponseMessage)[type=21, channelID=11, packetObject=NullResponseMessage]

      Mar 14, 2016 3:51:49 PM com.wright.hornetQ.HornetQTest$ConsumerThread run

      INFO: [Consumer11] sleep 1 seconds

      Mar 14, 2016 3:51:50 PM com.wright.hornetQ.HornetQTest$ConsumerThread run

      INFO: [Consumer11] handled 11 messages

      Mar 14, 2016 3:51:50 PM org.hornetq.core.client.impl.ClientConsumerImpl receive

       

      I have only one consumer processing message, from the log, it takes 14 seconds to receive the acknowledge response from server, how can I reduce the time and make it quicker?

       

      I just set below two attributes:

          locator.setBlockOnAcknowledge(true);

          locator.setAckBatchSize(0);

       

      All the other attributes are default, and I'm using Jboss-eap-6.2 as the HornetQ server.