cgl.narada.wsinfra.deployment.axis.wse
Class WseSourceClientService

java.lang.Object
  extended by cgl.narada.wsinfra.deployment.axis.wse.WseSourceClientService
All Implemented Interfaces:
WsMessageFlow

public class WseSourceClientService
extends Object
implements WsMessageFlow


Field Summary
 
Fields inherited from interface cgl.narada.wsinfra.WsMessageFlow
FROM_APPLICATION, FROM_NETWORK
 
Constructor Summary
WseSourceClientService(String sourceAddressParam, String subManagerAddressParam)
           
 
Method Summary
 void addTopicInfo(EnvelopeDocument envelopeDocument)
           
 SOAPMessage createSOAPMessage()
           
 void enrouteToApplication(SOAPMessage soapMessage)
          Routes a message enroute to the application.
 void enrouteToNetwork(SOAPMessage soapMessage)
          I over wrote this method because I have to make call to Sink instead of Source.
 void injectMessageTowardsApplication(SOAPMessage soapMessage, Filter filter)
          Injects a message based on the filter's position within the filter pipeline towards the application.
 void injectMessageTowardsApplication(SOAPMessage soapMessage, int position)
          Injects a message at a specific location within the filter pipeline towards the application.
 void injectMessageTowardsNetwork(SOAPMessage soapMessage, Filter filter)
          Injects a message at the filter immediately following this filter in the path TOWARDS the NETWORK.
 void injectMessageTowardsNetwork(SOAPMessage soapMessage, int position)
          Injects a message at a specific location within the filter pipeline.
 void onException(Exception exception)
           
 void onMessage(SOAPMessage soapMessage)
           
 void printSoapMessage(SOAPMessage soapMessage)
           
 void processMessageFromApplication(SOAPMessage soapMessage)
          Process a message received from the application.
 void processMessageFromNetwork(SOAPMessage soapMessage)
          Process a message received over the network.
 void sendSOAPMessage(SOAPMessage soapMessage)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

WseSourceClientService

public WseSourceClientService(String sourceAddressParam,
                              String subManagerAddressParam)
Method Detail

enrouteToApplication

public final void enrouteToApplication(SOAPMessage soapMessage)
                                throws MessageFlowException
Routes a message enroute to the application. The message is basically routed to a neighboring filter which is nearer to the application.

Specified by:
enrouteToApplication in interface WsMessageFlow
Throws:
MessageFlowException

enrouteToNetwork

public final void enrouteToNetwork(SOAPMessage soapMessage)
                            throws MessageFlowException
I over wrote this method because I have to make call to Sink instead of Source. Sink will store request & response

Specified by:
enrouteToNetwork in interface WsMessageFlow
Parameters:
SOAPMessage -
Throws:
MessageFlowException

createSOAPMessage

public SOAPMessage createSOAPMessage()

addTopicInfo

public void addTopicInfo(EnvelopeDocument envelopeDocument)

onMessage

public void onMessage(SOAPMessage soapMessage)

onException

public void onException(Exception exception)

printSoapMessage

public void printSoapMessage(SOAPMessage soapMessage)

sendSOAPMessage

public void sendSOAPMessage(SOAPMessage soapMessage)
                     throws DeploymentException,
                            MessageFlowException,
                            ProcessingException
Throws:
DeploymentException
MessageFlowException
ProcessingException

processMessageFromNetwork

public void processMessageFromNetwork(SOAPMessage soapMessage)
Process a message received over the network.


injectMessageTowardsApplication

public void injectMessageTowardsApplication(SOAPMessage soapMessage,
                                            Filter filter)
                                     throws DeploymentException
Injects a message based on the filter's position within the filter pipeline towards the application.

Throws:
DeploymentException

injectMessageTowardsApplication

public void injectMessageTowardsApplication(SOAPMessage soapMessage,
                                            int position)
                                     throws DeploymentException
Injects a message at a specific location within the filter pipeline towards the application.

Throws:
DeploymentException

processMessageFromApplication

public void processMessageFromApplication(SOAPMessage soapMessage)
                                   throws DeploymentException,
                                          MessageFlowException,
                                          ProcessingException
Process a message received from the application.

Throws:
DeploymentException
MessageFlowException
ProcessingException

injectMessageTowardsNetwork

public void injectMessageTowardsNetwork(SOAPMessage soapMessage,
                                        Filter filter)
                                 throws DeploymentException,
                                        MessageFlowException,
                                        ProcessingException
Injects a message at the filter immediately following this filter in the path TOWARDS the NETWORK.

Throws:
DeploymentException
MessageFlowException
ProcessingException

injectMessageTowardsNetwork

public void injectMessageTowardsNetwork(SOAPMessage soapMessage,
                                        int position)
                                 throws DeploymentException,
                                        MessageFlowException,
                                        ProcessingException
Injects a message at a specific location within the filter pipeline.

Throws:
DeploymentException
MessageFlowException
ProcessingException


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