Skip to content
广告❤️成为赞助商

命令监听器

命令监听器,Mongo驱动在执行命令语句时,会在开始执行前、执行成功后、执行失败后,发布消息

说明:

使用命令监听器时,需要将其注册为SpringBean

com.anwen.mongo.listener.Listener

  • 该接口是监听器的接口,所有监听器都应实现此接口,实现接口中的方法
  • commandStarted:处理命令开始信息
  • commandSucceeded: 处理命令成功信息
  • commandFailed: 处理命令失败信息
  • getOrder:指定监听器排序

示例

首先,需要将监听器类实现Listener接口,并将该类注册为Bean
java
//注册为SpringBean
@Component
public class CustomListener implements Listener {}
接下来,实现Listener接口中的方法,就可以对命令进行监听了
java
//注册为SpringBean
@Component
public class CustomListener implements Listener {
    @Override
    public void commandStarted(CommandStarted commandStarted) {
        System.out.println(JSON.toJSONString(commandStarted));
    }

    @Override
    public void commandSucceeded(CommandSucceeded commandSucceeded) {
        System.out.println(JSON.toJSONString(commandSucceeded));
    }

    @Override
    public void commandFailed(CommandFailed commandFailed) {
        System.out.println(JSON.toJSONString(commandFailed));
    }

    @Override
    public int getOrder() {
        return 0;
    }
}