[
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 maste...@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 maste...@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 maste...@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-unsubscr...@qpid.apache.org
For additional commands, e-mail: dev-h...@qpid.apache.org
