cgl.narada.wsinfra.wse
Interface WseSource

All Known Implementing Classes:

WseSourceProcessor

public interface WseSource

This interface encapsulates the behavior of a WS-Eventing source node.

Method Summary

void	processNotification(EnvelopeDocument envelopeDocument, AddressingHeaders addressingHeaders) This method is used to ensure the dissemination of a notification to registered subscriptions.
SubscribeResponseDocument	processSubscribeRequest(SubscribeDocument subscribeDocument) The method to process a SubscriptionRequest issued by a Sink.
void	processSubscriptionRenewal(EnvelopeDocument envelopeDocument, AddressingHeaders addressingHeaders) This method is used to update the subscription tables maintained at the source.
void	processUnsubscribe(EnvelopeDocument envelopeDocument, AddressingHeaders addressingHeaders) This method is used to update the subscription tables maintained at the source.

Method Detail

processSubscribeRequest

SubscribeResponseDocument processSubscribeRequest(SubscribeDocument subscribeDocument)
                                                  throws WsFaultException,
                                                         ProcessingException

The method to process a SubscriptionRequest issued by a Sink. If this request is successfully processed a SubscribeResponseDocument is issued. If the request is NOT successful a WsFaultException is thrown.

Throws:

WsFaultException

ProcessingException

processSubscriptionRenewal

void processSubscriptionRenewal(EnvelopeDocument envelopeDocument,
                                AddressingHeaders addressingHeaders)
                                throws WsFaultException

This method is used to update the subscription tables maintained at the source. ONLY requests successfully renewed by the SubscriptionManager are forwarded onto the source for updates at the source. This method will throw an error if the request was issued by anyone BUT the registered SubscriptionManager. wse:Identifier of the subscription. wse:From should match Subscription Manager for the subscription. wse:RenewResponse which would indicate the new expiry time for the subscription.

Throws:

WsFaultException

processUnsubscribe

void processUnsubscribe(EnvelopeDocument envelopeDocument,
                        AddressingHeaders addressingHeaders)
                        throws WsFaultException

This method is used to update the subscription tables maintained at the source. Unsubscribe requests processed by the SubscriptionManager are forwarded onto the source for updates at the source. This method will throw an error if the request was issued by anyone BUT the registered SubscriptionManager for the subscription in question. wse:Identifier of the subscription wse:From shoould match SubscriptionManager for the subscription.

Throws:

WsFaultException

processNotification

void processNotification(EnvelopeDocument envelopeDocument,
                         AddressingHeaders addressingHeaders)
                         throws ProcessingException,
                                MessageFlowException

This method is used to ensure the dissemination of a notification to registered subscriptions.

Throws:

ProcessingException

MessageFlowException