summaryrefslogtreecommitdiff
path: root/test/plugin/example_plugin_message.lua
diff options
context:
space:
mode:
Diffstat (limited to 'test/plugin/example_plugin_message.lua')
-rw-r--r--test/plugin/example_plugin_message.lua30
1 files changed, 30 insertions, 0 deletions
diff --git a/test/plugin/example_plugin_message.lua b/test/plugin/example_plugin_message.lua
new file mode 100644
index 0000000..6515bdc
--- /dev/null
+++ b/test/plugin/example_plugin_message.lua
@@ -0,0 +1,30 @@
+function plugin_ctx_new(sess, plug_env, sess_context)
+ -- print("now create new ctx example message, plugin id", plug_env.id)
+end
+
+function plugin_ctx_free(sess, sess_context, plug_env)
+ -- print("now begin to free ctx context example message")
+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)
+end
+
+function plugin_load(stellar, plug_env)
+ print("now begin to load plugin example messaga")
+ print("this example aims to test topic functions")
+
+ plug_env.st = stellar
+ 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 = 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)
+ print("now unload lua plugin example message")
+ print("plugin env data is", plug_env.data)
+end \ No newline at end of file