Uploaded image for project: 'Qpid'
  1. Qpid
  2. QPID-5855

JAVA Client Can not recieve message with qpid ha cluster "Session exception occured while trying to commit"

    Details

      Description

      Description of problem:

      the java client can not recieve message in qpid ha cluster
      but drain message is work fine
      if i remove ha cluster ,all are OK

      2014-05-09 00:20:18,695 WARN [org.springframework.jms.listener.DefaultMessageListenerContainer] Execution of JMS message listener failed, and no ErrorHandler has been set.
      "javax.jms.JMSException: Session exception occured while trying to commit: timed out waiting for sync: complete = 8, point = 10
      at org.apache.qpid.client.AMQSession.toJMSException(AMQSession.java:3465)
      at org.apache.qpid.client.AMQSession.commit(AMQSession.java:843)
      at org.springframework.jms.support.JmsUtils.commitIfNecessary(JmsUtils.java:217)
      at org.springframework.jms.listener.AbstractMessageListenerContainer.commitIfNecessary(AbstractMessageListenerContainer.java:575)
      at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:481)
      at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)
      at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)
      at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)
      at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)
      at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)
      at java.lang.Thread.run(Thread.java:722)
      Caused by: org.apache.qpid.transport.SessionException: timed out waiting for sync: complete = 8, point = 10
      at org.apache.qpid.transport.Session.sync(Session.java:867)
      at org.apache.qpid.transport.Session.sync(Session.java:837)
      at org.apache.qpid.transport.Session.invoke(Session.java:789)
      at org.apache.qpid.transport.Session.invoke(Session.java:627)
      at org.apache.qpid.transport.SessionInvoker.txCommit(SessionInvoker.java:145)
      at org.apache.qpid.client.AMQSession_0_10.commitImpl(AMQSession_0_10.java:1037)
      at org.apache.qpid.client.AMQSession.commit(AMQSession.java:830)
      ... 9 more
      Version-Release number of selected component (if applicable):

      How reproducible:

      Steps to Reproduce:
      1.
      2.
      3.

      Actual results:
      throw excpeion

      Expected results:
      no exception

      Additional info:
      [reply] [−] Private Comment 1 masterQi@126.com 2014-05-08 12:37:17 EDT
      there are manay qpid-ha tx queue

      qpid: list
      Summary of Objects by Type:
      Package Class Active Deleted
      ============================================================
      org.apache.qpid.broker binding 17 0
      org.apache.qpid.broker broker 1 0
      org.apache.qpid.broker memory 1 0
      org.apache.qpid.broker system 1 0
      org.apache.qpid.ha habroker 1 0
      org.apache.qpid.legacystore store 1 0
      org.apache.qpid.broker subscription 8 0
      org.apache.qpid.broker connection 3 0
      org.apache.qpid.legacystore journal 2 0
      org.apache.qpid.broker session 4 0
      org.apache.qpid.broker queue 42 0
      org.apache.qpid.broker exchange 9 0
      org.apache.qpid.broker vhost 1 0
      qpid: list queue
      Object Summary:
      ID Created Destroyed Index
      ==================================================================================================================================================================================
      132 16:01:41 - org.apache.qpid.broker:queue:log
      133 16:01:41 - org.apache.qpid.broker:queue:meizu.game.order.notify
      134 16:34:38 - org.apache.qpid.broker:queue:qmfc-v2-GZ-GAME-19.65.19797.1
      135 16:34:38 - org.apache.qpid.broker:queue:qmfc-v2-hb-GZ-GAME-19.65.19797.1
      136 16:34:38 - org.apache.qpid.broker:queue:qmfc-v2-ui-GZ-GAME-19.65.19797.1
      137 16:01:52 - org.apache.qpid.broker:queue:qpid.bridge_queue_qpid.broker-replicator.bridge.55f21fec-fb5d-49e2-92e3-45c3b8c6a31f_58b2be25-5a48-4691-8dcb-2f05e22af240
      138 16:25:18 - org.apache.qpid.broker:queue:qpid.ha-tx:050dee8e-eb28-43ae-8853-6b8774ec467a
      139 16:31:23 - org.apache.qpid.broker:queue:qpid.ha-tx:16df28dd-47f0-4a39-a96f-c7e07fd79c05
      140 16:28:18 - org.apache.qpid.broker:queue:qpid.ha-tx:1b2d1353-8c42-484b-b231-25964a5f6453
      141 16:16:18 - org.apache.qpid.broker:queue:qpid.ha-tx:26239421-986e-4dc3-b22a-243e44d36a40
      142 16:01:53 - org.apache.qpid.broker:queue:qpid.ha-tx:2dfbb304-2020-464a-a14f-c87418956867
      143 16:01:53 - org.apache.qpid.broker:queue:qpid.ha-tx:2e54c358-c200-4d4e-b4ac-ef8edb7c6b9d
      144 16:16:18 - org.apache.qpid.broker:queue:qpid.ha-tx:30815be3-714d-4e4b-9733-b61359120ac3
      145 16:14:12 - org.apache.qpid.broker:queue:qpid.ha-tx:31521fd7-5308-4a08-8882-bd8aefa0050e
      146 16:25:23 - org.apache.qpid.broker:queue:qpid.ha-tx:34fe2710-9243-4884-8abb-85ab54685b1e
      147 16:34:19 - org.apache.qpid.broker:queue:qpid.ha-tx:4c4dcb65-7a2c-4ee0-92a1-567da5ae5aba
      148 16:01:53 - org.apache.qpid.broker:queue:qpid.ha-tx:5b0fa3f5-264c-4477-b6a0-46c0b39a6a79
      149 16:19:18 - org.apache.qpid.broker:queue:qpid.ha-tx:5b8eb722-1a3d-4c46-97b1-26b108703044
      150 16:12:06 - org.apache.qpid.broker:queue:qpid.ha-tx:6457ac02-fcb7-4144-b0c2-3339cfa2cf4f
      151 16:04:54 - org.apache.qpid.broker:queue:qpid.ha-tx:701ac0c7-b3fd-41da-8832-70dc700cf0f3
      152 16:31:18 - org.apache.qpid.broker:queue:qpid.ha-tx:70b0f4a0-2de0-49f7-ad6b-08506dbd211f
      153 16:09:06 - org.apache.qpid.broker:queue:qpid.ha-tx:7b171b6a-8f17-4519-9fe5-204fc5626529
      154 16:34:25 - org.apache.qpid.broker:queue:qpid.ha-tx:7c003fc5-9986-4598-8950-c409ff86b709
      155 16:09:06 - org.apache.qpid.broker:queue:qpid.ha-tx:7c6c8f9a-8eab-4446-9bc2-50deaf66d627
      156 16:15:06 - org.apache.qpid.broker:queue:qpid.ha-tx:80c0e04c-5f80-4f75-95ba-81091292cd4d
      157 16:12:06 - org.apache.qpid.broker:queue:qpid.ha-tx:8c3aea7e-f333-48c8-829b-564f89d600ba
      158 16:22:23 - org.apache.qpid.broker:queue:qpid.ha-tx:a11e7cbd-d5c0-4a50-b94d-d6bd8f36d8bc
      159 16:17:12 - org.apache.qpid.broker:queue:qpid.ha-tx:ad1ab060-2a6f-41e8-80c2-16aabdfcf8de
      160 16:28:23 - org.apache.qpid.broker:queue:qpid.ha-tx:b0454339-4759-44de-906f-d1bf3465a2cb
      161 16:10:00 - org.apache.qpid.broker:queue:qpid.ha-tx:b4c5ad63-ec07-4619-b45c-35593894e072
      162 16:04:54 - org.apache.qpid.broker:queue:qpid.ha-tx:d57c3e52-8f65-44e4-9595-6e8440d39978
      163 16:19:23 - org.apache.qpid.broker:queue:qpid.ha-tx:da34735a-6e9c-44c0-bd8c-c8368ab74912
      164 16:22:18 - org.apache.qpid.broker:queue:qpid.ha-tx:dad4938e-7308-4c9e-b648-49494da41682
      165 16:04:54 - org.apache.qpid.broker:queue:qpid.ha-tx:e82f5575-9e2b-4567-be77-fb2a766fa74b
      166 16:07:54 - org.apache.qpid.broker:queue:qpid.ha-tx:ead7752b-54f0-4e5b-a389-5d2b46b8949a
      167 16:34:23 - org.apache.qpid.broker:queue:qpid.ha-tx:ecd4b7e9-1199-44be-927a-b5230ed8aa3c
      168 16:07:00 - org.apache.qpid.broker:queue:qpid.ha-tx:ed388289-24b8-4415-9b3e-3568874c6f39
      169 16:34:19 - org.apache.qpid.broker:queue:qpid.ha-tx:ed4417bf-ee74-4928-ad2d-989b3ed6b44a
      170 16:12:06 - org.apache.qpid.broker:queue:qpid.ha-tx:f64dd47f-c174-40a9-aba9-f39c4ce9f5c6
      171 16:01:53 - org.apache.qpid.broker:queue:qpid.ha-tx:fc85c5e7-be8e-44fd-8521-cf99dcfc3f96
      172 16:34:38 - org.apache.qpid.broker:queue:reply-GZ-GAME-19.65.19797.1
      173 16:34:38 - org.apache.qpid.broker:queue:topic-GZ-GAME-19.65.19797.1
      195 16:34:53 16:34:53 org.apache.qpid.broker:queue:64fdbc38-22a9-4950-91d6-28bdc4e9cf8d:0.0
      [reply] [−] Private Comment 2 masterQi@126.com 2014-05-08 12:43:31 EDT
      broker:
      qpid-cpp-0.26
      client version:
      qpid-client-0.26.jar
      qpid-common-0.26.jar
      [reply] [−] Private Comment 3 masterQi@126.com 2014-05-19 07:36:57 EDT
      when i set "sessionTransacted" false the it's OK.
      [reply] [−] Private

        Attachments

          Activity

            People

            • Assignee:
              aconway Alan Conway
              Reporter:
              aconway Alan Conway
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: