org.apache.synapse.eventing
Class SynapseEventSource

java.lang.Object
  org.apache.synapse.core.axis2.SynapseMessageReceiver
      org.apache.synapse.eventing.SynapseEventSource

All Implemented Interfaces:

MessageReceiver

public class SynapseEventSource
extends SynapseMessageReceiver

Eventsource that accepts the event requests using a message receiver. Eventsource is responsible on two tasks accepting the subscriptions and subscription related reqests and dispatching events. Subscriptions contains operations listed in the WS-Eventing specification. {SubscribeOP, UnsubscribeOP, RenewOP, GetstatusOP, SubscriptionEndOP} based on the action in the request eventsource identify the operation and send it for processing. Eventsource link with a subscription manager to store the subscriptions.

Constructor Summary

SynapseEventSource(String name)

Method Summary

void	buildService(AxisConfiguration axisCfg)
void	dispatchEvents(MessageContext msgCtx) Public method for event dispatching, used by the eventPublisher mediator and eventSource
String	getConfigurationProperty(String name)
String	getFileName()
String	getName()
org.wso2.eventing.SubscriptionManager	getSubscriptionManager()
boolean	isContainsConfigurationProperty(String name)
void	putConfigurationProperty(String name, String value)
void	receive(MessageContext mc) Override the Message receiver method to accept subscriptions and events
void	setFileName(String fileName)
void	setName(String name)
void	setSubscriptionManager(org.wso2.eventing.SubscriptionManager subscriptionManager)

Methods inherited from class java.lang.Object

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

Constructor Detail

SynapseEventSource

public SynapseEventSource(String name)

Method Detail

getName

public String getName()

setName

public void setName(String name)

getSubscriptionManager

public org.wso2.eventing.SubscriptionManager getSubscriptionManager()

setSubscriptionManager

public void setSubscriptionManager(org.wso2.eventing.SubscriptionManager subscriptionManager)

getFileName

public String getFileName()

setFileName

public void setFileName(String fileName)

buildService

public void buildService(AxisConfiguration axisCfg)
                  throws AxisFault

Throws:

AxisFault

receive

public void receive(MessageContext mc)
             throws AxisFault

Override the Message receiver method to accept subscriptions and events

Specified by:

receive in interface MessageReceiver

Overrides:

receive in class SynapseMessageReceiver

Parameters:

mc - message context

Throws:

AxisFault

dispatchEvents

public void dispatchEvents(MessageContext msgCtx)

Public method for event dispatching, used by the eventPublisher mediator and eventSource

Parameters:

msgCtx - message context

putConfigurationProperty

public void putConfigurationProperty(String name,
                                     String value)

getConfigurationProperty

public String getConfigurationProperty(String name)

isContainsConfigurationProperty

public boolean isContainsConfigurationProperty(String name)