cgl.narada.wsinfra.wsr
Interface WsrSource

All Known Implementing Classes:

WsrSourceNode

public interface WsrSource

This interfaces outlines the functionality of a WSR Source

Method Summary

EndpointReferenceType	getEndpointReference() Retrieves the endpoint reference associated with this node
boolean	processExchange(EnvelopeDocument envelopeDocument, int direction) Process the exchange.
void	processMessageFromApplication(EnvelopeDocument envelopeDocument, AddressingHeaders addressingHeaders) Process exchange received from application, and send it across reliability
void	processResponse(EnvelopeDocument envelopeDocument, AddressingHeaders addressingHeaders) Process group acknowledgements received over the wire from the sink
void	setEndpointReference(EndpointReferenceType endpointReference) Retrieves the endpoint reference associated with this node

Method Detail

processExchange

public boolean processExchange(EnvelopeDocument envelopeDocument,
                               int direction)
                        throws UnknownExchangeException,
                               IncorrectExchangeException,
                               ProcessingException,
                               MessageFlowException

Process the exchange. The argument also indicates the direction in which the exchange has actually traversed.

Throws:

UnknownExchangeException

IncorrectExchangeException

ProcessingException

MessageFlowException

processResponse

public void processResponse(EnvelopeDocument envelopeDocument,
                            AddressingHeaders addressingHeaders)
                     throws WsFaultException,
                            MessageFlowException,
                            WsrStorageException

Process group acknowledgements received over the wire from the sink

Throws:

WsFaultException

MessageFlowException

WsrStorageException

processMessageFromApplication

public void processMessageFromApplication(EnvelopeDocument envelopeDocument,
                                          AddressingHeaders addressingHeaders)
                                   throws WsFaultException,
                                          MessageFlowException,
                                          WsrStorageException

Process exchange received from application, and send it across reliability

Throws:

WsFaultException

MessageFlowException

WsrStorageException

getEndpointReference

public EndpointReferenceType getEndpointReference()

Retrieves the endpoint reference associated with this node

setEndpointReference

public void setEndpointReference(EndpointReferenceType endpointReference)

Retrieves the endpoint reference associated with this node