Fixed a build failure caused by the change described in AXIS2-4196.
diff --git a/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java b/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java
index 44681af..2bec253 100644
--- a/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java
+++ b/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java
@@ -933,9 +933,9 @@
msgContext.setTransportOut(sandesha2TransportOutDesc);
//this invocation has to be a blocking one.
- Boolean isTransportNonBlocking = (Boolean) msgContext.getProperty(MessageContext.TRANSPORT_NON_BLOCKING);
+ Boolean isTransportNonBlocking = (Boolean) msgContext.getProperty(MessageContext.CLIENT_API_NON_BLOCKING);
if (isTransportNonBlocking!=null && isTransportNonBlocking.booleanValue())
- msgContext.setProperty(MessageContext.TRANSPORT_NON_BLOCKING, Boolean.FALSE);
+ msgContext.setProperty(MessageContext.CLIENT_API_NON_BLOCKING, Boolean.FALSE);
// sending the message once through Sandesha2TransportSender.
if (msgContext.isPaused())
@@ -944,7 +944,7 @@
AxisEngine.send(msgContext);
}
//put the original value of isTransportNonBlocking back on
- msgContext.setProperty(MessageContext.TRANSPORT_NON_BLOCKING, isTransportNonBlocking);
+ msgContext.setProperty(MessageContext.CLIENT_API_NON_BLOCKING, isTransportNonBlocking);
}
if (LoggingControl.isAnyTracingEnabled() && log.isDebugEnabled())
log.debug("Exit: SandeshaUtil::executeAndStore");
diff --git a/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java b/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java
index 37a001b..4c1a48b 100644
--- a/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java
+++ b/modules/core/src/main/java/org/apache/sandesha2/workers/SenderWorker.java
@@ -326,12 +326,12 @@
if (log.isDebugEnabled())
log.debug("Resuming a send for message : " + msgCtx.getEnvelope().getHeader());
msgCtx.setPaused(false);
- msgCtx.setProperty(MessageContext.TRANSPORT_NON_BLOCKING, Boolean.FALSE);
+ msgCtx.setProperty(MessageContext.CLIENT_API_NON_BLOCKING, Boolean.FALSE);
response = AxisEngine.resumeSend(msgCtx);
} else {
if (log.isDebugEnabled())
log.debug("Sending a message : " + msgCtx.getEnvelope().getHeader());
- msgCtx.setProperty(MessageContext.TRANSPORT_NON_BLOCKING, Boolean.FALSE);
+ msgCtx.setProperty(MessageContext.CLIENT_API_NON_BLOCKING, Boolean.FALSE);
AxisEngine.send(msgCtx); // TODO check if this should return an invocation response
}
} else {
@@ -350,7 +350,7 @@
if (log.isDebugEnabled())
log.debug("Resuming a send for message : " + msgCtx.getEnvelope().getHeader());
- msgCtx.setProperty(MessageContext.TRANSPORT_NON_BLOCKING, Boolean.FALSE);
+ msgCtx.setProperty(MessageContext.CLIENT_API_NON_BLOCKING, Boolean.FALSE);
response = AxisEngine.resumeSend(msgCtx);
}
if(log.isDebugEnabled()) log.debug("Engine resume returned " + response);
