//
//消费者：订阅事件
//
@CloudEvent("hello.demo")
public class EVENT_hello_demo implements CloudEventHandler {
    @Override
    public boolean handler(Event event) throws Throwable {
        //业务处理
        System.out.println(LocalDateTime.now() + ONode.stringify(event));
        
        //如果成功返回true，否则为false（之后会延时再派送）
        return true;
    }
}


//
// 发产者：发布事件
//
@Controller
public class DemoController {
    @Mapping("/test")
    public Object test(String msg) {
        if(Utils.isEmpty(msg)){
            msg = "demo2";
        }

        //发布事件
        Event event = new Event("hello.demo", msg);
        return CloudClient.event().publish(event);
    }
}

附演示源码：https://gitee.com/noear/solon_rpc_demo/tree/main/demo30.solon-cloud-rabbitmq

5、发布日志总线服务适配组件

• water-solon-plugin（对water日志的适配）

特性说明：

1. 支持元信息描述（可语义操作）

@Controller
public class DemoController {

    CloudLogger logger = CloudLogger.get(TestController.class);

    @Mapping("/test")
    public void test(String msg) throws Exception {
        logger.info("我是好人：（");
        logger.info("我不是：{} \n\n {}", "坏人",12);
        logger.info(Tags.tag2("打卡"), "我是谁？");
    }
}