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

java.lang.Object
  cgl.narada.wsinfra.deployment.axis.wse.WseSinkClientService

All Implemented Interfaces:

WsMessageFlow

public class WseSinkClientService

extends Object

implements WsMessageFlow

Field Summary

Fields inherited from interface cgl.narada.wsinfra.WsMessageFlow

FROM_APPLICATION, FROM_NETWORK

Constructor Summary

WseSinkClientService(String sinkAddressParam, String smAddressParam)
Default Constructor for WseSinkClientHandler

Method Summary

SOAPMessage	createSOAPMessage(String source) This method will create simple SOAPEnvelope for given Source Address..
void	createSubRequest(String sourceAdd, String topic) This method will generate Subscription Request based on Source Address and Topic of subscription.
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.
WseSinkProcessor	getProcessor() This method will return instance of Sink Processor
void	issueGetStatusRequest(String subscriptionIdentifier) This method will generate Status Request for subscription based on Identifier
void	issueRenewRequest(String subscriptionIdentifier, Calendar expiresAt) This method will generate Renew Request for subscription based on Identifier.
void	issueUnsubscribeRequest(String subscriptionIdentifier) This method will generate Unsubscribe request for Subscription based on Identifier

Methods inherited from class java.lang.Object

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

Constructor Detail

WseSinkClientService

public WseSinkClientService(String sinkAddressParam,
                            String smAddressParam)

Default Constructor for WseSinkClientHandler

Method Detail

getProcessor

public WseSinkProcessor getProcessor()

This method will return instance of Sink Processor

Returns:

WseSinkProcessor

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

issueGetStatusRequest

public void issueGetStatusRequest(String subscriptionIdentifier)
                           throws ProcessingException,
                                  DeploymentException,
                                  SOAPException,
                                  MessageFlowException

This method will generate Status Request for subscription based on Identifier

Parameters:

subscriptionIdentifier -

Throws:

ProcessingException

DeploymentException

SOAPException

MessageFlowException

issueRenewRequest

public void issueRenewRequest(String subscriptionIdentifier,
                              Calendar expiresAt)
                       throws ProcessingException,
                              MessageFlowException

This method will generate Renew Request for subscription based on Identifier.

Parameters:

subscriptionIdentifier -

expiresAt -

Throws:

ProcessingException

MessageFlowException

issueUnsubscribeRequest

public void issueUnsubscribeRequest(String subscriptionIdentifier)
                             throws ProcessingException,
                                    MessageFlowException

This method will generate Unsubscribe request for Subscription based on Identifier

Parameters:

subscriptionIdentifier -

Throws:

ProcessingException

MessageFlowException

createSubRequest

public void createSubRequest(String sourceAdd,
                             String topic)
                      throws DeploymentException,
                             ProcessingException,
                             MessageFlowException,
                             SOAPException

This method will generate Subscription Request based on Source Address and Topic of subscription.

Parameters:

sourceAdd -

topic -

Throws:

DeploymentException

ProcessingException

MessageFlowException

SOAPException

createSOAPMessage

public SOAPMessage createSOAPMessage(String source)

This method will create simple SOAPEnvelope for given Source Address..

Parameters:

source -

Returns:

SOAPMessage