qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (QPID-5855) JAVA Client Can not recieve message with qpid ha cluster "Session exception occured while trying to commit"
Date Thu, 03 Sep 2015 18:59:46 GMT

    [ https://issues.apache.org/jira/browse/QPID-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14729587#comment-14729587
] 

ASF subversion and git services commented on QPID-5855:
-------------------------------------------------------

Commit 1701109 from [~aconway] in branch 'qpid/trunk'
[ https://svn.apache.org/r1701109 ]

QPID-5855 - Simplified HA transaction logic.

Removed complex and incorrect HA+TX logic, reverted to the following limitation:

You can use transactions in a HA cluster, but there are limitations on the
transactional guarantees. Transactions function normally with the *primary*
broker but replication to the backups is not coverted by the atomic guarantee.

The following situations are all safe:
- Client rolls back a transaction.
- Client successfully commits a transaction.
- Primary fails during a transaction *before* the client sends a commit.
- Transaction contains only one message.

The problem case is when all of the following occur:
- transaction contains multiple actions (enqueues or dequeues)
- primary fails between client sending commit and receiving commit-complete.

In this case it is possible that only part of the transaction was replicated to
the backups, so on fail-over partial transaction results may be visible.

> JAVA Client Can not recieve message with qpid ha cluster "Session exception occured while
trying to commit"
> -----------------------------------------------------------------------------------------------------------
>
>                 Key: QPID-5855
>                 URL: https://issues.apache.org/jira/browse/QPID-5855
>             Project: Qpid
>          Issue Type: Bug
>          Components: C++ Clustering, Java Client
>    Affects Versions: 0.27
>            Reporter: Alan Conway
>            Assignee: Alan Conway
>             Fix For: 0.31
>
>
> 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



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org


Mime
View raw message