cgl.narada.wsinfra.messaging.interactions.wse
Class WSESubscriberWithPublisher

java.lang.Object
  cgl.narada.wsinfra.messaging.wse.WseFrameworkIndicator
      cgl.narada.wsinfra.messaging.interactions.wse.WSESubscriberInteraction
          cgl.narada.wsinfra.messaging.interactions.wse.WSESubscriberWithPublisher

All Implemented Interfaces:

FrameworkIndicator, SubscriberInteraction, SubscriberWithPublisher

public class WSESubscriberWithPublisher
extends WSESubscriberInteraction
implements SubscriberWithPublisher

Constructor Summary

WSESubscriberWithPublisher(WseSinkProcessor wseSinkProcessor)

Method Summary

EnvelopeDocument	createSubscribe(EndpointReferenceType sourceEPR, String filterConstraint, Calendar expiresAt) Create a subscribe request based on the specified parameters.
EnvelopeDocument	createSubscribe(EndpointReferenceType sourceEPR, String filterDialect, String filterConstraint, Calendar expiresAt) Create a subscribe request based on the specified parameters.
void	subscribe(EndpointReferenceType sourceEPR, String filterConstraint, Calendar expiresAt) Issue a subscribe request based on the specified arguments.
void	subscribe(EndpointReferenceType sourceEPR, String filterDialect, String filterConstraint, Calendar expiresAt) Issue a subscribe request based on the specified arguments.

Methods inherited from class cgl.narada.wsinfra.messaging.interactions.wse.WSESubscriberInteraction

issueExchange

Methods inherited from class cgl.narada.wsinfra.messaging.wse.WseFrameworkIndicator

getProvider, getSpecVersion, isEventing, isNotification

Methods inherited from class java.lang.Object

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

Methods inherited from interface cgl.narada.wsinfra.messaging.interactions.SubscriberInteraction

issueExchange

Methods inherited from interface cgl.narada.wsinfra.messaging.FrameworkIndicator

getProvider, getSpecVersion, isEventing, isNotification

Constructor Detail

WSESubscriberWithPublisher

public WSESubscriberWithPublisher(WseSinkProcessor wseSinkProcessor)

Method Detail

subscribe

public void subscribe(EndpointReferenceType sourceEPR,
                      String filterDialect,
                      String filterConstraint,
                      Calendar expiresAt)
               throws ProcessingException,
                      MessageFlowException

Description copied from interface: SubscriberWithPublisher

Issue a subscribe request based on the specified arguments.

Specified by:

subscribe in interface SubscriberWithPublisher

Parameters:

sourceEPR - The EPR of the publisher in question

filterDialect - The filter dialect associated with the subscription

filterConstraint - The filter constraint associated with the subscription

expiresAt - The time at which this subscription has been scheduled to expire.

Throws:

ProcessingException - This exception is thrown if there are problems with the arguments or in the creation of the subscription message.

MessageFlowException - this exception is thrown if there are problems in routing the message.

See Also:

SubscriberWithPublisher.subscribe(cgl.narada.wsinfra.schemas.addressing.EndpointReferenceType, java.lang.String, java.lang.String, java.util.Calendar)

subscribe

public void subscribe(EndpointReferenceType sourceEPR,
                      String filterConstraint,
                      Calendar expiresAt)
               throws ProcessingException,
                      MessageFlowException

Description copied from interface: SubscriberWithPublisher

Issue a subscribe request based on the specified arguments. The default filter dialect is associated with this subscription request.

Specified by:

subscribe in interface SubscriberWithPublisher

Parameters:

sourceEPR - The EPR of the publisher in question

filterConstraint - The filter constraint associated with the subscription

expiresAt - The time at which this subscription has been scheduled to expire.

Throws:

ProcessingException - This exception is thrown if there are problems with the arguments or in the creation of the subscription message.

MessageFlowException

See Also:

SubscriberWithPublisher.subscribe(cgl.narada.wsinfra.schemas.addressing.EndpointReferenceType, java.lang.String, java.util.Calendar)

createSubscribe

public EnvelopeDocument createSubscribe(EndpointReferenceType sourceEPR,
                                        String filterDialect,
                                        String filterConstraint,
                                        Calendar expiresAt)
                                 throws ProcessingException

Description copied from interface: SubscriberWithPublisher

Create a subscribe request based on the specified parameters.

Specified by:

createSubscribe in interface SubscriberWithPublisher

Parameters:

sourceEPR - The EPR of the publisher in question

filterDialect - The filter dialect associated with the subscription

filterConstraint - The filter constraint associated with the subscription

expiresAt - The time at which this subscription has been scheduled to expire.

Returns:

The EnvelopeDocument containing this subscription request

Throws:

ProcessingException - This exception is thrown if there are problems with the arguments or in the creation of the subscription message.

See Also:

SubscriberWithPublisher.createSubscribe(cgl.narada.wsinfra.schemas.addressing.EndpointReferenceType, java.lang.String, java.lang.String, java.util.Calendar)

createSubscribe

public EnvelopeDocument createSubscribe(EndpointReferenceType sourceEPR,
                                        String filterConstraint,
                                        Calendar expiresAt)
                                 throws ProcessingException

Description copied from interface: SubscriberWithPublisher

Create a subscribe request based on the specified parameters. The default filter dialect is associated with this subscription request.

Specified by:

createSubscribe in interface SubscriberWithPublisher

Parameters:

sourceEPR - The EPR of the publisher in question

filterConstraint - The filter constraint associated with the subscription

expiresAt - The time at which this subscription has been scheduled to expire.

Returns:

The EnvelopeDocument containing this subscription request

Throws:

ProcessingException - This exception is thrown if there are problems with the arguments or in the creation of the subscription message.

See Also:

SubscriberWithPublisher.createSubscribe(cgl.narada.wsinfra.schemas.addressing.EndpointReferenceType, java.lang.String, java.util.Calendar)