// Инициализация плагина zbus
String brokerAddress = "127.0.0.1:155555";
String scanRootPackage = "com.wellbole";
ZbusPlugin zbusPlugin = new ZbusPlugin(brokerAddress,scanRootPackage);
me.add(zbusPlugin);

// Создание отправителя MQ общего типа (Dict) с именем MyMQ
Sender<Dict> mqSender = new MqSender<Dict>("MyMQ");
Dict dict = new Dict();
dict.setId(1L);
dict.set("key", "key"+1);
dict.set("value", "value"+1);
// Синхронная отправка объекта в MQ
mqSender.sendSync(dict);
// sendAsync
// Асинхронная отправка объекта в MQ
// mqSender.sendAsync(dict);

// Создание отправителя Topic общего типа (String) с именами MQ и Topic
Sender<String> topicSender = new TopicSender<String>("Topic", "Check");
// Синхронная отправка объекта на Topic
topicSender.sendSync("Это сообщение для подписки");
// Асинхронная отправка объекта на Topic
// topicSender.sendAsync("Это сообщение для подписки");

// Создание отправителя Event общего типа (String), который является разновидностью Topic и использует общий MQ, где тип становится именем Topic
Sender<String> eventSender = new EventSender<String>();

@Mq("MQ-Str")
@Topic(mq="Topic",topic="Check")
@Event
@Handler
public class TestMsgHandler extends TMsgHandler<String> {
    private static final Log LOG = Log.getLog(TestMsgHandler.class);
    @Override
    public void handle(String msg) {
        LOG.info("received:msg="+msg);
    }
}