cgl.narada.wsinfra.wsrm.impl
Class WsrmSourceNode

java.lang.Object
  extended by cgl.narada.wsinfra.WsProcessor
      extended by 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


For comments and suggestions please send e-mail to The NaradaBrokering Project