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

java.lang.Object
  extended by 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)
          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)
          This method will make service call to Sink Web services 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)
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
This method will make service call to Sink Web services instead of Source.

Specified by:
enrouteToNetwork in interface WsMessageFlow
Parameters:
SOAPMessage -
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


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