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

java.lang.Object
  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

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