diff options
Diffstat (limited to 'example/plugin/example_plugin-2.lua')
| -rw-r--r-- | example/plugin/example_plugin-2.lua | 29 |
1 files changed, 23 insertions, 6 deletions
diff --git a/example/plugin/example_plugin-2.lua b/example/plugin/example_plugin-2.lua index faffe5b..62c13ed 100644 --- a/example/plugin/example_plugin-2.lua +++ b/example/plugin/example_plugin-2.lua @@ -1,16 +1,24 @@ function plugin_ctx_new(sess, plug_env, sess_context) print("now create new ctx example-2, plugin id ", plug_env.id) - local sessid = session.getid(sess) + local sesstype = session.gettype(sess) sess_context.id = 200 - print("session id is ", sessid) - session.setid(sess, 50000) + sess_context.called = 0 + print("session type is ", sesstype) + -- session.setid(sess, 50000) end function plugin_ctx_free(sess, sess_context, plug_env) - print(sess_context.id) + print(plug_env.id, sess_context.id, sess_context.called, plug_env.called) print("now begin to free ctx context example-2") end +function on_message(sess, topic_id, msg, sess_context, env) + -- print(sess, topic_id, msg, sess_context, env) + sess_context.called = sess_context.called + 1 + env.calledcount = env.calledcount + 1 + print("call on message", env.id, env.calledcount, sess_context.called) +end + function free_message() print("free message") end @@ -18,8 +26,17 @@ end function plugin_load(stellar, plug_env) print("now begin to load plugin example-2") plug_env.id = plugin_manage.register(stellar, plugin_ctx_new, plugin_ctx_free, plug_env) - topic_id = message.gettopicid(stellar, "TOPIC_SESSION_STAT") + topic_id = message.gettopicid(stellar, "TCP") print("get topic id is ", topic_id) + message.subscribetopic(stellar, topic_id, on_message, plug_env.id) + -- print("subscribetopic result", bool) + -- mq_topic_id = message.gettopicid(stellar, "SESSION_MQ_TOPIC") + -- print("get session mq topic is", mq_topic_id) + -- message.subscribetopic(stellar, mq_topic_id, on_message, plug_env.id) + + plug_env.calledcount = 0 + + --[[ create_id = message.gettopicid(stellar, "TOPIC_LUA_SESSION_TEST") if (create_id < 0) then @@ -30,9 +47,9 @@ function plugin_load(stellar, plug_env) else print("has created, id is ", create_id) end + --]] end function plugin_unload(plug_env) print("now running unload plugin example-2 function, plugin id is ", plug_env.id) - end
\ No newline at end of file |