<dependencies>
<dependency>
<groupId>com.cronus</groupId>
<artifactId>cronus-core</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies>
import com.cronus.Cronus;
import com.cronus.annotation.Cron;
public class MyScheduler {
@Cron(cronExpression = "0 0/5 * * * ?")
public void runTask() {
}
public static void main(String[] args) {
Cronus cronus = new Cronus();
cronus.register(new MyScheduler());
cronus.start();
}
}
import com.cronus.event.CronusEvent;
import com.cronus.annotation.CronusEvent;
public class MyEventHandler {
@CronusEvent(topic = "user.created")
public void handleUserCreatedEvent(CronusEvent event) {
String userId = event.getPayload().getString("userId");
}
public static void main(String[] args) {
Cronus cronus = new Cronus();
cronus.register(new MyEventHandler());
cronus.start();
}
}
