diff --git a/ojc-core/httpsoapbc/httpsoapbcimpl/src/com/sun/jbi/httpsoapbc/async/AsyncResponseProcessor.java b/ojc-core/httpsoapbc/httpsoapbcimpl/src/com/sun/jbi/httpsoapbc/async/AsyncResponseProcessor.java index 48312e04b..d76a2d841 100755 --- a/ojc-core/httpsoapbc/httpsoapbcimpl/src/com/sun/jbi/httpsoapbc/async/AsyncResponseProcessor.java +++ b/ojc-core/httpsoapbc/httpsoapbcimpl/src/com/sun/jbi/httpsoapbc/async/AsyncResponseProcessor.java @@ -96,17 +96,15 @@ public class AsyncResponseProcessor implements Runnable { context.getEndpoint().getEndpointStatus().incrementReceivedReplies(); replyHTTP((DataSource) result); } else { - //final String err = Messages.getMessages(AsyncResponseProcessor.class).getString("HTTPBC-E1001"); - suspendTransaction(); - logger.warning("HTTPBC-E1001: Unsupported response media"); + final String err = Messages.getMessages(AsyncResponseProcessor.class).getString("HTTPBC-E1001"); + logger.warning(err); return; } - try { - suspendTransaction(); + try { context.getChannel().send(context.getInout()); } catch (MessagingException ex) { - //final String err = Messages.getMessages(AsyncResponseProcessor.class).getString("HTTPBC-E1002"); - logger.warning(new StringBuilder("HTTPBC-E1002: ").append(ex.getMessage()).toString()); + final String err = Messages.getMessages(AsyncResponseProcessor.class).getString("HTTPBC-E1002"); + logger.warning(err); } } finally { @@ -197,7 +195,6 @@ public class AsyncResponseProcessor implements Runnable { } private void replyError(Throwable t) { - logger.warning("HTTPBC: Exchange fault for service URL: " + context.getEndpoint().getEndpointUrl() + " : " + t.getLocalizedMessage()); setExchangeFaulty((Exception) t, CLIENT, "", t.getLocalizedMessage()); } @@ -274,7 +271,7 @@ public class AsyncResponseProcessor implements Runnable { private void resumeTransaction() { javax.transaction.Transaction tx = (Transaction) context.getInout().getProperty(context.getInout().JTA_TRANSACTION_PROPERTY_NAME); if (tx != null) { - txResumed = TransactionsUtil.resumeTransaction(tx); + TransactionsUtil.resumeTransaction(tx); } } @@ -282,7 +279,6 @@ public class AsyncResponseProcessor implements Runnable { try { if (txResumed) { TransactionsUtil.suspendTransaction(); - txResumed = false; } } catch (SystemException ex) {/* I hope noone uses misterious XA*/