国产一级a片免费看高清,亚洲熟女中文字幕在线视频,黄三级高清在线播放,免费黄色视频在线看

打開APP
userphoto
未登錄

開通VIP，暢享免費電子書等14項超值服

開通VIP

首頁

好書

留言交流

下載APP

聯(lián)系客服
openfire推送離線聊天信息插件

  2.  * 
  3.  * Licensed under the Apache License, Version 2.0 (the "License"); 
  4.  * you may not use this file except in compliance with the License. 
  5.  * You may obtain a copy of the License at 
  6.  * 
  7.  *     http://www.apache.org/licenses/LICENSE-2.0 
  8.  * 
  9.  * Unless required by applicable law or agreed to in writing, software 
  10.  * distributed under the License is distributed on an "AS IS" BASIS, 
  11.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 
  12.  * See the License for the specific language governing permissions and 
  13.  * limitations under the License. 
  14.  */  
  15. package com.hyh.offlinemessage.plugin;  
  16.   
  17. import java.io.File;  
  18. import java.io.IOException;  
  19. import java.sql.Timestamp;  
  20. import java.util.Date;  
  21. import java.util.List;  
  22. import org.jivesoftware.database.SequenceManager;  
  23. import org.jivesoftware.openfire.PresenceManager;  
  24. import org.jivesoftware.openfire.XMPPServer;  
  25. import org.jivesoftware.openfire.container.Plugin;  
  26. import org.jivesoftware.openfire.container.PluginManager;  
  27. import org.jivesoftware.openfire.interceptor.InterceptorManager;  
  28. import org.jivesoftware.openfire.interceptor.PacketInterceptor;  
  29. import org.jivesoftware.openfire.interceptor.PacketRejectedException;  
  30. import org.jivesoftware.openfire.session.Session;  
  31. import org.jivesoftware.openfire.user.User;  
  32. import org.jivesoftware.openfire.user.UserManager;  
  33. import org.jivesoftware.openfire.user.UserNotFoundException;  
  34. import org.slf4j.Logger;  
  35. import org.slf4j.LoggerFactory;  
  36. import org.xmpp.packet.IQ;  
  37. import org.xmpp.packet.JID;  
  38. import org.xmpp.packet.Message;  
  39. import org.xmpp.packet.Packet;  
  40. import org.xmpp.packet.Presence;  
  41. import org.jivesoftware.openfire.XMPPServer;  
  42. import org.jivesoftware.openfire.container.Plugin;  
  43. import org.jivesoftware.openfire.container.PluginManager;  
  44. import org.jivesoftware.openfire.user.User;  
  45. import org.jivesoftware.openfire.user.UserManager;  
  46. import org.jivesoftware.openfire.PresenceManager;  
  47. import org.jivesoftware.util.JiveGlobals;  
  48. import org.jivesoftware.util.Log;  
  49.   
  50. /** 
  51.  * send offline msg plugin 
  52.  */  
  53. public class OfflineMsg implements PacketInterceptor, Plugin {  
  54.     private static final Logger log = LoggerFactory.getLogger(OfflineMsg.class);  
  55.     // Hook for intercpetorn  
  56.     private InterceptorManager interceptorManager;  
  57.     private static PluginManager pluginManager;  
  58.     private UserManager userManager;  
  59.     private PresenceManager presenceManager;  
  60.   
  61.     public OfflineMsg() {  
  62.     }  
  63.   
  64.     public void debug(String str) {  
  65.         if (true) {  
  66.             // System.out.println(str);  
  67.         }  
  68.     }  
  69.   
  70.     public void initializePlugin(PluginManager manager, File pluginDirectory) {  
  71.         interceptorManager = InterceptorManager.getInstance();  
  72.         interceptorManager.addInterceptor(this);  
  73.         XMPPServer server = XMPPServer.getInstance();  
  74.         userManager = server.getUserManager();  
  75.         presenceManager = server.getPresenceManager();  
  76.         pluginManager = manager;  
  77.         this.debug("start offline 1640");  
  78.     }  
  79.   
  80.     public void destroyPlugin() {  
  81.         this.debug("start offline 1640");  
  82.     }  
  83.   
  84.     /** 
  85.      * intercept message 
  86.      */  
  87.     @Override  
  88.     public void interceptPacket(Packet packet, Session session,  
  89.             boolean incoming, boolean processed) throws PacketRejectedException {  
  90.         JID recipient = packet.getTo();  
  91.         if (recipient != null) {  
  92.             String username = recipient.getNode();  
  93.             // if broadcast message or user is not exist  
  94.             if (username == null  
  95.                     || !UserManager.getInstance().isRegisteredUser(recipient)) {  
  96.                 return;  
  97.             } else if (!XMPPServer.getInstance().getServerInfo()  
  98.                     .getXMPPDomain().equals(recipient.getDomain())) {  
  99.                 // not from the same domain  
  100.                 return;  
  101.             } else if ("".equals(recipient.getResource())) {  
  102.             }  
  103.         }  
  104.         this.doAction(packet, incoming, processed, session);  
  105.     }  
  106.   
  107.     /** 
  108.      * send offline msg from this function 
  109.      */  
  110.     private void doAction(Packet packet, boolean incoming, boolean processed,  
  111.             Session session) {  
  112.         Packet copyPacket = packet.createCopy();  
  113.         if (packet instanceof Message) {  
  114.             Message message = (Message) copyPacket;  
  115.             if (message.getType() == Message.Type.chat) {  
  116.                 if (processed || !incoming) {  
  117.                     return;  
  118.                 }  
  119.                 Message sendmessage = (Message) packet;  
  120.                 String content = sendmessage.getBody();  
  121.                 JID recipient = sendmessage.getTo();  
  122.                 // get message  
  123.                 try {  
  124.                     if (recipient.getNode() == null  
  125.                             || !UserManager.getInstance().isRegisteredUser(  
  126.                                     recipient.getNode())) {  
  127.                         // Sender is requesting presence information of an  
  128.                         // anonymous user  
  129.                         throw new UserNotFoundException("Username is null");  
  130.                     }  
  131.                     Presence status = presenceManager.getPresence(userManager  
  132.                             .getUser(recipient.getNode()));  
  133.                     if (status != null) {  
  134.                         this.debug(recipient.getNode() + " online111"  
  135.                                 + ",message: " + content);  
  136.                     } else {  
  137.                         this.debug(recipient.getNode() + " offline111"  
  138.                                 + ",message: " + content);  
  139.                         /* 
  140.                          * add your code here to send offline msg 
  141.                          * recipient.getNode() : receive's id,for example,if 
  142.                          * receive's jid is "23@localhost", receive's id is "23" 
  143.                          * content: message content 
  144.                          */  
  145.                     }// end if  
  146.                 } catch (UserNotFoundException e) {  
  147.                     this.debug("exceptoin " + recipient.getNode() + " not find"  
  148.                             + ",full jid: " + recipient.toFullJID());  
  149.                 }  
  150.             } else if (message.getType() == Message.Type.groupchat) {  
  151.                 List<?> els = message.getElement().elements("x");  
  152.                 if (els != null && !els.isEmpty()) {  
  153.                 } else {  
  154.                 }  
  155.             } else {  
  156.             }  
  157.         } else if (packet instanceof IQ) {  
  158.             IQ iq = (IQ) copyPacket;  
  159.             if (iq.getType() == IQ.Type.set && iq.getChildElement() != null  
  160.                     && "session".equals(iq.getChildElement().getName())) {  
  161.             }  
  162.         } else if (packet instanceof Presence) {  
  163.             Presence presence = (Presence) copyPacket;  
  164.             if (presence.getType() == Presence.Type.unavailable) {  
  165.             }  
  166.         }  
  167.     }  
  168. }  


本站僅提供存儲服務(wù)，所有內(nèi)容均由用戶發(fā)布，如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容，請點擊舉報。
打開APP，閱讀全文并永久保存 查看更多類似文章
猜你喜歡
類似文章
源碼詳解openfire保存消息記錄_修改服務(wù)端方式
openfire3.6.3插件開發(fā)方法(經(jīng)小組測試成功)
通過openfire發(fā)送文字
Android客戶端基于XMPP的IM（openfire+asmack）的聊天工具之環(huán)境搭建及與服務(wù)器建立連接（一）
一個gtalk的robot的簡單實現(xiàn)
java實現(xiàn)簡單XMPP發(fā)送消息和文件的簡單例子
更多類似文章 >>
生活服務(wù)
分享 收藏 導長圖 關(guān)注 下載文章
綁定賬號成功
后續(xù)可登錄賬號暢享VIP特權(quán)！
如果VIP功能使用有故障，
可點擊這里聯(lián)系客服！

聯(lián)系客服