openfire推送离线聊天信息插件

1、openfire 推送离线聊天信息插件转载地址： java view plain copy /* Copyright (C) 2004-2008 JiveSoftware. All rights reserved.* * Licensed under theApache License, Version 2.0 (the License);* you maynot use this file except in compliance with the License. You may obtain a copy of the License at* * * * Unless required

2、by applicable law or agreed to in writing, software * distributed under the License is distributed on an AS IS BASIS,* WITHOUT WARRANTIES ORCONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and * limitations under the License. */* * se

3、nd offline msg plugin */ public class OfflineMsg implements PacketInterceptor, Plugin private static final Logger log =LoggerFactory.getLogger(OfflineMsg.class); / Hook for intercpetornprivate InterceptorManagerinterceptorManager;private static PluginManagerpluginManager;private UserManager userMana

4、ger;private PresenceManager presenceManager;public OfflineMsg() public void debug(String str) if (true) / public void initializePlugin(PluginManager manager, File pluginDirectory) interceptorManager = InterceptorManager.getInstance(); interceptorManager.addInterceptor(this);XMPPServer server = XMPPS

5、erver.getInstance(); userManager = server.getUserManager();presenceManager = server.getPresenceManager(); pluginManager = manager; this.debug(startthis.debug(start offline 1640);/* * intercept message */ Override public void interceptPacket(Packet packet, Session session,boolean incoming, booleanpro

6、cessed) throws PacketRejectedException JID recipient = packet.getTo(); if (recipient != null) String username =recipient.getNode();/ if broadcastmessage or user is not existif (username= null| !UserManager.getInstance().isRegisteredUser(recipient) return; else if(!XMPPServer.getInstance().getServerI

7、nfo().getXMPPDomain().equals(recipient.getDomain( ) / not from the same domainreturn; else if (.equals(recipient.getResource() this.doAction(packet, incoming, processed, session); /* send offline msg fromthis function*/private void doAction(Packetpacket, boolean incoming, boolean processed,Session s

8、ession) Packet copyPacket =packet.createCopy();if (packet instanceofMessage) Message message = (Message)copyPacket;if (message.getType() =Message.Type.chat) if (processed| !incoming)return; Message sendmessage =(Message) packet;String content = sendmessage.getBody(); JID recipient = sendmessage.getT

9、o();try/ get messageif (recipient.getNode() = null| !UserManager.getInstance().isRegisteredUser(recipient.getNode()/ Sender is requestingpresence information of an / anonymous user throw new UserNotFoundException(Username is null); Presence status = presenceManager.getPresence(userManager.getUser(re

10、cipient.getNode();if (status != null)this.debug(recipient.getNode() + online111+ elsethis.debug(recipient.getNod,message: + content); e() + offline111+,message: + content); /* add your code here to send offline msg* recipient.getNode() : receives id,for example,if* receives jid is 23localhost, recei

11、ves id is 23* content: message content*/ / end if catch (UserNotFoundException e) this.debug(exceptoin + recipient.getNode() + not find+ ,full jid: +recipient.toFullJID(); else if (message.getType() = List<?> els =message.getElement().elements(x); if (els != null && !els.isEmpty() else else else if (packet instanceof IQ)IQ iq = (IQ) copyPacket;if(iq.getType() = iq.getChi