odbtools/odbctest/mql/aaa/19extensions/31subscription.mql

-- ============================================================
-- subscribe(S) / unsubscribe(S) 测试
-- ============================================================

-- 1. subscribe 订阅
/**
beforerun(subscribe('test_topic'))
**/
;

insert into /test/aaa/test_ext (e_name, e_text) values ('sub_test_1', 'subscribe topic test')
;

/**
sleep(2s)
**/
;

select e_name from /test/aaa/test_ext where e_name='sub_test_1'
/**
output()
onerror(continue)
**/
;

-- 2. unsubscribe 取消订阅
/**
beforerun(unsubscribe('test_topic'))
**/
;

insert into /test/aaa/test_ext (e_name, e_text) values ('unsub_test_1', 'unsubscribe topic test')
;

/**
sleep(2s)
**/
;

select e_name from /test/aaa/test_ext where e_name='unsub_test_1'
/**
output()
onerror(continue)
**/
;

-- 3. 同时 subscribe 多个
/**
beforerun(subscribe('topic_a'), subscribe('topic_b'))
**/
;

insert into /test/aaa/test_ext (e_name, e_text) values ('multi_sub_test', 'multi subscribe test')
;

/**
beforerun(unsubscribe('topic_a'), unsubscribe('topic_b'))
**/
;

/**
sleep(2s)
**/
;

select e_name from /test/aaa/test_ext where e_name='multi_sub_test'
/**
output()
onerror(continue)
**/
;