This dependency is designed for guaranteed processing of event queues in Spring applications. If you need to process a lot of events quickly, guaranteed not to lose any, even if your app crashes, then this is the solution for you.
If we use Spring Boot 2 or Spring 5, then we can utilize the Mover Process starter package. Let's add the following dependency to the pom.xml file:
<dependency>
<groupId>org.maxron.platform</groupId>
<artifactId>mover-process</artifactId>
<version>2.0.4</version>
</dependency>To enable Mover Process, Spring makes good use of annotations, much like enabling any other configuration level feature in the framework.
We can enable the Mover Process feature simply by adding the @EnableMoverProcess annotation to any of the configuration classes:
@EnableMoverProcess
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}Note: After we enable Mover Process, for the minimal setup, we must implement CommandExecutor.class and Command.class.
CommandExecutor.class executes Command.class events in transaction
@Getter
public class YourExtendCommand extends AbstractCommand {
private final YourDataEvent dataEvent;
public YourExtendCommand(String commandId, String trackingKey, YourDataEvent dataEvent) {
super(commandId, trackingKey);
this.dataEvent = dataEvent;
}
}@Component
public class YourCommandExecutor implements CommandExecutor<YourExtendCommand> {
@Autowired
private YourMessageChannel messageChannel;
@Override
public void executeInMoverTransaction(CommandExecution executionContext, TwCommand command) {
try {
if (messageChannel.send(command.getDataEvent())) {
// the event was successful, remove it from the queue
commandExecution.ok();
} else {
// re-executing the event
commandExecution.retry();
}
} catch (Exception e) {
if (isTransientException(e)) {
// re-executing the event
commandExecution.retry();
} else {
// stopping event processing to fix the error
commandExecution.stop(e);
}
}
}
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent