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

-- 1. subscribe 订阅
insert into /test/aaa/test_ext (e_name, e_text) values ('sub_test_1', 'subscribe topic test')
/**
subscribe('test_topic')
sleep(2s)
**/
;

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

-- 2. unsubscribe 取消订阅
insert into /test/aaa/test_ext (e_name, e_text) values ('unsub_test_1', 'unsubscribe topic test')
/**
unsubscribe('test_topic')
sleep(2s)
**/
;

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

-- 3. 同时 subscribe 多个
insert into /test/aaa/test_ext (e_name, e_text) values ('multi_sub_test', 'multi subscribe test')
/**
subscribe('topic_a')
subscribe('topic_b')
**/
;

-- 取消多个订阅
insert into /test/aaa/test_ext (e_name, e_text) values ('multi_unsub_test', 'multi unsubscribe test')
/**
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)
**/
;