cgl.narada.wsinfra.wsrm.impl
Class WsrmSourceNode

java.lang.Object
  cgl.narada.wsinfra.WsProcessor
      cgl.narada.wsinfra.wsrm.impl.WsrmSourceNode

All Implemented Interfaces:

WsrmSource

public class WsrmSourceNode
extends WsProcessor
implements WsrmSource

This interfaces outlines the functionality of a WSRM sink.

Constructor Summary

WsrmSourceNode(String configInfo)

Method Summary

EndpointReferenceType	getEndpointReference()
WsMessageFlow	getMessageFlow() Gets the message flow which the processor should use.
void	processCreateSequenceResponse(EnvelopeDocument envelopeDocument, AddressingHeaders addressingHeaders) Process a create sequence response received from the sink
boolean	processExchange(EnvelopeDocument envelopeDocument, int direction) Process the exchange.
void	processMessageFromApplication(EnvelopeDocument envelopeDocument, AddressingHeaders addressingHeaders) Process exchange received from application, and send it across reliably
void	processSequenceAcknowledgement(EnvelopeDocument envelopeDocument, AddressingHeaders addressingHeaders) Process sequence acknowledgements received over the wire from the sink
void	setEndpointReference(EndpointReferenceType endpointReference) Set the endpoint reference associated with this node
void	setMessageFlow(WsMessageFlow wsMessageFlow) Sets the message flow which the processor should use

Methods inherited from class cgl.narada.wsinfra.WsProcessor

enrouteToApplication, enrouteToNetwork, enrouteToNetwork, isFault, manageFaultException, processExchange, processExchange

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WsrmSourceNode

public WsrmSourceNode(String configInfo)
               throws DeploymentException

Throws:

DeploymentException

Method Detail

setMessageFlow

public void setMessageFlow(WsMessageFlow wsMessageFlow)
                    throws DeploymentException

Sets the message flow which the processor should use

Specified by:

setMessageFlow in class WsProcessor

Throws:

DeploymentException

getMessageFlow

public WsMessageFlow getMessageFlow()

Gets the message flow which the processor should use.

Specified by:

getMessageFlow in class WsProcessor

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.

Specified by:

processExchange in class WsProcessor

Throws:

UnknownExchangeException

IncorrectExchangeException

ProcessingException

MessageFlowException

processCreateSequenceResponse

public void processCreateSequenceResponse(EnvelopeDocument envelopeDocument,
                                          AddressingHeaders addressingHeaders)
                                   throws WsFaultException,
                                          WsrmStorageException

Process a create sequence response received from the sink

Specified by:

processCreateSequenceResponse in interface WsrmSource

Throws:

WsFaultException

WsrmStorageException

processSequenceAcknowledgement

public void processSequenceAcknowledgement(EnvelopeDocument envelopeDocument,
                                           AddressingHeaders addressingHeaders)
                                    throws WsFaultException,
                                           WsrmStorageException,
                                           MessageFlowException

Process sequence acknowledgements received over the wire from the sink

Specified by:

processSequenceAcknowledgement in interface WsrmSource

Throws:

WsFaultException

WsrmStorageException

MessageFlowException

processMessageFromApplication

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

Process exchange received from application, and send it across reliably

Specified by:

processMessageFromApplication in interface WsrmSource

Throws:

WsFaultException

MessageFlowException

WsrmStorageException

getEndpointReference

public EndpointReferenceType getEndpointReference()

Specified by:

getEndpointReference in interface WsrmSource

setEndpointReference

public void setEndpointReference(EndpointReferenceType endpointReference)

Set the endpoint reference associated with this node

Specified by:

setEndpointReference in interface WsrmSource