cgl.narada.wsinfra.wsrm.impl
Class WsrmSinkNode

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

All Implemented Interfaces:

WsrmSink

public class WsrmSinkNode

extends WsProcessor

implements WsrmSink

This interfaces outlines the functionality of a WSRM sink.

Constructor Summary

WsrmSinkNode(String configInfo)

Method Summary

cgl.narada.wsinfra.schemas.addressing.EndpointReferenceType	getEndpointReference()
WsMessageFlow	getMessageFlow() Gets the message flow which the processor should use.
void	processAckRequested(cgl.narada.wsinfra.schemas.soap.EnvelopeDocument envelopeDocument, cgl.narada.wsinfra.wsa.AddressingHeaders addressingHeaders) Process AckRequested received over the network, from the source
cgl.narada.wsinfra.schemas.wsrm.CreateSequenceResponseDocument	processCreateSequence(cgl.narada.wsinfra.schemas.wsrm.CreateSequenceDocument createSequenceDocument) Process a CreateSequence request received from the source
void	processCreateSequence(cgl.narada.wsinfra.schemas.soap.EnvelopeDocument envelopeDocument, cgl.narada.wsinfra.wsa.AddressingHeaders addressingHeaders) Process CreateSequence received over the network, from the source
boolean	processExchange(cgl.narada.wsinfra.schemas.soap.EnvelopeDocument envelopeDocument, int direction) Process the exchange.
void	processTerminateSequence(cgl.narada.wsinfra.schemas.soap.EnvelopeDocument envelopeDocument, cgl.narada.wsinfra.wsa.AddressingHeaders addressingHeaders) Process TerminateSequence received over the network, from the source
void	processTerminateSequence(cgl.narada.wsinfra.schemas.wsrm.TerminateSequenceDocument terminateSequenceDocument) Process the TerminateSequence message received from the source (over the network)
void	processWsrmMessageFromSource(cgl.narada.wsinfra.schemas.soap.EnvelopeDocument envelopeDocument, cgl.narada.wsinfra.wsa.AddressingHeaders addressingHeaders) Process wsrm message received over the network, from the source
void	setEndpointReference(cgl.narada.wsinfra.schemas.addressing.EndpointReferenceType endpointReference) Retrieves 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, isFault, manageFaultException, processExchange, processExchange

Methods inherited from class java.lang.Object

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

Constructor Detail

WsrmSinkNode

public WsrmSinkNode(String configInfo)
             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(cgl.narada.wsinfra.schemas.soap.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

processCreateSequence

public void processCreateSequence(cgl.narada.wsinfra.schemas.soap.EnvelopeDocument envelopeDocument,
                                  cgl.narada.wsinfra.wsa.AddressingHeaders addressingHeaders)
                           throws WsFaultException,
                                  MessageFlowException,
                                  WsrmStorageException,
                                  ProcessingException

Process CreateSequence received over the network, from the source

Throws:

WsFaultException

MessageFlowException

WsrmStorageException

ProcessingException

processCreateSequence

public cgl.narada.wsinfra.schemas.wsrm.CreateSequenceResponseDocument processCreateSequence(cgl.narada.wsinfra.schemas.wsrm.CreateSequenceDocument createSequenceDocument)
                                                                                     throws WsFaultException,
                                                                                            MessageFlowException

Process a CreateSequence request received from the source

Specified by:

processCreateSequence in interface WsrmSink

Throws:

WsFaultException

MessageFlowException

processWsrmMessageFromSource

public void processWsrmMessageFromSource(cgl.narada.wsinfra.schemas.soap.EnvelopeDocument envelopeDocument,
                                         cgl.narada.wsinfra.wsa.AddressingHeaders addressingHeaders)
                                  throws WsFaultException,
                                         MessageFlowException,
                                         WsrmStorageException

Process wsrm message received over the network, from the source

Specified by:

processWsrmMessageFromSource in interface WsrmSink

Throws:

WsFaultException

MessageFlowException

WsrmStorageException

processAckRequested

public void processAckRequested(cgl.narada.wsinfra.schemas.soap.EnvelopeDocument envelopeDocument,
                                cgl.narada.wsinfra.wsa.AddressingHeaders addressingHeaders)
                         throws WsFaultException,
                                MessageFlowException,
                                WsrmStorageException,
                                ProcessingException

Process AckRequested received over the network, from the source

Throws:

WsFaultException

MessageFlowException

WsrmStorageException

ProcessingException

processTerminateSequence

public void processTerminateSequence(cgl.narada.wsinfra.schemas.soap.EnvelopeDocument envelopeDocument,
                                     cgl.narada.wsinfra.wsa.AddressingHeaders addressingHeaders)
                              throws WsFaultException,
                                     MessageFlowException,
                                     WsrmStorageException

Process TerminateSequence received over the network, from the source

Throws:

WsFaultException

MessageFlowException

WsrmStorageException

processTerminateSequence

public void processTerminateSequence(cgl.narada.wsinfra.schemas.wsrm.TerminateSequenceDocument terminateSequenceDocument)
                              throws WsFaultException,
                                     MessageFlowException

Process the TerminateSequence message received from the source (over the network)

Specified by:

processTerminateSequence in interface WsrmSink

Throws:

WsFaultException

MessageFlowException

getEndpointReference

public cgl.narada.wsinfra.schemas.addressing.EndpointReferenceType getEndpointReference()

Specified by:

getEndpointReference in interface WsrmSink

setEndpointReference

public void setEndpointReference(cgl.narada.wsinfra.schemas.addressing.EndpointReferenceType endpointReference)

Retrieves the endpoint reference associated with this node

Specified by:

setEndpointReference in interface WsrmSink