Package com.apama.epl.plugin
Class Correlator
- java.lang.Object
-
- com.apama.epl.plugin.Correlator
-
public class Correlator extends java.lang.Object
Static class to allow java plugins to interact with the correlator. This class must only be used from an EPL Java plugin. (Not from JMon)
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
pluginMethodBlocking()
Methods declared as non-blocking can opt to block by calling this method.static void
sendTo(java.lang.String evt, Channel c)
Sends the supplied string to the specified Channel.static void
sendTo(java.lang.String evt, Context c)
Sends the supplied string to the specified context.static void
sendTo(java.lang.String evt, Context... c)
Sends the supplied string to the specified contexts.static void
sendTo(java.lang.String evt, java.lang.String channel)
Sends the supplied string to the specified channel name.static void
subscribe(EventHandler handler, java.lang.String... channels)
Subscribes a callback handler for events sent to the given channels.static void
unsubscribe(EventHandler handler)
Unsubscribes a handler from all channels.static void
unsubscribe(EventHandler handler, java.lang.String... channels)
Unsubscribes a handler from some channels.
-
-
-
Method Detail
-
sendTo
public static void sendTo(java.lang.String evt, Context c)
Sends the supplied string to the specified context. The context ref can only be passed into the plugin or retrieved as the current context.- See Also:
Context
,Context.getCurrent()
-
sendTo
public static void sendTo(java.lang.String evt, java.lang.String channel)
Sends the supplied string to the specified channel name.
-
sendTo
public static void sendTo(java.lang.String evt, Channel c)
Sends the supplied string to the specified Channel.- See Also:
Channel
-
sendTo
public static void sendTo(java.lang.String evt, Context... c)
Sends the supplied string to the specified contexts. The context refs can only be passed into the plugin or retrieved as the current context.- See Also:
Context
,Context.getCurrent()
-
subscribe
public static void subscribe(EventHandler handler, java.lang.String... channels)
Subscribes a callback handler for events sent to the given channels. The handleEvent method on the handler will be called with the event string and the channel to which it was sent on a correlator worker thread. If this handler is already subscribed to channels, the extra channels will be added.
-
unsubscribe
public static void unsubscribe(EventHandler handler, java.lang.String... channels)
Unsubscribes a handler from some channels.
-
unsubscribe
public static void unsubscribe(EventHandler handler)
Unsubscribes a handler from all channels.
-
pluginMethodBlocking
public static void pluginMethodBlocking()
Methods declared as non-blocking can opt to block by calling this method.
-
-