2017-07-12 00:57:54 +08:00
|
|
|
import RedisPubSub from '/imports/startup/server/redis2x';
|
|
|
|
import handleChatMessage from './handlers/chatMessage';
|
|
|
|
import handleChatHistory from './handlers/chatHistory';
|
2017-07-20 20:44:57 +08:00
|
|
|
import handleChatPublicHistoryClear from './handlers/chatPublicHistoryClear';
|
2017-07-12 00:57:54 +08:00
|
|
|
|
|
|
|
RedisPubSub.on('GetChatHistoryRespMsg', handleChatHistory);
|
|
|
|
RedisPubSub.on('SendPublicMessageEvtMsg', handleChatMessage);
|
|
|
|
RedisPubSub.on('SendPrivateMessageEvtMsg', handleChatMessage);
|
2017-07-20 20:44:57 +08:00
|
|
|
RedisPubSub.on('ClearPublicChatHistoryEvtMsg', handleChatPublicHistoryClear);
|