Author: hemapani
Date: Wed Jun 13 06:31:37 2007
New Revision: 546863
URL: http://svn.apache.org/viewvc?view=rev&rev=546863
Log:
remove tabs checked in by a mistake and fix a typo in a variable name
Modified:
webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/receivers/AbstractInOutAsyncMessageReceiver.java
webservices/axis2/trunk/java/modules/kernel/test/org/apache/axis2/faults/FaultSerializationTest.java
Modified:
webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/receivers/AbstractInOutAsyncMessageReceiver.java
URL:
http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/receivers/AbstractInOutAsyncMessageReceiver.java?view=diff&rev=546863&r1=546862&r2=546863
==============================================================================
---
webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/receivers/AbstractInOutAsyncMessageReceiver.java
(original)
+++
webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/receivers/AbstractInOutAsyncMessageReceiver.java
Wed Jun 13 06:31:37 2007
@@ -62,27 +62,32 @@
* async message recivers are removed later
*/
- if(messageCtx.getReplyTo() != null
- &&
!AddressingConstants.Submission.WSA_ANONYMOUS_URL.equals(messageCtx.getReplyTo().getAddress())
- &&
!AddressingConstants.Final.WSA_ANONYMOUS_URL.equals(messageCtx.getReplyTo().getAddress())){
-
messageCtx.getConfigurationContext().getThreadPool().execute(theadedTask);
- }else{
- theadedTask.run();
- }
+ if (messageCtx.getReplyTo() != null
+ && !AddressingConstants.Submission.WSA_ANONYMOUS_URL
+ .equals(messageCtx.getReplyTo().getAddress())
+ && !AddressingConstants.Final.WSA_ANONYMOUS_URL
+ .equals(messageCtx.getReplyTo().getAddress())) {
+ messageCtx.getConfigurationContext().getThreadPool().execute(
+ theadedTask);
+ } else {
+ theadedTask.run();
+ }
}
- public class AsyncMessageReceiverWorker implements Runnable{
- private MessageContext messageCtx;
- private ServerCallback callback;
-
- public AsyncMessageReceiverWorker(MessageContext
messageCtx,ServerCallback callback){
- this.messageCtx = messageCtx;
- this.callback = callback;
- }
-
+ public class AsyncMessageReceiverWorker implements Runnable {
+ private MessageContext messageCtx;
+
+ private ServerCallback callback;
+
+ public AsyncMessageReceiverWorker(MessageContext messageCtx,
+ ServerCallback callback) {
+ this.messageCtx = messageCtx;
+ this.callback = callback;
+ }
+
public void run() {
try {
- MessageContext newmsgCtx =
-
MessageContextBuilder.createOutMessageContext(messageCtx);
+ MessageContext newmsgCtx = MessageContextBuilder
+ .createOutMessageContext(messageCtx);
newmsgCtx.getOperationContext().addMessageContext(newmsgCtx);
ThreadContextDescriptor tc = setThreadContext(messageCtx);
try {
Modified:
webservices/axis2/trunk/java/modules/kernel/test/org/apache/axis2/faults/FaultSerializationTest.java
URL:
http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/test/org/apache/axis2/faults/FaultSerializationTest.java?view=diff&rev=546863&r1=546862&r2=546863
==============================================================================
---
webservices/axis2/trunk/java/modules/kernel/test/org/apache/axis2/faults/FaultSerializationTest.java
(original)
+++
webservices/axis2/trunk/java/modules/kernel/test/org/apache/axis2/faults/FaultSerializationTest.java
Wed Jun 13 06:31:37 2007
@@ -42,25 +42,31 @@
SOAPFactory soapFactory = OMAbstractFactory.getSOAP12Factory();
SOAPFaultCode soapFaultCode = soapFactory.createSOAPFaultCode();
- SOAPFaultValue soapFaultValue =
soapFactory.createSOAPFaultValue(soapFaultCode);
- soapFaultValue.setText(new
QName(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI, "Sender"));
+ SOAPFaultValue soapFaultValue = soapFactory
+ .createSOAPFaultValue(soapFaultCode);
+ soapFaultValue.setText(new QName(
+ SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI, "Sender"));
SOAPFaultReason soapFaultReason = soapFactory.createSOAPFaultReason();
- SOAPFaultText soapFaultText =
soapFactory.createSOAPFaultText(soapFaultReason);
+ SOAPFaultText soapFaultText = soapFactory
+ .createSOAPFaultText(soapFaultReason);
soapFaultText.setText(REASON);
SOAPFaultDetail soapFaultDetail = soapFactory.createSOAPFaultDetail();
QName qName = new QName("http://mycompany.com";, "FaultException",
"ex");
- OMElement exception = soapFactory.createOMElement(qName,
soapFaultDetail);
+ OMElement exception = soapFactory.createOMElement(qName,
+ soapFaultDetail);
exception.setText("Detail text");
- AxisFault fault = new AxisFault(soapFaultCode, soapFaultReason, null,
null,
- soapFaultDetail);
+ AxisFault fault = new AxisFault(soapFaultCode, soapFaultReason, null,
+ null, soapFaultDetail);
- ConfigurationContext cc =
ConfigurationContextFactory.createDefaultConfigurationContext();
+ ConfigurationContext cc = ConfigurationContextFactory
+ .createDefaultConfigurationContext();
MessageContext ctx = cc.createMessageContext();
SOAPFactory fac = OMAbstractFactory.getSOAP12Factory();
ctx.setEnvelope(fac.getDefaultEnvelope());
- MessageContext faultCtx =
MessageContextBuilder.createFaultMessageContext(ctx, fault);
+ MessageContext faultCtx = MessageContextBuilder
+ .createFaultMessageContext(ctx, fault);
ByteArrayOutputStream bos = new ByteArrayOutputStream();
TransportUtils.writeMessage(faultCtx, bos);
@@ -71,21 +77,25 @@
// Confirm reason was correctly processed
assertTrue("Incorrect or missing reason!", result.indexOf(REASON) >
-1);
}
-
- //test for https://issues.apache.org/jira/browse/AXIS2-1703
+
+ // test for https://issues.apache.org/jira/browse/AXIS2-1703
public void testFaultReason() throws Exception {
- SOAPFactory soapFactory = OMAbstractFactory.getSOAP12Factory();
- OMElement response = soapFactory.createOMElement(new
QName("testNs","test"));
- String falutReason = "myFaultReason";
- AxisFault fault = new AxisFault( new QName( "myQname" ),
falutReason ,
- "myFaultNode" , "myFaultRole" , response);
+ SOAPFactory soapFactory = OMAbstractFactory.getSOAP12Factory();
+ OMElement response = soapFactory.createOMElement(new QName("testNs",
+ "test"));
+ String faultReason = "myFaultReason";
+ AxisFault fault = new AxisFault(new QName("myQname"), faultReason,
+ "myFaultNode", "myFaultRole", response);
- ConfigurationContext cc =
ConfigurationContextFactory.createDefaultConfigurationContext();
+ ConfigurationContext cc = ConfigurationContextFactory
+ .createDefaultConfigurationContext();
MessageContext ctx = cc.createMessageContext();
SOAPFactory fac = OMAbstractFactory.getSOAP12Factory();
ctx.setEnvelope(fac.getDefaultEnvelope());
- MessageContext faultCtx =
MessageContextBuilder.createFaultMessageContext(ctx, fault);
+ MessageContext faultCtx = MessageContextBuilder
+ .createFaultMessageContext(ctx, fault);
- assertEquals(falutReason,
Utils.getInboundFaultFromMessageContext(faultCtx).getReason());
+ assertEquals(faultReason, Utils.getInboundFaultFromMessageContext(
+ faultCtx).getReason());
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
