import com.apama.epl.plugin.Context;
import com.apama.epl.plugin.Correlator;

/**
Demonstrates passing contexts around and enqueueing events
*/
public class enqueue_plugin
{
public static void enqueueEventTo(String event, Context context)
{
// Get the current context we're running in
Context current = Context.getCurrent();

// for some reason we don't want to let you do this.
// An exception will terminate the monitor instance
if (current.equals(context))
{
throw new IllegalArgumentException("Please don't use this function to
send events to the current context!");
}

// send the event to the other context
Correlator.enqueueTo(event, context);
}
}

<application-classes>
<plugin>
<plugin-name>enqueue_plugin</plugin-name>
<plugin-class>enqueue_plugin</plugin-class>
<description>A test plugin</description>
</plugin>
</application-classes>

event A {
string str;
}

monitor EnqueuePluginTest {

// Load the plugin
import "enqueue_plugin" as enqueue_plugin;

action onload {
context c1 := context("receiver");
context c2 := context("sender1");
context c3 := context("sender2");
spawn receiver() to c1; // listen for events
spawn sendto(c1) to c2; // this will work
spawn sendto(c3) to c3; // this won't work because both contexts are the same
}

action receiver()
{
A a;
on all A(): a {
print "receiver got: "+a.toString();
}
}

action sendto(context c)
{
on all A() {
print "sender really shouldn't get anything!";
}
enqueue_plugin.enqueueEventTo(A("Hello, World").toString(), c);
}
}