View Source

Application use cases often require sending recurring or timed notifications. This can be done by creating a timer component that has a producer connected to a channel:


public class SomeTime implements Runnable&nbsp;{

&nbsp;&nbsp; @Producer

&nbsp;&nbsp; protected Channel channel;

&nbsp;&nbsp;

&nbsp;&nbsp;public void run() {

&nbsp;&nbsp; &nbsp; Event event = ...

&nbsp;&nbsp; &nbsp; channel.publish(event);

&nbsp;&nbsp;}

}

and configuring it in a composite:


<composite ....>

&nbsp;&nbsp; <component name="Timer">

&nbsp;&nbsp; &nbsp; &nbsp;<f3:implementation.timer class="..." repeatInterval="10000"/>

&nbsp;&nbsp; &nbsp; &nbsp;<producer name="channel" target="SomeChannel"/>

</composite>

Further, to limit timed events to a single source in a clustered zone, mark the implementation with @Scope("DOMAIN").