You are viewing a plain text version of this content. The canonical link for it is here.
Posted to axis-cvs@ws.apache.org by he...@apache.org on 2005/03/23 14:07:13 UTC
svn commit: r158764 - in
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src: ./ org/
org/apache/ org/apache/axis/ org/apache/axis/clientapi/
org/apache/axis/context/ org/apache/axis/description/
org/apache/axis/messaging/ org/apache/axis/serverapi/
Author: hemapani
Date: Wed Mar 23 05:07:08 2005
New Revision: 158764
URL: http://svn.apache.org/viewcvs?view=rev&rev=158764
Log:
checked in the toy for the Messaging core proposal for f2f
Added:
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/Call.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/Callback.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/CallbacksBag.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/TransportEndpointManager.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/context/
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/context/MessageContext.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisRegistry.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisService.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/EPR.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/MessageReciver.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/MessageSender.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/SOAPEnvelope.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/AsyncProvider.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/EndpointReciver.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InEndpointReciverAsync.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InEndpointReciverSync.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InOutEndpointReciverAsync.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InOutEndpointReciverSync.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/Provider.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/RobustInEndpointReciverAsync.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/RobustInEndpointReciverSync.java
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/Call.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/Call.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/Call.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/Call.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,121 @@
+package org.apache.axis.clientapi;
+import java.io.InputStream;
+
+import org.apache.axis.context.MessageContext;
+import org.apache.axis.description.AxisRegistry;
+import org.apache.axis.description.AxisService;
+import org.apache.axis.messaging.EPR;
+import org.apache.axis.messaging.MessageReciver;
+import org.apache.axis.messaging.MessageSender;
+import org.apache.axis.messaging.SOAPEnvelope;
+import org.apache.axis.serverapi.EndpointReciver;
+import org.apache.xml.utils.QName;
+
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class Call {
+ AxisRegistry registry;
+ public SOAPEnvelope sendAndReciveSync(SOAPEnvelope env, EPR to) {
+ MessageSender sender = new MessageSender(registry);
+ sender.send(env);
+ InputStream in = registry.getEndPointManager().getInStream(to);
+ SOAPEnvelope res = new SOAPEnvelope(in);
+ MessageReciver reciver = new MessageReciver(registry);
+ reciver.recive(res);
+ return res;
+ }
+
+ public void sendAndReciveAsync(
+ SOAPEnvelope env,
+ EPR to,
+ Callback callback) {
+ MessageSender sender = new MessageSender(registry);
+ sender.send(env);
+
+ String serviceName = "replyService";
+ EPR replyTo = new EPR("http:127.0.0.1:8080/services/"+serviceName);
+ registry.getEndPointManager().makeSureListenerIsUp(replyTo);
+ String messageId = String.valueOf(System.currentTimeMillis());
+ AxisService service = new AxisService(new QName(serviceName));
+ CallbacksBag bag = registry.getCallBackBag();
+ bag.addCallBack(messageId,callback);
+ service.setReciever(new CallbackReciver(bag));
+ registry.addService(service);
+ }
+
+ public void sendOneWay(SOAPEnvelope env, EPR to){
+ String transport = null;
+ MessageSender sender = new MessageSender(registry);
+ sender.send(env);
+ if("http".equals(transport)){
+ //check for the HTTP 202 OK
+ }
+ }
+
+ public void sendOneWayRobustSync(SOAPEnvelope env, EPR to) throws Exception{
+ String transport = null;
+ MessageSender sender = new MessageSender(registry);
+ sender.send(env);
+ if("http".equals(transport)){
+ boolean isResponseIsHTTP202 = true;
+ if (isResponseIsHTTP202){
+ //return
+ }else{
+ InputStream in = registry.getEndPointManager().getInStream(to);
+ SOAPEnvelope res = new SOAPEnvelope(in);
+ MessageReciver reciver = new MessageReciver(registry);
+ reciver.recive(res);
+ throw new Exception(res.toString());
+
+ }
+ }else if("mail".equals(transport)){
+ //what is here? Not supported I think
+ }
+
+
+
+ }
+ public void sendOneWayRobustAsync(SOAPEnvelope env, EPR to,Callback callback) throws Exception{
+ String transport = null;
+ MessageSender sender = new MessageSender(registry);
+ sender.send(env);
+ if("http".equals(transport)){
+ boolean isResponseIsHTTP202 = true;
+ if (isResponseIsHTTP202){
+ //return
+ }
+ }
+ String serviceName = "replyService";
+ EPR replyTo = new EPR("http:127.0.0.1:8080/services/"+serviceName);
+ registry.getEndPointManager().makeSureListenerIsUp(replyTo);
+ String messageId = String.valueOf(System.currentTimeMillis());
+ AxisService service = new AxisService(new QName(serviceName));
+ CallbacksBag bag = registry.getCallBackBag();
+ bag.addCallBack(messageId,callback);
+ service.setReciever(new CallbackReciver(bag));
+ registry.addService(service);
+ }
+
+ public class CallbackReciver implements EndpointReciver {
+ private CallbacksBag callbacks;
+ public CallbackReciver(CallbacksBag callbacks) {
+ this.callbacks = callbacks;
+ }
+ public void invoke(MessageContext msgctx) {
+ Callback callback = callbacks.getCallBack(msgctx.getMessageID());
+ callback.handleResult(msgctx.getEnvelope());
+ }
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/Callback.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/Callback.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/Callback.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/Callback.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,20 @@
+package org.apache.axis.clientapi;
+
+import org.apache.axis.messaging.SOAPEnvelope;
+
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public interface Callback {
+ public void handleResult(SOAPEnvelope env);
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/CallbacksBag.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/CallbacksBag.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/CallbacksBag.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/CallbacksBag.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,25 @@
+package org.apache.axis.clientapi;
+import java.util.HashMap;
+
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class CallbacksBag {
+ private HashMap callbacks = new HashMap();
+ public void addCallBack(String messageId,Callback callBack){
+ callbacks.put(messageId,callBack);
+ }
+ public Callback getCallBack(String messageId){
+ return (Callback)callbacks.get(messageId);
+ }
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/TransportEndpointManager.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/TransportEndpointManager.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/TransportEndpointManager.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/clientapi/TransportEndpointManager.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,42 @@
+package org.apache.axis.clientapi;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.util.HashMap;
+
+import org.apache.axis.messaging.EPR;
+
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class TransportEndpointManager {
+ private HashMap inMap;
+ private HashMap outMap;
+
+ public InputStream getInStream(EPR epr) {
+ return (InputStream) inMap.get(epr);
+ }
+ public OutputStream getOutStream(EPR epr, OutputStream out) {
+ return (OutputStream) outMap.get(epr);
+ }
+ public void setInStream(EPR epr, InputStream in) {
+ inMap.put(epr, in);
+ }
+ public void setOutputStream(EPR epr, OutputStream out) {
+ outMap.put(epr, out);
+ }
+
+ public void makeSureListenerIsUp(EPR epr) {
+
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/context/MessageContext.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/context/MessageContext.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/context/MessageContext.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/context/MessageContext.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,74 @@
+package org.apache.axis.context;
+
+import org.apache.axis.description.AxisRegistry;
+import org.apache.axis.messaging.EPR;
+import org.apache.axis.messaging.SOAPEnvelope;
+
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class MessageContext {
+ private EPR to;
+ private EPR replyTo;
+ private AxisRegistry registry;
+
+ public SOAPEnvelope getEnvelope(){
+ return null;
+ }
+
+ public String getMessageID(){
+ return null;
+ }
+ /**
+ * @return
+ */
+ public EPR getReplyTo() {
+ return replyTo;
+ }
+
+ /**
+ * @return
+ */
+ public EPR getTo() {
+ return to;
+ }
+
+ /**
+ * @param epr
+ */
+ public void setReplyTo(EPR epr) {
+ replyTo = epr;
+ }
+
+ /**
+ * @param epr
+ */
+ public void setTo(EPR epr) {
+ to = epr;
+ }
+
+ /**
+ * @return
+ */
+ public AxisRegistry getRegistry() {
+ return registry;
+ }
+
+ /**
+ * @param registry
+ */
+ public void setRegistry(AxisRegistry registry) {
+ this.registry = registry;
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisRegistry.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisRegistry.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisRegistry.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisRegistry.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,32 @@
+package org.apache.axis.description;
+
+import org.apache.axis.clientapi.CallbacksBag;
+import org.apache.axis.clientapi.TransportEndpointManager;
+
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class AxisRegistry {
+ private TransportEndpointManager epm;
+ public TransportEndpointManager getEndPointManager(){
+ return epm;
+ }
+
+ public void addService(AxisService service){
+
+ }
+
+ public CallbacksBag getCallBackBag(){
+ return null;
+ }
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisService.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisService.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisService.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisService.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,38 @@
+package org.apache.axis.description;
+
+import org.apache.xml.utils.QName;
+
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class AxisService {
+ public AxisService(QName name) {
+
+ }
+
+ private Object receiver;
+ /**
+ * @return
+ */
+ public Object getReciever() {
+ return receiver;
+ }
+
+ /**
+ * @param object
+ */
+ public void setReciever(Object object) {
+ receiver = object;
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/EPR.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/EPR.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/EPR.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/EPR.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,19 @@
+package org.apache.axis.messaging;
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class EPR {
+ public EPR(String uri){
+
+ }
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/MessageReciver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/MessageReciver.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/MessageReciver.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/MessageReciver.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,32 @@
+package org.apache.axis.messaging;
+
+import org.apache.axis.description.AxisRegistry;
+
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class MessageReciver {
+ private EPR to;
+ private AxisRegistry registry;
+
+ public MessageReciver(AxisRegistry registry){
+ this.registry = registry;
+ }
+
+
+ public void recive(SOAPEnvelope envelope){
+ //find the transport based on the to
+ //create MessageContext
+ //invoke the Engine
+ }
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/MessageSender.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/MessageSender.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/MessageSender.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/MessageSender.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,59 @@
+package org.apache.axis.messaging;
+
+import org.apache.axis.description.AxisRegistry;
+
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class MessageSender {
+ private EPR to;
+ private EPR replyTo;
+ private AxisRegistry registry;
+
+ public MessageSender(AxisRegistry registry){
+ this.registry = registry;
+ }
+ public void send(SOAPEnvelope envelope){
+ //find the transport based on the to
+ //create MessageContext
+ //invoke the Engine
+ }
+ /**
+ * @return
+ */
+ public EPR getTo() {
+ return to;
+ }
+
+ /**
+ * @param epr
+ */
+ public void setTo(EPR epr) {
+ to = epr;
+ }
+
+ /**
+ * @return
+ */
+ public EPR getReplyTo() {
+ return replyTo;
+ }
+
+ /**
+ * @param epr
+ */
+ public void setReplyTo(EPR epr) {
+ replyTo = epr;
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/SOAPEnvelope.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/SOAPEnvelope.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/SOAPEnvelope.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/SOAPEnvelope.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,24 @@
+package org.apache.axis.messaging;
+import java.io.InputStream;
+
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class SOAPEnvelope {
+ public SOAPEnvelope(InputStream in){
+ }
+
+ public SOAPEnvelope(Exception e){
+ //hack
+ }
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/AsyncProvider.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/AsyncProvider.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/AsyncProvider.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/AsyncProvider.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,20 @@
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.serverapi;
+
+import org.apache.axis.clientapi.Callback;
+import org.apache.axis.context.MessageContext;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public interface AsyncProvider {
+ public void invoke(MessageContext msgCtx,Callback callback);
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/EndpointReciver.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/EndpointReciver.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/EndpointReciver.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/EndpointReciver.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,19 @@
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.serverapi;
+
+import org.apache.axis.context.MessageContext;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public interface EndpointReciver {
+ public void invoke(MessageContext msgctx);
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InEndpointReciverAsync.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InEndpointReciverAsync.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InEndpointReciverAsync.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InEndpointReciverAsync.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,32 @@
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.serverapi;
+
+import org.apache.axis.context.MessageContext;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class InEndpointReciverAsync implements EndpointReciver{
+ private Provider provider;
+ public InEndpointReciverAsync(Provider provider){
+ this.provider = provider;
+ }
+
+ public void invoke(final MessageContext msgctx) {
+ Thread thrad = new Thread(new Runnable() {
+ public void run() {
+ provider.invoke(msgctx);
+ }
+ });
+ thrad.start();
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InEndpointReciverSync.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InEndpointReciverSync.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InEndpointReciverSync.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InEndpointReciverSync.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,27 @@
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.serverapi;
+
+import org.apache.axis.context.MessageContext;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class InEndpointReciverSync implements EndpointReciver{
+ private Provider provider;
+ public InEndpointReciverSync(Provider provider){
+ this.provider = provider;
+ }
+
+ public void invoke(final MessageContext msgctx) {
+ provider.invoke(msgctx);
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InOutEndpointReciverAsync.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InOutEndpointReciverAsync.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InOutEndpointReciverAsync.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InOutEndpointReciverAsync.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,42 @@
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.serverapi;
+
+import org.apache.axis.clientapi.Callback;
+import org.apache.axis.context.MessageContext;
+import org.apache.axis.messaging.MessageSender;
+import org.apache.axis.messaging.SOAPEnvelope;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class InOutEndpointReciverAsync implements EndpointReciver{
+ private AsyncProvider provider;
+ public InOutEndpointReciverAsync(AsyncProvider provider){
+ this.provider = provider;
+ }
+
+ public void invoke(final MessageContext msgctx) {
+ final Callback callback = new Callback() {
+ public void handleResult(SOAPEnvelope env) {
+ MessageSender sender = new MessageSender(msgctx.getRegistry());
+ sender.setTo(msgctx.getReplyTo());
+ sender.send(env);
+ }
+ };
+ Thread thrad = new Thread(new Runnable() {
+ public void run() {
+ provider.invoke(msgctx,callback);
+ }
+ });
+
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InOutEndpointReciverSync.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InOutEndpointReciverSync.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InOutEndpointReciverSync.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/InOutEndpointReciverSync.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,32 @@
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.serverapi;
+
+import org.apache.axis.context.MessageContext;
+import org.apache.axis.messaging.MessageSender;
+import org.apache.axis.messaging.SOAPEnvelope;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class InOutEndpointReciverSync implements EndpointReciver{
+ private Provider provider;
+ public InOutEndpointReciverSync(Provider provider){
+ this.provider = provider;
+ }
+
+ public void invoke(MessageContext msgctx) {
+ SOAPEnvelope result = provider.invoke(msgctx);
+ MessageSender sender = new MessageSender(msgctx.getRegistry());
+ sender.setTo(msgctx.getReplyTo());
+ sender.send(result);
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/Provider.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/Provider.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/Provider.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/Provider.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,20 @@
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.serverapi;
+
+import org.apache.axis.context.MessageContext;
+import org.apache.axis.messaging.SOAPEnvelope;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public interface Provider {
+ public SOAPEnvelope invoke(MessageContext msgCtx);
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/RobustInEndpointReciverAsync.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/RobustInEndpointReciverAsync.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/RobustInEndpointReciverAsync.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/RobustInEndpointReciverAsync.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,41 @@
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.serverapi;
+
+import org.apache.axis.context.MessageContext;
+import org.apache.axis.messaging.MessageSender;
+import org.apache.axis.messaging.SOAPEnvelope;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class RobustInEndpointReciverAsync implements EndpointReciver{
+ private Provider provider;
+ public RobustInEndpointReciverAsync(Provider provider){
+ this.provider = provider;
+ }
+
+ public void invoke(final MessageContext msgctx) {
+ Thread thrad = new Thread(new Runnable() {
+ public void run() {
+ try {
+ provider.invoke(msgctx);
+ } catch (Exception e) {
+ SOAPEnvelope env = new SOAPEnvelope(e);
+ MessageSender sender = new MessageSender(msgctx.getRegistry());
+ sender.setTo(msgctx.getReplyTo());
+ sender.send(env);
+ }
+ }
+ });
+ thrad.start();
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/RobustInEndpointReciverSync.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/RobustInEndpointReciverSync.java?view=auto&rev=158764
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/RobustInEndpointReciverSync.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/RobustInEndpointReciverSync.java Wed Mar 23 05:07:08 2005
@@ -0,0 +1,36 @@
+/*
+ * Created on Mar 23, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.serverapi;
+
+import org.apache.axis.context.MessageContext;
+import org.apache.axis.messaging.MessageSender;
+import org.apache.axis.messaging.SOAPEnvelope;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class RobustInEndpointReciverSync implements EndpointReciver {
+ private Provider provider;
+ public RobustInEndpointReciverSync(Provider provider) {
+ this.provider = provider;
+ }
+
+ public void invoke(final MessageContext msgctx) {
+ try {
+ provider.invoke(msgctx);
+ } catch (Exception e) {
+ SOAPEnvelope env = new SOAPEnvelope(e);
+ MessageSender sender = new MessageSender(msgctx.getRegistry());
+ sender.setTo(msgctx.getReplyTo());
+ sender.send(env);
+ }
+ }
+
+}