Author: sagara
Date: Wed Sep 19 11:04:43 2012
New Revision: 1387526
URL: http://svn.apache.org/viewvc?rev=1387526&view=rev
Log:
Required code level changes from AXIS2-5374 and a test case fix.
Modified:
axis/axis2/java/transports/trunk/modules/base/src/main/java/org/apache/axis2/transport/base/BaseUtils.java
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSSender.java
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java
axis/axis2/java/transports/trunk/modules/tcp/src/org/apache/axis2/transport/tcp/TCPTransportSender.java
axis/axis2/java/transports/trunk/modules/testkit/src/main/java/org/apache/axis2/transport/testkit/axis2/client/AxisTestClient.java
axis/axis2/java/transports/trunk/modules/udp/src/main/java/org/apache/axis2/transport/udp/UDPSender.java
Modified:
axis/axis2/java/transports/trunk/modules/base/src/main/java/org/apache/axis2/transport/base/BaseUtils.java
URL:
http://svn.apache.org/viewvc/axis/axis2/java/transports/trunk/modules/base/src/main/java/org/apache/axis2/transport/base/BaseUtils.java?rev=1387526&r1=1387525&r2=1387526&view=diff
==============================================================================
---
axis/axis2/java/transports/trunk/modules/base/src/main/java/org/apache/axis2/transport/base/BaseUtils.java
(original)
+++
axis/axis2/java/transports/trunk/modules/base/src/main/java/org/apache/axis2/transport/base/BaseUtils.java
Wed Sep 19 11:04:43 2012
@@ -34,6 +34,7 @@ import org.apache.axis2.format.BinaryFor
import org.apache.axis2.format.PlainTextFormatter;
import org.apache.axis2.transport.MessageFormatter;
import org.apache.axis2.transport.TransportUtils;
+import org.apache.axis2.util.MessageProcessorSelector;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -156,7 +157,7 @@ public class BaseUtils {
// ... otherwise, let Axis choose the right message formatter:
try {
- return TransportUtils.getMessageFormatter(msgContext);
+ return MessageProcessorSelector.getMessageFormatter(msgContext);
} catch (AxisFault axisFault) {
throw new BaseTransportException("Unable to get the message
formatter to use");
}
Modified:
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSSender.java
URL:
http://svn.apache.org/viewvc/axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSSender.java?rev=1387526&r1=1387525&r2=1387526&view=diff
==============================================================================
---
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSSender.java
(original)
+++
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSSender.java
Wed Sep 19 11:04:43 2012
@@ -19,12 +19,12 @@ import org.apache.axiom.om.OMOutputForma
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMText;
import org.apache.axiom.om.OMNode;
+import org.apache.axis2.util.MessageProcessorSelector;
import org.apache.axis2.AxisFault;
import org.apache.axis2.Constants;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.description.TransportOutDescription;
-import org.apache.axis2.transport.TransportUtils;
import org.apache.axis2.transport.MessageFormatter;
import org.apache.axis2.transport.OutTransportInfo;
import org.apache.axis2.transport.base.*;
@@ -343,7 +343,7 @@ public class JMSSender extends AbstractT
OMOutputFormat format = BaseUtils.getOMOutputFormat(msgContext);
MessageFormatter messageFormatter = null;
try {
- messageFormatter =
TransportUtils.getMessageFormatter(msgContext);
+ messageFormatter =
MessageProcessorSelector.getMessageFormatter(msgContext);
} catch (AxisFault axisFault) {
throw new JMSException("Unable to get the message formatter to
use");
}
Modified:
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java
URL:
http://svn.apache.org/viewvc/axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java?rev=1387526&r1=1387525&r2=1387526&view=diff
==============================================================================
---
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java
(original)
+++
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java
Wed Sep 19 11:04:43 2012
@@ -22,6 +22,7 @@ import org.apache.axis2.builder.Builder;
import org.apache.axis2.builder.BuilderUtil;
import org.apache.axis2.builder.SOAPBuilder;
import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.util.MessageProcessorSelector;
import org.apache.axis2.description.AxisService;
import org.apache.axis2.format.DataSourceMessageBuilder;
import org.apache.axis2.format.TextMessageBuilder;
@@ -130,7 +131,7 @@ public class JMSUtils extends BaseUtils
int index = contentType.indexOf(';');
String type = index > 0 ? contentType.substring(0, index) :
contentType;
- Builder builder = BuilderUtil.getBuilderFromSelector(type, msgContext);
+ Builder builder = MessageProcessorSelector.getMessageBuilder(type,
msgContext);
if (builder == null) {
if (log.isDebugEnabled()) {
log.debug("No message builder found for type '" + type + "'.
Falling back to SOAP.");
Modified:
axis/axis2/java/transports/trunk/modules/tcp/src/org/apache/axis2/transport/tcp/TCPTransportSender.java
URL:
http://svn.apache.org/viewvc/axis/axis2/java/transports/trunk/modules/tcp/src/org/apache/axis2/transport/tcp/TCPTransportSender.java?rev=1387526&r1=1387525&r2=1387526&view=diff
==============================================================================
---
axis/axis2/java/transports/trunk/modules/tcp/src/org/apache/axis2/transport/tcp/TCPTransportSender.java
(original)
+++
axis/axis2/java/transports/trunk/modules/tcp/src/org/apache/axis2/transport/tcp/TCPTransportSender.java
Wed Sep 19 11:04:43 2012
@@ -31,6 +31,7 @@ import org.apache.axis2.transport.base.A
import org.apache.axis2.transport.base.BaseUtils;
import org.apache.axiom.soap.SOAPEnvelope;
import org.apache.axiom.om.OMOutputFormat;
+import org.apache.axis2.util.MessageProcessorSelector;
import java.io.IOException;
import java.io.OutputStream;
@@ -84,7 +85,7 @@ public class TCPTransportSender extends
private void writeOut(MessageContext msgContext, Socket socket,
String contentType) throws IOException {
- MessageFormatter messageFormatter =
TransportUtils.getMessageFormatter(msgContext);
+ MessageFormatter messageFormatter =
MessageProcessorSelector.getMessageFormatter(msgContext);
OMOutputFormat format = BaseUtils.getOMOutputFormat(msgContext);
format.setContentType(contentType);
byte[] payload = messageFormatter.getBytes(msgContext, format);
Modified:
axis/axis2/java/transports/trunk/modules/testkit/src/main/java/org/apache/axis2/transport/testkit/axis2/client/AxisTestClient.java
URL:
http://svn.apache.org/viewvc/axis/axis2/java/transports/trunk/modules/testkit/src/main/java/org/apache/axis2/transport/testkit/axis2/client/AxisTestClient.java?rev=1387526&r1=1387525&r2=1387526&view=diff
==============================================================================
---
axis/axis2/java/transports/trunk/modules/testkit/src/main/java/org/apache/axis2/transport/testkit/axis2/client/AxisTestClient.java
(original)
+++
axis/axis2/java/transports/trunk/modules/testkit/src/main/java/org/apache/axis2/transport/testkit/axis2/client/AxisTestClient.java
Wed Sep 19 11:04:43 2012
@@ -118,6 +118,8 @@ public class AxisTestClient implements T
mc.setProperty(BaseConstants.METRICS_COLLECTOR, metrics);
}
mepClient.addMessageContext(mc);
+ mepClient.getOptions().setAction("");
+
mepClient.execute(block);
// mepClient.complete(mc);
return resultMessageLabel == null ? null :
mepClient.getMessageContext(resultMessageLabel);
Modified:
axis/axis2/java/transports/trunk/modules/udp/src/main/java/org/apache/axis2/transport/udp/UDPSender.java
URL:
http://svn.apache.org/viewvc/axis/axis2/java/transports/trunk/modules/udp/src/main/java/org/apache/axis2/transport/udp/UDPSender.java?rev=1387526&r1=1387525&r2=1387526&view=diff
==============================================================================
---
axis/axis2/java/transports/trunk/modules/udp/src/main/java/org/apache/axis2/transport/udp/UDPSender.java
(original)
+++
axis/axis2/java/transports/trunk/modules/udp/src/main/java/org/apache/axis2/transport/udp/UDPSender.java
Wed Sep 19 11:04:43 2012
@@ -37,6 +37,7 @@ import org.apache.axis2.transport.OutTra
import org.apache.axis2.transport.TransportUtils;
import org.apache.axis2.transport.base.AbstractTransportSender;
import org.apache.axis2.transport.base.BaseUtils;
+import org.apache.axis2.util.MessageProcessorSelector;
import org.apache.commons.logging.LogFactory;
import javax.xml.stream.XMLStreamException;
@@ -67,7 +68,7 @@ public class UDPSender extends AbstractT
} else {
udpOutInfo = new UDPOutTransportInfo(targetEPR);
}
- MessageFormatter messageFormatter =
TransportUtils.getMessageFormatter(msgContext);
+ MessageFormatter messageFormatter =
MessageProcessorSelector.getMessageFormatter(msgContext);
OMOutputFormat format = BaseUtils.getOMOutputFormat(msgContext);
format.setContentType(udpOutInfo.getContentType());
byte[] payload = messageFormatter.getBytes(msgContext, format);
