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 he...@apache.org on 2005/03/26 16:37:44 UTC
svn commit: r159111 - in
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis:
clientapi/ description/ inapi/ messaging/ outapi/ serverapi/
Author: hemapani
Date: Sat Mar 26 07:37:40 2005
New Revision: 159111
URL: http://svn.apache.org/viewcvs?view=rev&rev=159111
Log:
checked in the updates
Added:
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisMessageEndpoint.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisServiceEndpoint.java
- copied, changed from r158764, 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/description/SOAPEndpoint.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/AsyncProvider.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/EndpointDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InEndpointAsyncDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InEndpointDialogSync.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InOutEndpointAsyncDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InOutEndpointSyncDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/Provider.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/RobustInEndpointAsyncDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/RobustInEndpointSyncDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/Dialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/AbstractSendingDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/Callback.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/CallbacksBag.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendAndReciveAsyncDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendAndReciveSyncDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOneWayRobustSyncDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOnewayDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOnewayRobustAsyncDialog.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/TransportEndpointManager.java
Removed:
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/description/AxisService.java
webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/serverapi/
Modified:
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/AxisMessageEndpoint.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisMessageEndpoint.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisMessageEndpoint.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisMessageEndpoint.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,22 @@
+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 AxisMessageEndpoint implements SOAPEndpoint{
+ public AxisMessageEndpoint(QName name) {
+
+ }
+}
Modified: 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=diff&r1=159110&r2=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisRegistry.java (original)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisRegistry.java Sat Mar 26 07:37:40 2005
@@ -1,7 +1,7 @@
package org.apache.axis.description;
-import org.apache.axis.clientapi.CallbacksBag;
-import org.apache.axis.clientapi.TransportEndpointManager;
+import org.apache.axis.outapi.CallbacksBag;
+import org.apache.axis.outapi.TransportEndpointManager;
/*
* Created on Mar 23, 2005
@@ -22,7 +22,7 @@
return epm;
}
- public void addService(AxisService service){
+ public void addService(AxisServiceEndpoint service){
}
Copied: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisServiceEndpoint.java (from r158764, 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/AxisServiceEndpoint.java?view=diff&rev=159111&p1=webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisService.java&r1=158764&p2=webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisServiceEndpoint.java&r2=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisService.java (original)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/AxisServiceEndpoint.java Sat Mar 26 07:37:40 2005
@@ -15,8 +15,8 @@
* 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) {
+public class AxisServiceEndpoint implements SOAPEndpoint{
+ public AxisServiceEndpoint(QName name) {
}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/SOAPEndpoint.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/SOAPEndpoint.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/SOAPEndpoint.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/description/SOAPEndpoint.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,17 @@
+/*
+ * Created on Mar 26, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.description;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public interface SOAPEndpoint {
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/AsyncProvider.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/AsyncProvider.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/AsyncProvider.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/AsyncProvider.java Sat Mar 26 07:37:40 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.inapi;
+
+import org.apache.axis.outapi.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/inapi/EndpointDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/EndpointDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/EndpointDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/EndpointDialog.java Sat Mar 26 07:37:40 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.inapi;
+
+import org.apache.axis.context.MessageContext;
+import org.apache.axis.messaging.Dialog;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public interface EndpointDialog extends Dialog{
+ public void handleMessage(MessageContext msgctx);
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InEndpointAsyncDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InEndpointAsyncDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InEndpointAsyncDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InEndpointAsyncDialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,43 @@
+/*
+ * 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.inapi;
+
+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 InEndpointAsyncDialog implements EndpointDialog{
+ private Provider provider;
+
+ public void handleMessage(final MessageContext msgctx) {
+ Thread thrad = new Thread(new Runnable() {
+ public void run() {
+ provider.invoke(msgctx);
+ }
+ });
+ thrad.start();
+ }
+
+ /**
+ * @return
+ */
+ public Provider getProvider() {
+ return provider;
+ }
+
+ /**
+ * @param provider
+ */
+ public void setProvider(Provider provider) {
+ this.provider = provider;
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InEndpointDialogSync.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InEndpointDialogSync.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InEndpointDialogSync.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InEndpointDialogSync.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,37 @@
+/*
+ * 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.inapi;
+
+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 InEndpointDialogSync implements EndpointDialog{
+ private Provider provider;
+
+
+ public void handleMessage(final MessageContext msgctx) {
+ provider.invoke(msgctx);
+ }
+ /**
+ * @return
+ */
+ public Provider getProvider() {
+ return provider;
+ }
+
+ /**
+ * @param provider
+ */
+ public void setProvider(Provider provider) {
+ this.provider = provider;
+ }
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InOutEndpointAsyncDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InOutEndpointAsyncDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InOutEndpointAsyncDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InOutEndpointAsyncDialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,53 @@
+/*
+ * 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.inapi;
+
+import org.apache.axis.outapi.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 InOutEndpointAsyncDialog implements EndpointDialog{
+ private AsyncProvider provider;
+
+
+ public void handleMessage(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);
+ }
+ });
+
+ }
+ /**
+ * @return
+ */
+ public AsyncProvider getProvider() {
+ return provider;
+ }
+
+ /**
+ * @param provider
+ */
+ public void setProvider(AsyncProvider provider) {
+ this.provider = provider;
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InOutEndpointSyncDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InOutEndpointSyncDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InOutEndpointSyncDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/InOutEndpointSyncDialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,44 @@
+/*
+ * 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.inapi;
+
+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 InOutEndpointSyncDialog implements EndpointDialog{
+ private Provider provider;
+
+
+ public void handleMessage(MessageContext msgctx) {
+ SOAPEnvelope result = provider.invoke(msgctx);
+ MessageSender sender = new MessageSender(msgctx.getRegistry());
+ sender.setTo(msgctx.getReplyTo());
+ sender.send(result);
+ }
+
+ /**
+ * @return
+ */
+ public Provider getProvider() {
+ return provider;
+ }
+
+ /**
+ * @param provider
+ */
+ public void setProvider(Provider provider) {
+ this.provider = provider;
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/Provider.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/Provider.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/Provider.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/Provider.java Sat Mar 26 07:37:40 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.inapi;
+
+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/inapi/RobustInEndpointAsyncDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/RobustInEndpointAsyncDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/RobustInEndpointAsyncDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/RobustInEndpointAsyncDialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,53 @@
+/*
+ * 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.inapi;
+
+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 RobustInEndpointAsyncDialog implements EndpointDialog{
+ private Provider provider;
+
+
+ public void handleMessage(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();
+ }
+
+ /**
+ * @return
+ */
+ public Provider getProvider() {
+ return provider;
+ }
+
+ /**
+ * @param provider
+ */
+ public void setProvider(Provider provider) {
+ this.provider = provider;
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/RobustInEndpointSyncDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/RobustInEndpointSyncDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/RobustInEndpointSyncDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/inapi/RobustInEndpointSyncDialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,48 @@
+/*
+ * 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.inapi;
+
+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 RobustInEndpointSyncDialog implements EndpointDialog {
+ private Provider provider;
+
+
+ public void handleMessage(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);
+ }
+ }
+
+ /**
+ * @return
+ */
+ public Provider getProvider() {
+ return provider;
+ }
+
+ /**
+ * @param provider
+ */
+ public void setProvider(Provider provider) {
+ this.provider = provider;
+ }
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/Dialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/Dialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/Dialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/messaging/Dialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,17 @@
+/*
+ * Created on Mar 26, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.messaging;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public interface Dialog {
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/AbstractSendingDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/AbstractSendingDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/AbstractSendingDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/AbstractSendingDialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,32 @@
+package org.apache.axis.outapi;
+import org.apache.axis.context.MessageContext;
+import org.apache.axis.description.AxisRegistry;
+import org.apache.axis.inapi.EndpointDialog;
+
+/*
+ * 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 AbstractSendingDialog {
+ AxisRegistry registry;
+ public static class CallbackReciver implements EndpointDialog {
+ private CallbacksBag callbacks;
+ public CallbackReciver(CallbacksBag callbacks) {
+ this.callbacks = callbacks;
+ }
+ public void handleMessage(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/outapi/Callback.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/Callback.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/Callback.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/Callback.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,20 @@
+package org.apache.axis.outapi;
+
+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/outapi/CallbacksBag.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/CallbacksBag.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/CallbacksBag.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/CallbacksBag.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,25 @@
+package org.apache.axis.outapi;
+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/outapi/SendAndReciveAsyncDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendAndReciveAsyncDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendAndReciveAsyncDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendAndReciveAsyncDialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,39 @@
+/*
+ * Created on Mar 26, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.outapi;
+
+import org.apache.axis.description.AxisServiceEndpoint;
+import org.apache.axis.messaging.EPR;
+import org.apache.axis.messaging.MessageSender;
+import org.apache.axis.messaging.SOAPEnvelope;
+import org.apache.xml.utils.QName;
+
+/**
+ * @author srinath
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class SendAndReciveAsyncDialog extends AbstractSendingDialog {
+ 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());
+ AxisServiceEndpoint service = new AxisServiceEndpoint(new QName(serviceName));
+ CallbacksBag bag = registry.getCallBackBag();
+ bag.addCallBack(messageId,callback);
+ service.setReciever(new CallbackReciver(bag));
+ registry.addService(service);
+ }
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendAndReciveSyncDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendAndReciveSyncDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendAndReciveSyncDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendAndReciveSyncDialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,32 @@
+/*
+ * Created on Mar 26, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.outapi;
+
+import java.io.InputStream;
+
+import org.apache.axis.messaging.EPR;
+import org.apache.axis.messaging.MessageReciver;
+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 SendAndReciveSyncDialog extends AbstractSendingDialog {
+ 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;
+ }
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOneWayRobustSyncDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOneWayRobustSyncDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOneWayRobustSyncDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOneWayRobustSyncDialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,46 @@
+/*
+ * Created on Mar 26, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.outapi;
+
+import java.io.InputStream;
+
+import org.apache.axis.messaging.EPR;
+import org.apache.axis.messaging.MessageReciver;
+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 SendOneWayRobustSyncDialog extends AbstractSendingDialog {
+ 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
+ }
+
+
+
+ }
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOnewayDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOnewayDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOnewayDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOnewayDialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,28 @@
+/*
+ * Created on Mar 26, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+package org.apache.axis.outapi;
+
+import org.apache.axis.messaging.EPR;
+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 SendOnewayDialog extends AbstractSendingDialog {
+ 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
+ }
+ }
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOnewayRobustAsyncDialog.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOnewayRobustAsyncDialog.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOnewayRobustAsyncDialog.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/SendOnewayRobustAsyncDialog.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,48 @@
+package org.apache.axis.outapi;
+import org.apache.axis.description.AxisRegistry;
+import org.apache.axis.description.AxisServiceEndpoint;
+import org.apache.axis.messaging.EPR;
+import org.apache.axis.messaging.MessageSender;
+import org.apache.axis.messaging.SOAPEnvelope;
+import org.apache.axis.outapi.AbstractSendingDialog.CallbackReciver;
+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 SendOnewayRobustAsyncDialog {
+ AxisRegistry registry;
+
+ 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());
+ AxisServiceEndpoint service = new AxisServiceEndpoint(new QName(serviceName));
+ CallbacksBag bag = registry.getCallBackBag();
+ bag.addCallBack(messageId,callback);
+ service.setReciever(new CallbackReciver(bag));
+ registry.addService(service);
+ }
+
+
+}
Added: webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/TransportEndpointManager.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/TransportEndpointManager.java?view=auto&rev=159111
==============================================================================
--- webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/TransportEndpointManager.java (added)
+++ webservices/axis/trunk/archive/java/scratch/srinath_jaliya/src/org/apache/axis/outapi/TransportEndpointManager.java Sat Mar 26 07:37:40 2005
@@ -0,0 +1,42 @@
+package org.apache.axis.outapi;
+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) {
+
+ }
+
+}