You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by ja...@apache.org on 2005/06/06 15:24:26 UTC
svn commit: r180307 - in
/webservices/axis/trunk/java/modules/samples/src/userguide:
clients/EchoBlockingDualClient.java loggingmodule/LogHandler.java
Author: jaliya
Date: Mon Jun 6 06:24:24 2005
New Revision: 180307
URL: http://svn.apache.org/viewcvs?rev=180307&view=rev
Log:
Changed the LogHandler and the EchoBlockingDualClient
Modified:
webservices/axis/trunk/java/modules/samples/src/userguide/clients/EchoBlockingDualClient.java
webservices/axis/trunk/java/modules/samples/src/userguide/loggingmodule/LogHandler.java
Modified: webservices/axis/trunk/java/modules/samples/src/userguide/clients/EchoBlockingDualClient.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/samples/src/userguide/clients/EchoBlockingDualClient.java?rev=180307&r1=180306&r2=180307&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/samples/src/userguide/clients/EchoBlockingDualClient.java (original)
+++ webservices/axis/trunk/java/modules/samples/src/userguide/clients/EchoBlockingDualClient.java Mon Jun 6 06:24:24 2005
@@ -3,16 +3,11 @@
import org.apache.axis.Constants;
import org.apache.axis.addressing.AddressingConstants;
import org.apache.axis.addressing.EndpointReference;
-import org.apache.axis.clientapi.AsyncResult;
import org.apache.axis.clientapi.Call;
-import org.apache.axis.clientapi.Callback;
import org.apache.axis.engine.AxisFault;
import org.apache.axis.om.OMElement;
import javax.xml.namespace.QName;
-import javax.xml.stream.XMLOutputFactory;
-import javax.xml.stream.XMLStreamException;
-import java.io.StringWriter;
/**
* Created by IntelliJ IDEA.
@@ -36,34 +31,8 @@
call.engageModule(new QName(Constants.MODULE_ADDRESSING));
call.setTransportInfo(Constants.TRANSPORT_HTTP, Constants.TRANSPORT_HTTP, true);
- //Callback to handle the response
- Callback callback = new Callback() {
- public void onComplete(AsyncResult result) {
- try {
- StringWriter writer = new StringWriter();
- result.getResponseEnvelope().serializeWithCache(
- XMLOutputFactory.newInstance().createXMLStreamWriter(writer));
- writer.flush();
-
- System.out.println(writer.toString());
-
- } catch (XMLStreamException e) {
- reportError(e);
- }
- }
-
- public void reportError(Exception e) {
- e.printStackTrace();
- }
- };
-
//Non-Blocking Invocation
- call.invokeNonBlocking("echo", payload, callback);
-
- //Wait till the callback receives the response.
- while (!callback.isComplete()) {
- Thread.sleep(1000);
- }
+ call.invokeBlocking("echo", payload);
//Need to close the Client Side Listener.
call.close();
Modified: webservices/axis/trunk/java/modules/samples/src/userguide/loggingmodule/LogHandler.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/samples/src/userguide/loggingmodule/LogHandler.java?rev=180307&r1=180306&r2=180307&view=diff
==============================================================================
--- webservices/axis/trunk/java/modules/samples/src/userguide/loggingmodule/LogHandler.java (original)
+++ webservices/axis/trunk/java/modules/samples/src/userguide/loggingmodule/LogHandler.java Mon Jun 6 06:24:24 2005
@@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+
package userguide.loggingmodule;
import org.apache.axis.context.MessageContext;
@@ -27,21 +27,18 @@
public class LogHandler extends AbstractHandler implements Handler {
private Log log = LogFactory.getLog(getClass());
- private String message;
private QName name;
- public LogHandler() {
- this.message = "Inside Log Handler";
- }
+
public QName getName() {
return name;
}
public void invoke(MessageContext msgContext) throws AxisFault {
- log.info("I am " + message + " Handler Running ");
+ log.info(msgContext.getEnvelope().toString());
}
public void revoke(MessageContext msgContext) {
- log.info("I am " + message + " Handler Running ");
+ log.info(msgContext.getEnvelope().toString());
}
public void setName(QName name) {