Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriberServiceLocator.java URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriberServiceLocator.java?view=auto&rev=149274 ============================================================================== --- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriberServiceLocator.java (added) +++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriberServiceLocator.java Mon Jan 31 09:47:06 2005 @@ -0,0 +1,255 @@ +/** + * EventingServiceLocator.java + * + * This file was auto-generated from WSDL + * by the Apache Axis 1.2RC2 Dec 19, 2004 (04:36:14 CET) WSDL2Java emitter. + */ + +package org.apache.ws.eventing.services.subscriber; + +public class SubscriberServiceLocator extends org.apache.axis.client.Service implements org.apache.ws.eventing.services.subscriber.SubscriberService { + +/** + * A publish subscribe system based on web services + */ + + public SubscriberServiceLocator() { + } + + + public SubscriberServiceLocator(org.apache.axis.EngineConfiguration config) { + super(config); + } + + // Use to get a proxy class for EventSourcePort + private java.lang.String EventSourcePort_address = "http://localhost:8080/axis/services/EventSourcePort";; + + public java.lang.String getEventSourcePortAddress() { + return EventSourcePort_address; + } + + // The WSDD service name defaults to the port name. + private java.lang.String EventSourcePortWSDDServiceName = "EventSourcePort"; + + public java.lang.String getEventSourcePortWSDDServiceName() { + return EventSourcePortWSDDServiceName; + } + + public void setEventSourcePortWSDDServiceName(java.lang.String name) { + EventSourcePortWSDDServiceName = name; + } + + public org.apache.ws.eventing.services.EventSource getEventSourcePort() throws javax.xml.rpc.ServiceException { + java.net.URL endpoint; + try { + endpoint = new java.net.URL(EventSourcePort_address); + } + catch (java.net.MalformedURLException e) { + throw new javax.xml.rpc.ServiceException(e); + } + return getEventSourcePort(endpoint); + } + + public org.apache.ws.eventing.services.EventSource getEventSourcePort(java.net.URL portAddress) throws javax.xml.rpc.ServiceException { + try { + org.apache.ws.eventing.services.subscriber.EventSourceBindingStub _stub = new org.apache.ws.eventing.services.subscriber.EventSourceBindingStub(portAddress, this); + _stub.setPortName(getEventSourcePortWSDDServiceName()); + return _stub; + } + catch (org.apache.axis.AxisFault e) { + return null; + } + } + + public void setEventSourcePortEndpointAddress(java.lang.String address) { + EventSourcePort_address = address; + } + + + // Use to get a proxy class for SubscriptionManagerPort + private java.lang.String SubscriptionManagerPort_address = "http://localhost:8080/axis/services/SubscriptionManagerPort";; + + public java.lang.String getSubscriptionManagerPortAddress() { + return SubscriptionManagerPort_address; + } + + // The WSDD service name defaults to the port name. + private java.lang.String SubscriptionManagerPortWSDDServiceName = "SubscriptionManagerPort"; + + public java.lang.String getSubscriptionManagerPortWSDDServiceName() { + return SubscriptionManagerPortWSDDServiceName; + } + + public void setSubscriptionManagerPortWSDDServiceName(java.lang.String name) { + SubscriptionManagerPortWSDDServiceName = name; + } + + public org.apache.ws.eventing.services.SubscriptionManager getSubscriptionManagerPort() throws javax.xml.rpc.ServiceException { + java.net.URL endpoint; + try { + endpoint = new java.net.URL(SubscriptionManagerPort_address); + } + catch (java.net.MalformedURLException e) { + throw new javax.xml.rpc.ServiceException(e); + } + return getSubscriptionManagerPort(endpoint); + } + + public org.apache.ws.eventing.services.SubscriptionManager getSubscriptionManagerPort(java.net.URL portAddress) throws javax.xml.rpc.ServiceException { + try { + org.apache.ws.eventing.services.subscriber.SubscriptionManagerBindingStub _stub = new org.apache.ws.eventing.services.subscriber.SubscriptionManagerBindingStub(portAddress, this); + _stub.setPortName(getSubscriptionManagerPortWSDDServiceName()); + return _stub; + } + catch (org.apache.axis.AxisFault e) { + return null; + } + } + + public void setSubscriptionManagerPortEndpointAddress(java.lang.String address) { + SubscriptionManagerPort_address = address; + } + + + // Use to get a proxy class for SubscriptionEndPort + private java.lang.String SubscriptionEndPort_address = "http://localhost:8080/axis/services/SubscriptionEndPort";; + + public java.lang.String getSubscriptionEndPortAddress() { + return SubscriptionEndPort_address; + } + + // The WSDD service name defaults to the port name. + private java.lang.String SubscriptionEndPortWSDDServiceName = "SubscriptionEndPort"; + + public java.lang.String getSubscriptionEndPortWSDDServiceName() { + return SubscriptionEndPortWSDDServiceName; + } +/* + public void setSubscriptionEndPortWSDDServiceName(java.lang.String name) { + SubscriptionEndPortWSDDServiceName = name; + } + + public org.apache.ws.eventing.services.SubscriptionEnd getSubscriptionEndPort() throws javax.xml.rpc.ServiceException { + java.net.URL endpoint; + try { + endpoint = new java.net.URL(SubscriptionEndPort_address); + } + catch (java.net.MalformedURLException e) { + throw new javax.xml.rpc.ServiceException(e); + } + return getSubscriptionEndPort(endpoint); + } + + public org.apache.ws.eventing.services.SubscriptionEnd getSubscriptionEndPort(java.net.URL portAddress) throws javax.xml.rpc.ServiceException { + try { + org.apache.ws.eventing.services.subscriber.SubscriptionEndBindingStub _stub = new org.apache.ws.eventing.services.subscriber.SubscriptionEndBindingStub(portAddress, this); + _stub.setPortName(getSubscriptionEndPortWSDDServiceName()); + return _stub; + } + catch (org.apache.axis.AxisFault e) { + return null; + } + } + + public void setSubscriptionEndPortEndpointAddress(java.lang.String address) { + SubscriptionEndPort_address = address; + } +*/ + /** + * For the given interface, get the stub implementation. + * If this service has no port for the given interface, + * then ServiceException is thrown. + */ + public java.rmi.Remote getPort(Class serviceEndpointInterface) throws javax.xml.rpc.ServiceException { + try { + if (org.apache.ws.eventing.services.EventSource.class.isAssignableFrom(serviceEndpointInterface)) { + org.apache.ws.eventing.services.subscriber.EventSourceBindingStub _stub = new org.apache.ws.eventing.services.subscriber.EventSourceBindingStub(new java.net.URL(EventSourcePort_address), this); + _stub.setPortName(getEventSourcePortWSDDServiceName()); + return _stub; + } + if (org.apache.ws.eventing.services.SubscriptionManager.class.isAssignableFrom(serviceEndpointInterface)) { + org.apache.ws.eventing.services.subscriber.SubscriptionManagerBindingStub _stub = new org.apache.ws.eventing.services.subscriber.SubscriptionManagerBindingStub(new java.net.URL(SubscriptionManagerPort_address), this); + _stub.setPortName(getSubscriptionManagerPortWSDDServiceName()); + return _stub; + } + /* + if (org.apache.ws.eventing.services.SubscriptionEnd.class.isAssignableFrom(serviceEndpointInterface)) { + org.apache.ws.eventing.services.SubscriptionEndBindingStub _stub = new org.apache.ws.eventing.services.SubscriptionEndBindingStub(new java.net.URL(SubscriptionEndPort_address), this); + _stub.setPortName(getSubscriptionEndPortWSDDServiceName()); + return _stub; + }*/ + } + catch (java.lang.Throwable t) { + throw new javax.xml.rpc.ServiceException(t); + } + throw new javax.xml.rpc.ServiceException("There is no stub implementation for the interface: " + (serviceEndpointInterface == null ? "null" : serviceEndpointInterface.getName())); + } + + /** + * For the given interface, get the stub implementation. + * If this service has no port for the given interface, + * then ServiceException is thrown. + */ + public java.rmi.Remote getPort(javax.xml.namespace.QName portName, Class serviceEndpointInterface) throws javax.xml.rpc.ServiceException { + if (portName == null) { + return getPort(serviceEndpointInterface); + } + java.lang.String inputPortName = portName.getLocalPart(); + if ("EventSourcePort".equals(inputPortName)) { + return getEventSourcePort(); + } + else if ("SubscriptionManagerPort".equals(inputPortName)) { + return getSubscriptionManagerPort(); + } +/* else if ("SubscriptionEndPort".equals(inputPortName)) { + return getSubscriptionEndPort(); + }*/ + else { + java.rmi.Remote _stub = getPort(serviceEndpointInterface); + ((org.apache.axis.client.Stub) _stub).setPortName(portName); + return _stub; + } + } + + public javax.xml.namespace.QName getServiceName() { + return new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing/services";, "EventingService"); + } + + private java.util.HashSet ports = null; + + public java.util.Iterator getPorts() { + if (ports == null) { + ports = new java.util.HashSet(); + ports.add(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing/services";, "EventSourcePort")); + ports.add(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing/services";, "SubscriptionManagerPort")); + ports.add(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing/services";, "SubscriptionEndPort")); + } + return ports.iterator(); + } + + /** + * Set the endpoint address for the specified port name. + */ + public void setEndpointAddress(java.lang.String portName, java.lang.String address) throws javax.xml.rpc.ServiceException { + if ("EventSourcePort".equals(portName)) { + setEventSourcePortEndpointAddress(address); + } + if ("SubscriptionManagerPort".equals(portName)) { + setSubscriptionManagerPortEndpointAddress(address); + } +/* if ("SubscriptionEndPort".equals(portName)) { + setSubscriptionEndPortEndpointAddress(address); + }*/ + else { // Unknown Port Name + throw new javax.xml.rpc.ServiceException(" Cannot set Endpoint Address for Unknown Port" + portName); + } + } + + /** + * Set the endpoint address for the specified port name. + */ + public void setEndpointAddress(javax.xml.namespace.QName portName, java.lang.String address) throws javax.xml.rpc.ServiceException { + setEndpointAddress(portName.getLocalPart(), address); + } + +}
Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionEndBindingImpl.java URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionEndBindingImpl.java?view=auto&rev=149274 ============================================================================== --- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionEndBindingImpl.java (added) +++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionEndBindingImpl.java Mon Jan 31 09:47:06 2005 @@ -0,0 +1,14 @@ +/** + * SubscriptionEndBindingImpl.java + * + * This file was auto-generated from WSDL + * by the Apache Axis 1.2RC2 Dec 19, 2004 (04:36:14 CET) WSDL2Java emitter. + */ + +package org.apache.ws.eventing.services.subscriber; + +public class SubscriptionEndBindingImpl implements org.apache.ws.eventing.services.SubscriptionEnd{ + public void subscriptionEnd(org.apache.ws.eventing.base.SubscriptionEnd body) throws java.rmi.RemoteException { + + } +} Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionEndBindingSkeleton.java URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionEndBindingSkeleton.java?view=auto&rev=149274 ============================================================================== --- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionEndBindingSkeleton.java (added) +++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionEndBindingSkeleton.java Mon Jan 31 09:47:06 2005 @@ -0,0 +1,58 @@ +/** + * SubscriptionEndBindingSkeleton.java + * + * This file was auto-generated from WSDL + * by the Apache Axis 1.2RC2 Dec 19, 2004 (04:36:14 CET) WSDL2Java emitter. + */ + +package org.apache.ws.eventing.services.subscriber; + +public class SubscriptionEndBindingSkeleton implements org.apache.ws.eventing.services.SubscriptionEnd, org.apache.axis.wsdl.Skeleton { + private org.apache.ws.eventing.services.SubscriptionEnd impl; + private static java.util.Map _myOperations = new java.util.Hashtable(); + private static java.util.Collection _myOperationsList = new java.util.ArrayList(); + + /** + * Returns List of OperationDesc objects with this name + */ + public static java.util.List getOperationDescByName(java.lang.String methodName) { + return (java.util.List)_myOperations.get(methodName); + } + + /** + * Returns Collection of OperationDescs + */ + public static java.util.Collection getOperationDescs() { + return _myOperationsList; + } + + static { + org.apache.axis.description.OperationDesc _oper; + org.apache.axis.description.FaultDesc _fault; + org.apache.axis.description.ParameterDesc [] _params; + _params = new org.apache.axis.description.ParameterDesc [] { + new org.apache.axis.description.ParameterDesc(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "SubscriptionEnd"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">SubscriptionEnd"), org.apache.ws.eventing.base.SubscriptionEnd.class, false, false), + }; + _oper = new org.apache.axis.description.OperationDesc("subscriptionEnd", _params, null); + _oper.setElementQName(new javax.xml.namespace.QName("", "SubscriptionEnd")); + _oper.setSoapAction("http://schemas.xmlsoap.org/ws/2004/08/eventing/SubscriptionEnd";); + _myOperationsList.add(_oper); + if (_myOperations.get("subscriptionEnd") == null) { + _myOperations.put("subscriptionEnd", new java.util.ArrayList()); + } + ((java.util.List)_myOperations.get("subscriptionEnd")).add(_oper); + } + + public SubscriptionEndBindingSkeleton() { + this.impl = new org.apache.ws.eventing.services.subscriber.SubscriptionEndBindingImpl(); + } + + public SubscriptionEndBindingSkeleton(org.apache.ws.eventing.services.SubscriptionEnd impl) { + this.impl = impl; + } + public void subscriptionEnd(org.apache.ws.eventing.base.SubscriptionEnd body) throws java.rmi.RemoteException + { + impl.subscriptionEnd(body); + } + +} Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionManagerBindingStub.java URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionManagerBindingStub.java?view=auto&rev=149274 ============================================================================== --- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionManagerBindingStub.java (added) +++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriptionManagerBindingStub.java Mon Jan 31 09:47:06 2005 @@ -0,0 +1,428 @@ +/** + * SubscriptionManagerBindingStub.java + * + * This file was auto-generated from WSDL + * by the Apache Axis 1.2RC2 Dec 19, 2004 (04:36:14 CET) WSDL2Java emitter. + */ + +package org.apache.ws.eventing.services.subscriber; + +public class SubscriptionManagerBindingStub extends org.apache.axis.client.Stub implements org.apache.ws.eventing.services.SubscriptionManager { + private java.util.Vector cachedSerClasses = new java.util.Vector(); + private java.util.Vector cachedSerQNames = new java.util.Vector(); + private java.util.Vector cachedSerFactories = new java.util.Vector(); + private java.util.Vector cachedDeserFactories = new java.util.Vector(); + + static org.apache.axis.description.OperationDesc [] _operations; + + static { + _operations = new org.apache.axis.description.OperationDesc[3]; + _initOperationDesc1(); + } + + private static void _initOperationDesc1(){ + org.apache.axis.description.OperationDesc oper; + oper = new org.apache.axis.description.OperationDesc(); + oper.setName("RenewMsg"); + oper.addParameter(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "Renew"), new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">Renew"), org.apache.ws.eventing.base.Renew.class, org.apache.axis.description.ParameterDesc.IN, false, false); + oper.setReturnType(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">RenewResponse")); + oper.setReturnClass(org.apache.ws.eventing.base.RenewResponse.class); + oper.setReturnQName(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "RenewResponse")); + oper.setStyle(org.apache.axis.constants.Style.DOCUMENT); + oper.setUse(org.apache.axis.constants.Use.LITERAL); + _operations[0] = oper; + + oper = new org.apache.axis.description.OperationDesc(); + oper.setName("GetStatusMsg"); + oper.addParameter(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "GetStatus"), new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">GetStatus"), org.apache.ws.eventing.base.GetStatus.class, org.apache.axis.description.ParameterDesc.IN, false, false); + oper.setReturnType(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">GetStatusResponse")); + oper.setReturnClass(org.apache.ws.eventing.base.GetStatusResponse.class); + oper.setReturnQName(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "GetStatusResponse")); + oper.setStyle(org.apache.axis.constants.Style.DOCUMENT); + oper.setUse(org.apache.axis.constants.Use.LITERAL); + _operations[1] = oper; + + oper = new org.apache.axis.description.OperationDesc(); + oper.setName("UnsubscribeMsg"); + oper.addParameter(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "Unsubscribe"), new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">Unsubscribe"), org.apache.ws.eventing.base.Unsubscribe.class, org.apache.axis.description.ParameterDesc.IN, false, false); + oper.setReturnType(org.apache.axis.encoding.XMLType.AXIS_VOID); + oper.setStyle(org.apache.axis.constants.Style.DOCUMENT); + oper.setUse(org.apache.axis.constants.Use.LITERAL); + _operations[2] = oper; + + } + + public SubscriptionManagerBindingStub() throws org.apache.axis.AxisFault { + this(null); + } + + public SubscriptionManagerBindingStub(java.net.URL endpointURL, javax.xml.rpc.Service service) throws org.apache.axis.AxisFault { + this(service); + super.cachedEndpoint = endpointURL; + } + + public SubscriptionManagerBindingStub(javax.xml.rpc.Service service) throws org.apache.axis.AxisFault { + if (service == null) { + super.service = new org.apache.axis.client.Service(); + } else { + super.service = service; + } + java.lang.Class cls; + javax.xml.namespace.QName qName; + java.lang.Class beansf = org.apache.axis.encoding.ser.BeanSerializerFactory.class; + java.lang.Class beandf = org.apache.axis.encoding.ser.BeanDeserializerFactory.class; + java.lang.Class enumsf = org.apache.axis.encoding.ser.EnumSerializerFactory.class; + java.lang.Class enumdf = org.apache.axis.encoding.ser.EnumDeserializerFactory.class; + java.lang.Class arraysf = org.apache.axis.encoding.ser.ArraySerializerFactory.class; + java.lang.Class arraydf = org.apache.axis.encoding.ser.ArrayDeserializerFactory.class; + java.lang.Class simplesf = org.apache.axis.encoding.ser.SimpleSerializerFactory.class; + java.lang.Class simpledf = org.apache.axis.encoding.ser.SimpleDeserializerFactory.class; + java.lang.Class simplelistsf = org.apache.axis.encoding.ser.SimpleListSerializerFactory.class; + java.lang.Class simplelistdf = org.apache.axis.encoding.ser.SimpleListDeserializerFactory.class; + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "LanguageSpecificStringType"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.LanguageSpecificStringType.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(simplesf); + cachedDeserFactories.add(simpledf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "ExpirationType"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.ExpirationType.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(simplesf); + cachedDeserFactories.add(simpledf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/addressing";, "FaultSubcodeValues"); + cachedSerQNames.add(qName); + cls = org.apache.axis.message.addressing.FaultSubcodeValues.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(enumsf); + cachedDeserFactories.add(enumdf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">RenewResponse"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.RenewResponse.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "SubscriptionEndCodeType"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.SubscriptionEndCodeType.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(enumsf); + cachedDeserFactories.add(enumdf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "OpenSubscriptionEndCodeType"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.OpenSubscriptionEndCodeType.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(simplesf); + cachedDeserFactories.add(simpledf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">GetStatus"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.GetStatus.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "DeliveryType"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.DeliveryType.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "NonNegativeDurationType"); + cachedSerQNames.add(qName); + cls = org.apache.axis.types.Duration.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(simplesf); + cachedDeserFactories.add(simpledf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">SubscriptionEnd"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.SubscriptionEnd.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">Renew"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.Renew.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/addressing";, "ReferencePropertiesType"); + cachedSerQNames.add(qName); + cls = org.apache.axis.message.addressing.ReferencePropertiesType.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/addressing";, "ReferenceParametersType"); + cachedSerQNames.add(qName); + cls = org.apache.axis.message.addressing.ReferenceParametersType.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">SubscribeResponse"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.SubscribeResponse.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/addressing";, "ServiceNameType"); + cachedSerQNames.add(qName); + cls = org.apache.axis.message.addressing.ServiceNameType.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(simplesf); + cachedDeserFactories.add(simpledf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/addressing";, "ReplyAfterType"); + cachedSerQNames.add(qName); + cls = org.apache.axis.message.addressing.ReplyAfterType.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(simplesf); + cachedDeserFactories.add(simpledf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/addressing";, "AttributedURI"); + cachedSerQNames.add(qName); + cls = org.apache.axis.message.addressing.AttributedURI.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(simplesf); + cachedDeserFactories.add(simpledf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">GetStatusResponse"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.GetStatusResponse.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">Unsubscribe"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.Unsubscribe.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, ">Subscribe"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.Subscribe.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "FilterType"); + cachedSerQNames.add(qName); + cls = org.apache.ws.eventing.base.FilterType.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/addressing";, "RelationshipTypeValues"); + cachedSerQNames.add(qName); + cls = org.apache.axis.message.addressing.RelationshipTypeValues.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(enumsf); + cachedDeserFactories.add(enumdf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/addressing";, "Relationship"); + cachedSerQNames.add(qName); + cls = org.apache.axis.message.addressing.Relationship.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(simplesf); + cachedDeserFactories.add(simpledf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/addressing";, "EndpointReferenceType"); + cachedSerQNames.add(qName); + cls = org.apache.axis.message.addressing.EndpointReferenceType.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(beansf); + cachedDeserFactories.add(beandf); + + qName = new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/addressing";, "AttributedQName"); + cachedSerQNames.add(qName); + cls = org.apache.axis.message.addressing.AttributedQName.class; + cachedSerClasses.add(cls); + cachedSerFactories.add(simplesf); + cachedDeserFactories.add(simpledf); + + } + + protected org.apache.axis.client.Call createCall() throws java.rmi.RemoteException { + try { + org.apache.axis.client.Call _call = + (org.apache.axis.client.Call) super.service.createCall(); + if (super.maintainSessionSet) { + _call.setMaintainSession(super.maintainSession); + } + if (super.cachedUsername != null) { + _call.setUsername(super.cachedUsername); + } + if (super.cachedPassword != null) { + _call.setPassword(super.cachedPassword); + } + if (super.cachedEndpoint != null) { + _call.setTargetEndpointAddress(super.cachedEndpoint); + } + if (super.cachedTimeout != null) { + _call.setTimeout(super.cachedTimeout); + } + if (super.cachedPortName != null) { + _call.setPortName(super.cachedPortName); + } + java.util.Enumeration keys = super.cachedProperties.keys(); + while (keys.hasMoreElements()) { + java.lang.String key = (java.lang.String) keys.nextElement(); + _call.setProperty(key, super.cachedProperties.get(key)); + } + // All the type mapping information is registered + // when the first call is made. + // The type mapping information is actually registered in + // the TypeMappingRegistry of the service, which + // is the reason why registration is only needed for the first call. + synchronized (this) { + if (firstCall()) { + // must set encoding style before registering serializers + _call.setEncodingStyle(null); + for (int i = 0; i < cachedSerFactories.size(); ++i) { + java.lang.Class cls = (java.lang.Class) cachedSerClasses.get(i); + javax.xml.namespace.QName qName = + (javax.xml.namespace.QName) cachedSerQNames.get(i); + Object x = cachedSerFactories.get(i); + if (x instanceof Class) { + java.lang.Class sf = (java.lang.Class) + cachedSerFactories.get(i); + java.lang.Class df = (java.lang.Class) + cachedDeserFactories.get(i); + _call.registerTypeMapping(cls, qName, sf, df, false); + } + else if (x instanceof javax.xml.rpc.encoding.SerializerFactory) { + org.apache.axis.encoding.SerializerFactory sf = (org.apache.axis.encoding.SerializerFactory) + cachedSerFactories.get(i); + org.apache.axis.encoding.DeserializerFactory df = (org.apache.axis.encoding.DeserializerFactory) + cachedDeserFactories.get(i); + _call.registerTypeMapping(cls, qName, sf, df, false); + } + } + } + } + return _call; + } + catch (java.lang.Throwable _t) { + throw new org.apache.axis.AxisFault("Failure trying to get the Call object", _t); + } + } + + public org.apache.ws.eventing.base.RenewResponse renewMsg(org.apache.ws.eventing.base.Renew body) throws java.rmi.RemoteException { + if (super.cachedEndpoint == null) { + throw new org.apache.axis.NoEndPointException(); + } + org.apache.axis.client.Call _call = createCall(); + _call.setOperation(_operations[0]); + _call.setUseSOAPAction(true); + _call.setSOAPActionURI("http://schemas.xmlsoap.org/ws/2004/08/eventing/RenewMsg";); + _call.setEncodingStyle(null); + _call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE); + _call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE); + _call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP11_CONSTANTS); + _call.setOperationName(new javax.xml.namespace.QName("", "RenewMsg")); + + setRequestHeaders(_call); + setAttachments(_call); + java.lang.Object _resp = _call.invoke(new java.lang.Object[] {body}); + + if (_resp instanceof java.rmi.RemoteException) { + throw (java.rmi.RemoteException)_resp; + } + else { + extractAttachments(_call); + try { + return (org.apache.ws.eventing.base.RenewResponse) _resp; + } catch (java.lang.Exception _exception) { + return (org.apache.ws.eventing.base.RenewResponse) org.apache.axis.utils.JavaUtils.convert(_resp, org.apache.ws.eventing.base.RenewResponse.class); + } + } + } + + public org.apache.ws.eventing.base.GetStatusResponse getStatusMsg(org.apache.ws.eventing.base.GetStatus body) throws java.rmi.RemoteException { + if (super.cachedEndpoint == null) { + throw new org.apache.axis.NoEndPointException(); + } + org.apache.axis.client.Call _call = createCall(); + _call.setOperation(_operations[1]); + _call.setUseSOAPAction(true); + _call.setSOAPActionURI("http://schemas.xmlsoap.org/ws/2004/08/eventing/GetStatusMsg";); + _call.setEncodingStyle(null); + _call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE); + _call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE); + _call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP11_CONSTANTS); + _call.setOperationName(new javax.xml.namespace.QName("", "GetStatusMsg")); + + setRequestHeaders(_call); + setAttachments(_call); + try{ + org.apache.axis.message.SOAPHeaderElement idh =new org.apache.axis.message.SOAPHeaderElement("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "Identifier"); + idh.addTextNode(body.getID()); + _call.addHeader(idh); + System.out.println("getStatus : added identifier header "+body.getID() +" - "+idh.toString()); + }catch(Exception e){ + e.printStackTrace(); + throw new java.rmi.RemoteException("set <wse:Identifier/>",e); + } + java.lang.Object _resp = _call.invoke(new java.lang.Object[] {body}); + + if (_resp instanceof java.rmi.RemoteException) { + throw (java.rmi.RemoteException)_resp; + } + else { + extractAttachments(_call); + try { + return (org.apache.ws.eventing.base.GetStatusResponse) _resp; + } catch (java.lang.Exception _exception) { + return (org.apache.ws.eventing.base.GetStatusResponse) org.apache.axis.utils.JavaUtils.convert(_resp, org.apache.ws.eventing.base.GetStatusResponse.class); + } + } + } + + public void unsubscribeMsg(org.apache.ws.eventing.base.Unsubscribe body) throws java.rmi.RemoteException { + if (super.cachedEndpoint == null) { + throw new org.apache.axis.NoEndPointException(); + } + org.apache.axis.client.Call _call = createCall(); + _call.setOperation(_operations[2]); + _call.setUseSOAPAction(true); + _call.setSOAPActionURI("http://schemas.xmlsoap.org/ws/2004/08/eventing/UnsubscribeMsg";); + _call.setEncodingStyle(null); + _call.setProperty(org.apache.axis.client.Call.SEND_TYPE_ATTR, Boolean.FALSE); + _call.setProperty(org.apache.axis.AxisEngine.PROP_DOMULTIREFS, Boolean.FALSE); + _call.setSOAPVersion(org.apache.axis.soap.SOAPConstants.SOAP11_CONSTANTS); + _call.setOperationName(new javax.xml.namespace.QName("", "UnsubscribeMsg")); + + setRequestHeaders(_call); + setAttachments(_call); + try{ + org.apache.axis.message.SOAPHeaderElement idh =new org.apache.axis.message.SOAPHeaderElement("http://schemas.xmlsoap.org/ws/2004/08/eventing";, "Identifier"); + idh.addTextNode(body.getID()); + _call.addHeader(idh); + System.out.println("Unsubscribe : added identifier header "+body.getID() +" - "+idh.toString()); + }catch(Exception e){ + e.printStackTrace(); + throw new java.rmi.RemoteException("set <wse:Identifier/>",e); + } + java.lang.Object _resp = _call.invoke(new java.lang.Object[] {body}); + + if (_resp instanceof java.rmi.RemoteException) { + throw (java.rmi.RemoteException)_resp; + } + extractAttachments(_call); + } + +} Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/undeploy.wsdd URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/undeploy.wsdd?view=auto&rev=149274 ============================================================================== --- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/undeploy.wsdd (added) +++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/undeploy.wsdd Mon Jan 31 09:47:06 2005 @@ -0,0 +1,18 @@ +<!-- Use this file to undeploy some handlers/chains and services --> +<!-- Two ways to do this: --> +<!-- java org.apache.axis.client.AdminClient undeploy.wsdd --> +<!-- after the axis server is running --> +<!-- or --> +<!-- java org.apache.axis.utils.Admin client|server undeploy.wsdd --> +<!-- from the same directory that the Axis engine runs --> + +<undeployment + xmlns="http://xml.apache.org/axis/wsdd/";> + + <!-- Services from EventingService WSDL service --> + + <service name="NotificationPort"/> + <service name="EventSourcePort"/> + <service name="SubscriptionManagerPort"/> + <service name="SubscriptionEndPort"/> +</undeployment> --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
