diff --git a/src/main/java/org/wildfly/transaction/client/provider/remoting/TransactionClientChannel.java b/src/main/java/org/wildfly/transaction/client/provider/remoting/TransactionClientChannel.java index 60f7c02..e358f3f 100644 --- a/src/main/java/org/wildfly/transaction/client/provider/remoting/TransactionClientChannel.java +++ b/src/main/java/org/wildfly/transaction/client/provider/remoting/TransactionClientChannel.java @@ -95,7 +95,7 @@ public void rollback(final Xid xid, final ConnectionPeerIdentity peerIdentity) t final int peerIdentityId = peerIdentity.getId(); if (peerIdentityId != 0) Protocol.writeParam(Protocol.P_SEC_CONTEXT, os, peerIdentityId, Protocol.UNSIGNED); } catch (IOException e) { - throw Log.log.failedToSendXA(e, XAException.XAER_RMERR); + throw Log.log.failedToSendXA(e, XAException.XAER_RMFAIL); } try (BlockingInvocation.Response response = invocation.getResponse()) { try (MessageInputStream is = response.getInputStream()) { @@ -130,7 +130,7 @@ public void rollback(final Xid xid, final ConnectionPeerIdentity peerIdentity) t throw Log.log.unrecognizedParameter(XAException.XAER_RMFAIL, id); } } catch (IOException e) { - throw Log.log.responseFailedXa(e, XAException.XAER_RMERR); + throw Log.log.responseFailedXa(e, XAException.XAER_RMFAIL); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); @@ -153,7 +153,7 @@ public void setRollbackOnly(final Xid xid, final ConnectionPeerIdentity peerIden final int peerIdentityId = peerIdentity.getId(); if (peerIdentityId != 0) Protocol.writeParam(Protocol.P_SEC_CONTEXT, os, peerIdentityId, Protocol.UNSIGNED); } catch (IOException e) { - throw Log.log.failedToSendXA(e, XAException.XAER_RMERR); + throw Log.log.failedToSendXA(e, XAException.XAER_RMFAIL); } try (BlockingInvocation.Response response = invocation.getResponse()) { try (MessageInputStream is = response.getInputStream()) { @@ -188,7 +188,7 @@ public void setRollbackOnly(final Xid xid, final ConnectionPeerIdentity peerIden throw Log.log.unrecognizedParameter(XAException.XAER_RMFAIL, id); } } catch (IOException e) { - throw Log.log.responseFailedXa(e, XAException.XAER_RMERR); + throw Log.log.responseFailedXa(e, XAException.XAER_RMFAIL); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); @@ -210,7 +210,7 @@ public void beforeCompletion(final Xid xid, final ConnectionPeerIdentity peerIde final int peerIdentityId = peerIdentity.getId(); if (peerIdentityId != 0) Protocol.writeParam(Protocol.P_SEC_CONTEXT, os, peerIdentityId, Protocol.UNSIGNED); } catch (IOException e) { - throw Log.log.failedToSendXA(e, XAException.XAER_RMERR); + throw Log.log.failedToSendXA(e, XAException.XAER_RMFAIL); } try (BlockingInvocation.Response response = invocation.getResponse()) { try (MessageInputStream is = response.getInputStream()) { @@ -245,7 +245,7 @@ public void beforeCompletion(final Xid xid, final ConnectionPeerIdentity peerIde throw Log.log.unrecognizedParameter(XAException.XAER_RMFAIL, id); } } catch (IOException e) { - throw Log.log.responseFailedXa(e, XAException.XAER_RMERR); + throw Log.log.responseFailedXa(e, XAException.XAER_RMFAIL); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); @@ -268,7 +268,7 @@ public int prepare(final Xid xid, final ConnectionPeerIdentity peerIdentity) thr final int peerIdentityId = peerIdentity.getId(); if (peerIdentityId != 0) Protocol.writeParam(Protocol.P_SEC_CONTEXT, os, peerIdentityId, Protocol.UNSIGNED); } catch (IOException e) { - throw Log.log.failedToSendXA(e, XAException.XAER_RMERR); + throw Log.log.failedToSendXA(e, XAException.XAER_RMFAIL); } try (BlockingInvocation.Response response = invocation.getResponse()) { try (MessageInputStream is = response.getInputStream()) { @@ -305,7 +305,7 @@ public int prepare(final Xid xid, final ConnectionPeerIdentity peerIdentity) thr throw Log.log.unrecognizedParameter(XAException.XAER_RMFAIL, id); } } catch (IOException e) { - throw Log.log.responseFailedXa(e, XAException.XAER_RMERR); + throw Log.log.responseFailedXa(e, XAException.XAER_RMFAIL); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); @@ -363,7 +363,7 @@ public void forget(final Xid xid, final ConnectionPeerIdentity peerIdentity) thr throw Log.log.unrecognizedParameter(XAException.XAER_RMFAIL, id); } } catch (IOException e) { - throw Log.log.responseFailedXa(e, XAException.XAER_RMERR); + throw Log.log.responseFailedXa(e, XAException.XAER_RMFAIL); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); @@ -495,7 +495,7 @@ public Xid[] recover(final int flag, final String parentName, final ConnectionPe Thread.currentThread().interrupt(); throw Log.log.interruptedXA(XAException.XAER_RMERR); } catch (IOException e) { - throw Log.log.responseFailedXa(e, XAException.XAER_RMERR); + throw Log.log.responseFailedXa(e, XAException.XAER_RMFAIL); } }