summaryrefslogtreecommitdiff
path: root/example/plugin/example_plugin_message.lua
diff options
context:
space:
mode:
Diffstat (limited to 'example/plugin/example_plugin_message.lua')
-rw-r--r--example/plugin/example_plugin_message.lua8
1 files changed, 4 insertions, 4 deletions
diff --git a/example/plugin/example_plugin_message.lua b/example/plugin/example_plugin_message.lua
index 3d1f52b..6515bdc 100644
--- a/example/plugin/example_plugin_message.lua
+++ b/example/plugin/example_plugin_message.lua
@@ -8,7 +8,7 @@ end
function on_message(sess, topic_id, msg, sess_context, env)
-- print("message call on message function, id", topic_id)
- -- print("message is", msg.data)
+ print("message is", msg.data)
end
function plugin_load(stellar, plug_env)
@@ -16,12 +16,12 @@ function plugin_load(stellar, plug_env)
print("this example aims to test topic functions")
plug_env.st = stellar
- plug_env.id = plugin_manage.register(stellar, plugin_ctx_new, plugin_ctx_free, plug_env)
+ plug_env.id = session_plugin.register(stellar, plugin_ctx_new, plugin_ctx_free, plug_env)
plug_env.data = "this is message example plug env data"
--[[ 订阅TOPIC_SESSION_STAT, 并完成函数注册 ]]
- test_topic_id = message.gettopicid(stellar, "TOPIC_SESSION_STAT")
- message.subscribetopic(stellar, test_topic_id, on_message, plug_env.id)
+ test_topic_id = session_mq.get_topic_id(stellar, "TOPIC_SESSION_STAT")
+ session_mq.subscribe_topic(stellar, test_topic_id, on_message, plug_env.id)
end
function plugin_unload(plug_env)