Package org.apache.synapse.eventing
Class SynapseEventSource
- java.lang.Object
-
- org.apache.synapse.core.axis2.SynapseMessageReceiver
-
- org.apache.synapse.eventing.SynapseEventSource
-
- All Implemented Interfaces:
org.apache.axis2.engine.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
Constructors Constructor Description SynapseEventSource(String name)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
buildService(org.apache.axis2.engine.AxisConfiguration axisCfg)
void
dispatchEvents(MessageContext msgCtx)
Public method for event dispatching, used by the eventPublisher mediator and eventSourceString
getConfigurationProperty(String name)
String
getFileName()
String
getName()
org.wso2.eventing.SubscriptionManager
getSubscriptionManager()
boolean
isContainsConfigurationProperty(String name)
void
putConfigurationProperty(String name, String value)
void
receive(org.apache.axis2.context.MessageContext mc)
Override the Message receiver method to accept subscriptions and eventsvoid
setFileName(String fileName)
void
setName(String name)
void
setSubscriptionManager(org.wso2.eventing.SubscriptionManager subscriptionManager)
-
Methods inherited from class org.apache.synapse.core.axis2.SynapseMessageReceiver
doPostInjectUpdates
-
-
-
-
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(org.apache.axis2.engine.AxisConfiguration axisCfg) throws org.apache.axis2.AxisFault
- Throws:
org.apache.axis2.AxisFault
-
receive
public void receive(org.apache.axis2.context.MessageContext mc) throws org.apache.axis2.AxisFault
Override the Message receiver method to accept subscriptions and events- Specified by:
receive
in interfaceorg.apache.axis2.engine.MessageReceiver
- Overrides:
receive
in classSynapseMessageReceiver
- Parameters:
mc
- message context- Throws:
org.apache.axis2.AxisFault
-
dispatchEvents
public void dispatchEvents(MessageContext msgCtx)
Public method for event dispatching, used by the eventPublisher mediator and eventSource- Parameters:
msgCtx
- message context
-
isContainsConfigurationProperty
public boolean isContainsConfigurationProperty(String name)
-
-