You are viewing a plain text version of this content. The canonical link for it is here.
Posted to pubscribe-dev@ws.apache.org by li...@apache.org on 2005/01/31 18:47:26 UTC
svn commit: r149274 [5/6] - in
incubator/hermes/trunk/src/java/org/apache/ws/eventing: ./ app/ base/
services/ services/broker/ services/publisher/ services/subscriber/
Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/deploy.wsdd
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/deploy.wsdd?view=auto&rev=149274
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/deploy.wsdd (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/deploy.wsdd Mon Jan 31 09:47:06 2005
@@ -0,0 +1,660 @@
+<!-- Use this file to deploy some handlers/chains and services -->
+<!-- Two ways to do this: -->
+<!-- java org.apache.axis.client.AdminClient deploy.wsdd -->
+<!-- after the axis server is running -->
+<!-- or -->
+<!-- java org.apache.axis.utils.Admin client|server deploy.wsdd -->
+<!-- from the same directory that the Axis engine runs -->
+
+<deployment
+ xmlns="http://xml.apache.org/axis/wsdd/"
+ xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">
+
+ <globalConfiguration>
+ <requestFlow>
+ <handler type="java:org.apache.axis.message.addressing.handler.AddressingHandler"/>
+ </requestFlow>
+
+ <responseFlow>
+ <handler type="java:org.apache.axis.message.addressing.handler.AddressingHandler"/>
+ </responseFlow>
+ </globalConfiguration>
+ <!-- Services from EventingService WSDL service -->
+
+ <service name="NotificationPort" style="message" use="literal">
+ <parameter name="wsdlTargetNamespace" value="http://schemas.xmlsoap.org/ws/2004/08/eventing/services"/>
+ <parameter name="wsdlServiceElement" value="NotificationService"/>
+ <parameter name="wsdlServicePort" value="NotificationPort"/>
+ <parameter name="className" value="org.apache.ws.eventing.services.subscriber.Notifier"/>
+ <parameter name="wsdlPortType" value="Notification"/>
+ <parameter name="allowedMethods" value="filter"/>
+</service>
+
+ <service name="EventSourcePort" provider="java:RPC" style="document" use="literal">
+ <parameter name="wsdlTargetNamespace" value="http://schemas.xmlsoap.org/ws/2004/08/eventing/services"/>
+ <parameter name="wsdlServiceElement" value="EventingService"/>
+ <parameter name="wsdlServicePort" value="EventSourcePort"/>
+ <parameter name="className" value="org.apache.ws.eventing.services.publisher.EventSourceBindingSkeleton"/>
+ <parameter name="wsdlPortType" value="EventSource"/>
+ <parameter name="allowedMethods" value="*"/>
+
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:AttributedQName"
+ type="java:org.apache.axis.message.addressing.AttributedQName"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ReferenceParametersType"
+ type="java:org.apache.axis.message.addressing.ReferenceParametersType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>SubscriptionEnd"
+ type="java:org.apache.ws.eventing.base.SubscriptionEnd"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:DeliveryType"
+ type="java:org.apache.ws.eventing.base.DeliveryType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ServiceNameType"
+ type="java:org.apache.axis.message.addressing.ServiceNameType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:AttributedURI"
+ type="java:org.apache.axis.message.addressing.AttributedURI"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ReplyAfterType"
+ type="java:org.apache.axis.message.addressing.ReplyAfterType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>Subscribe"
+ type="java:org.apache.ws.eventing.Subscription"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>Unsubscribe"
+ type="java:org.apache.ws.eventing.base.Unsubscribe"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:FilterType"
+ type="java:org.apache.ws.eventing.base.FilterType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:OpenSubscriptionEndCodeType"
+ type="java:org.apache.ws.eventing.base.OpenSubscriptionEndCodeType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>Renew"
+ type="java:org.apache.ws.eventing.base.Renew"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>GetStatusResponse"
+ type="java:org.apache.ws.eventing.base.GetStatusResponse"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:ExpirationType"
+ type="java:org.apache.ws.eventing.base.ExpirationType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>RenewResponse"
+ type="java:org.apache.ws.eventing.base.RenewResponse"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:SubscriptionEndCodeType"
+ type="java:org.apache.ws.eventing.base.SubscriptionEndCodeType"
+ serializer="org.apache.axis.encoding.ser.EnumSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.EnumDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:Relationship"
+ type="java:org.apache.axis.message.addressing.Relationship"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ReferencePropertiesType"
+ type="java:org.apache.axis.message.addressing.ReferencePropertiesType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:LanguageSpecificStringType"
+ type="java:org.apache.ws.eventing.base.LanguageSpecificStringType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:EndpointReferenceType"
+ type="java:org.apache.axis.message.addressing.EndpointReferenceType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:NonNegativeDurationType"
+ type="java:org.apache.axis.types.Duration"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>SubscribeResponse"
+ type="java:org.apache.ws.eventing.base.SubscribeResponse"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:FaultSubcodeValues"
+ type="java:org.apache.axis.message.addressing.FaultSubcodeValues"
+ serializer="org.apache.axis.encoding.ser.EnumSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.EnumDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>GetStatus"
+ type="java:org.apache.ws.eventing.base.GetStatus"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:RelationshipTypeValues"
+ type="java:org.apache.axis.message.addressing.RelationshipTypeValues"
+ serializer="org.apache.axis.encoding.ser.EnumSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.EnumDeserializerFactory"
+ encodingStyle=""
+ />
+ </service>
+ <service name="SubscriptionManagerPort" provider="java:RPC" style="document" use="literal">
+ <parameter name="wsdlTargetNamespace" value="http://schemas.xmlsoap.org/ws/2004/08/eventing/services"/>
+ <parameter name="wsdlServiceElement" value="EventingService"/>
+ <parameter name="wsdlServicePort" value="SubscriptionManagerPort"/>
+ <parameter name="className" value="org.apache.ws.eventing.services.publisher.SubscriptionManagerBindingSkeleton"/>
+ <parameter name="wsdlPortType" value="SubscriptionManager"/>
+ <parameter name="allowedMethods" value="*"/>
+
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:AttributedQName"
+ type="java:org.apache.axis.message.addressing.AttributedQName"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ReferenceParametersType"
+ type="java:org.apache.axis.message.addressing.ReferenceParametersType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>SubscriptionEnd"
+ type="java:org.apache.ws.eventing.base.SubscriptionEnd"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:DeliveryType"
+ type="java:org.apache.ws.eventing.base.DeliveryType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ServiceNameType"
+ type="java:org.apache.axis.message.addressing.ServiceNameType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:AttributedURI"
+ type="java:org.apache.axis.message.addressing.AttributedURI"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ReplyAfterType"
+ type="java:org.apache.axis.message.addressing.ReplyAfterType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>Subscribe"
+ type="java:org.apache.ws.eventing.Subscription"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>Unsubscribe"
+ type="java:org.apache.ws.eventing.base.Unsubscribe"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:FilterType"
+ type="java:org.apache.ws.eventing.base.FilterType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:OpenSubscriptionEndCodeType"
+ type="java:org.apache.ws.eventing.base.OpenSubscriptionEndCodeType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>Renew"
+ type="java:org.apache.ws.eventing.base.Renew"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>GetStatusResponse"
+ type="java:org.apache.ws.eventing.base.GetStatusResponse"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:ExpirationType"
+ type="java:org.apache.ws.eventing.base.ExpirationType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>RenewResponse"
+ type="java:org.apache.ws.eventing.base.RenewResponse"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:SubscriptionEndCodeType"
+ type="java:org.apache.ws.eventing.base.SubscriptionEndCodeType"
+ serializer="org.apache.axis.encoding.ser.EnumSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.EnumDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:Relationship"
+ type="java:org.apache.axis.message.addressing.Relationship"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ReferencePropertiesType"
+ type="java:org.apache.axis.message.addressing.ReferencePropertiesType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:LanguageSpecificStringType"
+ type="java:org.apache.ws.eventing.base.LanguageSpecificStringType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:EndpointReferenceType"
+ type="java:org.apache.axis.message.addressing.EndpointReferenceType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:NonNegativeDurationType"
+ type="java:org.apache.axis.types.Duration"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>SubscribeResponse"
+ type="java:org.apache.ws.eventing.base.SubscribeResponse"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:FaultSubcodeValues"
+ type="java:org.apache.axis.message.addressing.FaultSubcodeValues"
+ serializer="org.apache.axis.encoding.ser.EnumSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.EnumDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>GetStatus"
+ type="java:org.apache.ws.eventing.base.GetStatus"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:RelationshipTypeValues"
+ type="java:org.apache.axis.message.addressing.RelationshipTypeValues"
+ serializer="org.apache.axis.encoding.ser.EnumSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.EnumDeserializerFactory"
+ encodingStyle=""
+ />
+ </service>
+ <service name="SubscriptionEndPort" provider="java:RPC" style="document" use="literal">
+ <parameter name="wsdlTargetNamespace" value="http://schemas.xmlsoap.org/ws/2004/08/eventing/services"/>
+ <parameter name="wsdlServiceElement" value="EventingService"/>
+ <parameter name="wsdlServicePort" value="SubscriptionEndPort"/>
+ <parameter name="className" value="org.apache.ws.eventing.services.subscriber.SubscriptionEndBindingSkeleton"/>
+ <parameter name="wsdlPortType" value="SubscriptionEnd"/>
+ <parameter name="allowedMethods" value="*"/>
+
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:AttributedQName"
+ type="java:org.apache.axis.message.addressing.AttributedQName"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ReferenceParametersType"
+ type="java:org.apache.axis.message.addressing.ReferenceParametersType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>SubscriptionEnd"
+ type="java:org.apache.ws.eventing.base.SubscriptionEnd"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:DeliveryType"
+ type="java:org.apache.ws.eventing.base.DeliveryType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ServiceNameType"
+ type="java:org.apache.axis.message.addressing.ServiceNameType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:AttributedURI"
+ type="java:org.apache.axis.message.addressing.AttributedURI"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ReplyAfterType"
+ type="java:org.apache.axis.message.addressing.ReplyAfterType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>Subscribe"
+ type="java:org.apache.ws.eventing.Subscription"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>Unsubscribe"
+ type="java:org.apache.ws.eventing.base.Unsubscribe"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:FilterType"
+ type="java:org.apache.ws.eventing.base.FilterType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:OpenSubscriptionEndCodeType"
+ type="java:org.apache.ws.eventing.base.OpenSubscriptionEndCodeType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>Renew"
+ type="java:org.apache.ws.eventing.base.Renew"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>GetStatusResponse"
+ type="java:org.apache.ws.eventing.base.GetStatusResponse"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:ExpirationType"
+ type="java:org.apache.ws.eventing.base.ExpirationType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>RenewResponse"
+ type="java:org.apache.ws.eventing.base.RenewResponse"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:SubscriptionEndCodeType"
+ type="java:org.apache.ws.eventing.base.SubscriptionEndCodeType"
+ serializer="org.apache.axis.encoding.ser.EnumSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.EnumDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:Relationship"
+ type="java:org.apache.axis.message.addressing.Relationship"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:ReferencePropertiesType"
+ type="java:org.apache.axis.message.addressing.ReferencePropertiesType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:LanguageSpecificStringType"
+ type="java:org.apache.ws.eventing.base.LanguageSpecificStringType"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:EndpointReferenceType"
+ type="java:org.apache.axis.message.addressing.EndpointReferenceType"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:NonNegativeDurationType"
+ type="java:org.apache.axis.types.Duration"
+ serializer="org.apache.axis.encoding.ser.SimpleSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.SimpleDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>SubscribeResponse"
+ type="java:org.apache.ws.eventing.base.SubscribeResponse"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:FaultSubcodeValues"
+ type="java:org.apache.axis.message.addressing.FaultSubcodeValues"
+ serializer="org.apache.axis.encoding.ser.EnumSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.EnumDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/eventing"
+ qname="ns:>GetStatus"
+ type="java:org.apache.ws.eventing.base.GetStatus"
+ serializer="org.apache.axis.encoding.ser.BeanSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.BeanDeserializerFactory"
+ encodingStyle=""
+ />
+ <typeMapping
+ xmlns:ns="http://schemas.xmlsoap.org/ws/2004/08/addressing"
+ qname="ns:RelationshipTypeValues"
+ type="java:org.apache.axis.message.addressing.RelationshipTypeValues"
+ serializer="org.apache.axis.encoding.ser.EnumSerializerFactory"
+ deserializer="org.apache.axis.encoding.ser.EnumDeserializerFactory"
+ encodingStyle=""
+ />
+ </service>
+</deployment>
Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/EventSourceBindingImpl.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/EventSourceBindingImpl.java?view=auto&rev=149274
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/EventSourceBindingImpl.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/EventSourceBindingImpl.java Mon Jan 31 09:47:06 2005
@@ -0,0 +1,40 @@
+/**
+ * EventSourceBindingImpl.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.publisher;
+import org.apache.axis.message.addressing.*;
+import org.apache.ws.eventing.base.*;
+import org.apache.ws.eventing.YFilterStore;
+
+
+
+import org.apache.axis.utils.XMLUtils;
+import org.apache.axis.message.MessageElement;
+
+public class EventSourceBindingImpl implements org.apache.ws.eventing.services.EventSource{
+ public org.apache.ws.eventing.base.SubscribeResponse subscribeMsg(org.apache.ws.eventing.Subscription body) throws java.rmi.RemoteException {
+ try{
+ YFilterStore b = YFilterStore.instance();
+ String id = b.addSubscription(body);
+
+ EndpointReference ep = new EndpointReference("http://localhost:7070/axis/services/SubscriptionManagerPort");
+ ReferenceParametersType rp = new ReferenceParametersType();
+ MessageElement[] any = new MessageElement[1];
+ any[0]=new MessageElement(XMLUtils.StringToElement("http://schemas.xmlsoap.org/ws/2004/08/eventing", "Identifier", id));
+ rp.set_any(any);
+ ep.setParameters(rp);
+ ExpirationType et = new ExpirationType("now");
+ SubscribeResponse r = new SubscribeResponse(ep,et,null);
+
+ return r;
+ }catch(Exception e){
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/EventSourceBindingSkeleton.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/EventSourceBindingSkeleton.java?view=auto&rev=149274
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/EventSourceBindingSkeleton.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/EventSourceBindingSkeleton.java Mon Jan 31 09:47:06 2005
@@ -0,0 +1,60 @@
+/**
+ * EventSourceBindingSkeleton.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.publisher;
+
+public class EventSourceBindingSkeleton implements org.apache.ws.eventing.services.EventSource, org.apache.axis.wsdl.Skeleton {
+ private org.apache.ws.eventing.services.EventSource 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", "Subscribe"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", ">Subscribe"), org.apache.ws.eventing.Subscription.class, false, false),
+ };
+ _oper = new org.apache.axis.description.OperationDesc("subscribeMsg", _params, new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", "SubscribeResponse"));
+ _oper.setReturnType(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", ">SubscribeResponse"));
+ _oper.setElementQName(new javax.xml.namespace.QName("", "SubscribeMsg"));
+ _oper.setSoapAction("http://schemas.xmlsoap.org/ws/2004/08/eventing/SubscribeMsg");
+ _myOperationsList.add(_oper);
+ if (_myOperations.get("subscribeMsg") == null) {
+ _myOperations.put("subscribeMsg", new java.util.ArrayList());
+ }
+ ((java.util.List)_myOperations.get("subscribeMsg")).add(_oper);
+ }
+
+ public EventSourceBindingSkeleton() {
+ this.impl = new org.apache.ws.eventing.services.publisher.EventSourceBindingImpl();
+ }
+
+ public EventSourceBindingSkeleton(org.apache.ws.eventing.services.EventSource impl) {
+ this.impl = impl;
+ }
+ public org.apache.ws.eventing.base.SubscribeResponse subscribeMsg(org.apache.ws.eventing.Subscription body) throws java.rmi.RemoteException
+ {
+ org.apache.ws.eventing.base.SubscribeResponse ret = impl.subscribeMsg(body);
+ return ret;
+ }
+
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionEndBindingStub.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionEndBindingStub.java?view=auto&rev=149274
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionEndBindingStub.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionEndBindingStub.java Mon Jan 31 09:47:06 2005
@@ -0,0 +1,328 @@
+/**
+ * SubscriptionEndBindingStub.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.publisher;
+
+public class SubscriptionEndBindingStub extends org.apache.axis.client.Stub implements org.apache.ws.eventing.services.SubscriptionEnd {
+ 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[1];
+ _initOperationDesc1();
+ }
+
+ private static void _initOperationDesc1(){
+ org.apache.axis.description.OperationDesc oper;
+ oper = new org.apache.axis.description.OperationDesc();
+ oper.setName("SubscriptionEnd");
+ oper.addParameter(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", "SubscriptionEnd"), new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", ">SubscriptionEnd"), org.apache.ws.eventing.base.SubscriptionEnd.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[0] = oper;
+
+ }
+
+ public SubscriptionEndBindingStub() throws org.apache.axis.AxisFault {
+ this(null);
+ }
+
+ public SubscriptionEndBindingStub(java.net.URL endpointURL, javax.xml.rpc.Service service) throws org.apache.axis.AxisFault {
+ this(service);
+ super.cachedEndpoint = endpointURL;
+ }
+
+ public SubscriptionEndBindingStub(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/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", "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/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", "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/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/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 void subscriptionEnd(org.apache.ws.eventing.base.SubscriptionEnd 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/SubscriptionEnd");
+ _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("", "SubscriptionEnd"));
+
+ 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;
+ }
+ extractAttachments(_call);
+ }
+
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionManagerBindingImpl.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionManagerBindingImpl.java?view=auto&rev=149274
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionManagerBindingImpl.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionManagerBindingImpl.java Mon Jan 31 09:47:06 2005
@@ -0,0 +1,70 @@
+/**
+ * SubscriptionManagerBindingImpl.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.publisher;
+import org.apache.ws.eventing.base.*;
+import org.apache.axis.MessageContext;
+import org.apache.axis.message.MessageElement;
+
+import org.w3c.dom.Node;
+import org.w3c.dom.NodeList;
+import javax.xml.soap.SOAPHeader;
+
+import org.apache.ws.eventing.Subscription;
+import org.apache.ws.eventing.YFilterStore;
+
+public class SubscriptionManagerBindingImpl implements org.apache.ws.eventing.services.SubscriptionManager{
+
+ public static String extractIdentifier() throws javax.xml.soap.SOAPException{
+ //first try to become wse:Identifier
+ MessageContext mC = MessageContext.getCurrentContext();
+ SOAPHeader h =mC.getMessage().getSOAPHeader();
+ NodeList it = h.getElementsByTagNameNS("http://schemas.xmlsoap.org/ws/2004/08/eventing", "Identifier");
+ if(it.getLength()==0)
+ throw new javax.xml.soap.SOAPException("<wse:Identifier> Tag is missing in the Header.... i dunno which Subscription you mean");
+ Node idnode = it.item(0);
+ if((idnode.getFirstChild()!=null)&&(idnode.getFirstChild().getNodeType()==Node.TEXT_NODE))
+ return(idnode.getFirstChild().getNodeValue());
+ else
+ throw new javax.xml.soap.SOAPException("<wse:Identifier> Tag is empty in the Header.... i dunno which Subscription you mean");
+ }
+ public org.apache.ws.eventing.base.RenewResponse renewMsg(org.apache.ws.eventing.base.Renew body) throws java.rmi.RemoteException {
+ return null;
+ }
+
+ public org.apache.ws.eventing.base.GetStatusResponse getStatusMsg(org.apache.ws.eventing.base.GetStatus body) throws java.rmi.RemoteException {
+ try{
+ String id = extractIdentifier();
+
+ //ask the Broker about the Status
+
+
+ YFilterStore b = YFilterStore.instance();
+ Subscription s = (org.apache.ws.eventing.Subscription)b.getSubscription(id);
+ ExpirationType exp = s.getExpires();
+ GetStatusResponse resp = new GetStatusResponse(exp,new MessageElement[0]);
+ return(resp);
+ }catch(Exception e){
+ e.printStackTrace();
+ throw new java.rmi.RemoteException("getStatusMsg",e);
+ }
+ }
+
+ public void unsubscribeMsg(org.apache.ws.eventing.base.Unsubscribe body) throws java.rmi.RemoteException {
+ try{
+ String id = extractIdentifier();
+ System.out.println("unsubscribe Subscription: "+id);
+ YFilterStore b = YFilterStore.instance();
+ b.removeSubscription(id);
+
+ }catch(Exception e){
+ e.printStackTrace();
+ throw new java.rmi.RemoteException("unsubscribeMsg",e);
+ }
+ }
+
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionManagerBindingSkeleton.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionManagerBindingSkeleton.java?view=auto&rev=149274
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionManagerBindingSkeleton.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/publisher/SubscriptionManagerBindingSkeleton.java Mon Jan 31 09:47:06 2005
@@ -0,0 +1,94 @@
+/**
+ * SubscriptionManagerBindingSkeleton.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.publisher;
+
+public class SubscriptionManagerBindingSkeleton implements org.apache.ws.eventing.services.SubscriptionManager, org.apache.axis.wsdl.Skeleton {
+ private org.apache.ws.eventing.services.SubscriptionManager 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", "Renew"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", ">Renew"), org.apache.ws.eventing.base.Renew.class, false, false),
+ };
+ _oper = new org.apache.axis.description.OperationDesc("renewMsg", _params, new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", "RenewResponse"));
+ _oper.setReturnType(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", ">RenewResponse"));
+ _oper.setElementQName(new javax.xml.namespace.QName("", "RenewMsg"));
+ _oper.setSoapAction("http://schemas.xmlsoap.org/ws/2004/08/eventing/RenewMsg");
+ _myOperationsList.add(_oper);
+ if (_myOperations.get("renewMsg") == null) {
+ _myOperations.put("renewMsg", new java.util.ArrayList());
+ }
+ ((java.util.List)_myOperations.get("renewMsg")).add(_oper);
+ _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", "GetStatus"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", ">GetStatus"), org.apache.ws.eventing.base.GetStatus.class, false, false),
+ };
+ _oper = new org.apache.axis.description.OperationDesc("getStatusMsg", _params, new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", "GetStatusResponse"));
+ _oper.setReturnType(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", ">GetStatusResponse"));
+ _oper.setElementQName(new javax.xml.namespace.QName("", "GetStatusMsg"));
+ _oper.setSoapAction("http://schemas.xmlsoap.org/ws/2004/08/eventing/GetStatusMsg");
+ _myOperationsList.add(_oper);
+ if (_myOperations.get("getStatusMsg") == null) {
+ _myOperations.put("getStatusMsg", new java.util.ArrayList());
+ }
+ ((java.util.List)_myOperations.get("getStatusMsg")).add(_oper);
+ _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", "Unsubscribe"), org.apache.axis.description.ParameterDesc.IN, new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", ">Unsubscribe"), org.apache.ws.eventing.base.Unsubscribe.class, false, false),
+ };
+ _oper = new org.apache.axis.description.OperationDesc("unsubscribeMsg", _params, null);
+ _oper.setElementQName(new javax.xml.namespace.QName("", "UnsubscribeMsg"));
+ _oper.setSoapAction("http://schemas.xmlsoap.org/ws/2004/08/eventing/UnsubscribeMsg");
+ _myOperationsList.add(_oper);
+ if (_myOperations.get("unsubscribeMsg") == null) {
+ _myOperations.put("unsubscribeMsg", new java.util.ArrayList());
+ }
+ ((java.util.List)_myOperations.get("unsubscribeMsg")).add(_oper);
+ }
+
+ public SubscriptionManagerBindingSkeleton() {
+ this.impl = new org.apache.ws.eventing.services.publisher.SubscriptionManagerBindingImpl();
+ }
+
+ public SubscriptionManagerBindingSkeleton(org.apache.ws.eventing.services.SubscriptionManager impl) {
+ this.impl = impl;
+ }
+ public org.apache.ws.eventing.base.RenewResponse renewMsg(org.apache.ws.eventing.base.Renew body) throws java.rmi.RemoteException
+ {
+ org.apache.ws.eventing.base.RenewResponse ret = impl.renewMsg(body);
+ return ret;
+ }
+
+ public org.apache.ws.eventing.base.GetStatusResponse getStatusMsg(org.apache.ws.eventing.base.GetStatus body) throws java.rmi.RemoteException
+ {
+ org.apache.ws.eventing.base.GetStatusResponse ret = impl.getStatusMsg(body);
+ return ret;
+ }
+
+ public void unsubscribeMsg(org.apache.ws.eventing.base.Unsubscribe body) throws java.rmi.RemoteException
+ {
+ impl.unsubscribeMsg(body);
+ }
+
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/EventSourceBindingStub.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/EventSourceBindingStub.java?view=auto&rev=149274
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/EventSourceBindingStub.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/EventSourceBindingStub.java Mon Jan 31 09:47:06 2005
@@ -0,0 +1,340 @@
+/**
+ * EventSourceBindingStub.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 EventSourceBindingStub extends org.apache.axis.client.Stub implements org.apache.ws.eventing.services.EventSource {
+ 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[1];
+ _initOperationDesc1();
+ }
+
+ private static void _initOperationDesc1(){
+ org.apache.axis.description.OperationDesc oper;
+ oper = new org.apache.axis.description.OperationDesc();
+ oper.setName("SubscribeMsg");
+ oper.addParameter(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", "Subscribe"), new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", ">Subscribe"), org.apache.ws.eventing.Subscription.class, org.apache.axis.description.ParameterDesc.IN, false, false);
+ oper.setReturnType(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", ">SubscribeResponse"));
+ oper.setReturnClass(org.apache.ws.eventing.base.SubscribeResponse.class);
+ oper.setReturnQName(new javax.xml.namespace.QName("http://schemas.xmlsoap.org/ws/2004/08/eventing", "SubscribeResponse"));
+ oper.setStyle(org.apache.axis.constants.Style.DOCUMENT);
+ oper.setUse(org.apache.axis.constants.Use.LITERAL);
+ _operations[0] = oper;
+
+ }
+
+ public EventSourceBindingStub() throws org.apache.axis.AxisFault {
+ this(null);
+ }
+
+ public EventSourceBindingStub(java.net.URL endpointURL, javax.xml.rpc.Service service) throws org.apache.axis.AxisFault {
+ this(service);
+ super.cachedEndpoint = endpointURL;
+ }
+
+ public EventSourceBindingStub(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/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", "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/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", "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/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/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.Subscription.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.SubscribeResponse subscribeMsg(org.apache.ws.eventing.Subscription 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/SubscribeMsg");
+ _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("", "SubscribeMsg"));
+
+ 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 {
+ org.apache.ws.eventing.base.SubscribeResponse resp = (org.apache.ws.eventing.base.SubscribeResponse) _resp;
+ body.setSubscriptionManager(resp.getSubscriptionManager());
+
+ return resp;
+ } catch (java.lang.Exception _exception) {
+ return (org.apache.ws.eventing.base.SubscribeResponse) org.apache.axis.utils.JavaUtils.convert(_resp, org.apache.ws.eventing.base.SubscribeResponse.class);
+ }
+ }
+ }
+
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/Notifier.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/Notifier.java?view=auto&rev=149274
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/Notifier.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/Notifier.java Mon Jan 31 09:47:06 2005
@@ -0,0 +1,17 @@
+package org.apache.ws.eventing.services.subscriber;
+
+import org.apache.axis.message.*;
+
+import org.apache.ws.eventing.SubscriberStore;
+
+
+public class Notifier{
+
+ public void filter(SOAPEnvelope req, SOAPEnvelope resp){
+ SubscriberStore b = SubscriberStore.instance();
+ System.out.println("Notifier.filter()");
+ b.notify(req);
+ }
+}
+
+
Added: incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriberService.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriberService.java?view=auto&rev=149274
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriberService.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/eventing/services/subscriber/SubscriberService.java Mon Jan 31 09:47:06 2005
@@ -0,0 +1,31 @@
+/**
+ * EventingService.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 interface SubscriberService extends javax.xml.rpc.Service {
+
+/**
+ * A publish subscribe system based on web services
+ */
+ public java.lang.String getEventSourcePortAddress();
+
+ public org.apache.ws.eventing.services.EventSource getEventSourcePort() throws javax.xml.rpc.ServiceException;
+
+ public org.apache.ws.eventing.services.EventSource getEventSourcePort(java.net.URL portAddress) throws javax.xml.rpc.ServiceException;
+ public java.lang.String getSubscriptionManagerPortAddress();
+
+ public org.apache.ws.eventing.services.SubscriptionManager getSubscriptionManagerPort() throws javax.xml.rpc.ServiceException;
+
+ public org.apache.ws.eventing.services.SubscriptionManager getSubscriptionManagerPort(java.net.URL portAddress) throws javax.xml.rpc.ServiceException;
+ public java.lang.String getSubscriptionEndPortAddress();
+/*
+ public org.apache.ws.eventing.services.SubscriptionEnd getSubscriptionEndPort() throws javax.xml.rpc.ServiceException;
+
+ public org.apache.ws.eventing.services.SubscriptionEnd getSubscriptionEndPort(java.net.URL portAddress) throws javax.xml.rpc.ServiceException;
+*/
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: hermes-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: hermes-dev-help@ws.apache.org