org.jivesoftware.smack.packet.Message.getPacketID()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(6.2k)|赞(0)|评价(0)|浏览(172)

本文整理了Java中org.jivesoftware.smack.packet.Message.getPacketID()方法的一些代码示例,展示了Message.getPacketID()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Message.getPacketID()方法的具体详情如下:
包路径:org.jivesoftware.smack.packet.Message
类名称:Message
方法名:getPacketID

Message.getPacketID介绍

暂无

代码示例

代码示例来源:origin: org.mobicents.resources/mobicents-slee-ra-xmpp-library

  1. IBBOutputStream(String userID, String sid, int blockSize) {
  2. if (blockSize <= 0) {
  3. throw new IllegalArgumentException("Buffer size <= 0");
  4. }
  5. buffer = new byte[blockSize];
  6. this.userID = userID;
  7. Message template = new Message(userID);
  8. messageID = template.getPacketID();
  9. this.sid = sid;
  10. closePacket = createClosePacket(userID, sid);
  11. }

代码示例来源:origin: org.littleshoot/xmpp

  1. @Override
  2. public void processPacket(final Packet packet) {
  3. final Message msg = (Message) packet;
  4. final String id = msg.getPacketID();
  5. log.info("Checking message ID: {}", id);
  6. if (loggedOut.get()) {
  7. log.warn("Got a message while logged out?");
  8. return;
  9. }
  10. if (sentMessageIds.contains(id)) {
  11. log.warn("Message is from us!!");
  12. // This is a little silly in that we're sending a
  13. // message back to ourselves, but this signals to the
  14. // client thread right away that the invite has failed.
  15. final Message error = newError(msg);
  16. xmppConnection.sendPacket(error);
  17. } else {
  18. exec.execute(new PacketProcessor(msg));
  19. }
  20. }
  21. };

代码示例来源:origin: org.littleshoot/xmpp

  1. @Override
  2. public void processPacket(final Packet packet) {
  3. final Message msg = (Message) packet;
  4. final String id = msg.getPacketID();
  5. log.info("Checking message ID: {}", id);
  6. if (loggedOut.get()) {
  7. log.warn("Got a message while logged out?");
  8. return;
  9. }
  10. if (sentMessageIds.contains(id)) {
  11. log.warn("Message is from us!!");
  12. // This is a little silly in that we're sending a
  13. // message back to ourselves, but this signals to the
  14. // client thread right away that the invite has failed.
  15. final Message error = newError(msg);
  16. xmppConnection.sendPacket(error);
  17. } else {
  18. exec.execute(new PacketProcessor(msg));
  19. }
  20. }
  21. };

代码示例来源:origin: org.mobicents.resources/mobicents-slee-ra-xmpp-library

  1. public String toXML() {
  2. StringBuffer buf = new StringBuffer();
  3. buf.append("<message");
  4. if (getPacketID() != null) {
  5. buf.append(" id=\"").append(getPacketID()).append("\"");

代码示例来源:origin: org.igniterealtime.smack/smackx

  1. public void processPacket(Packet packet) {
  2. Message message = (Message) packet;
  3. MessageEvent messageEvent =
  4. (MessageEvent) message.getExtension("x", "jabber:x:event");
  5. if (messageEvent.isMessageEventRequest()) {
  6. // Fire event for requests of message events
  7. for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
  8. fireMessageEventRequestListeners(
  9. message.getFrom(),
  10. message.getPacketID(),
  11. ((String) it.next()).concat("NotificationRequested"));
  12. } else
  13. // Fire event for notifications of message events
  14. for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
  15. fireMessageEventNotificationListeners(
  16. message.getFrom(),
  17. messageEvent.getPacketID(),
  18. ((String) it.next()).concat("Notification"));
  19. };

代码示例来源:origin: org.mobicents.resources/mobicents-slee-ra-xmpp-library

  1. public void processPacket(Packet packet) {
  2. Message message = (Message) packet;
  3. MessageEvent messageEvent =
  4. (MessageEvent) message.getExtension("x", "jabber:x:event");
  5. if (messageEvent.isMessageEventRequest()) {
  6. // Fire event for requests of message events
  7. for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
  8. fireMessageEventRequestListeners(
  9. message.getFrom(),
  10. message.getPacketID(),
  11. ((String) it.next()).concat("NotificationRequested"));
  12. } else
  13. // Fire event for notifications of message events
  14. for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
  15. fireMessageEventNotificationListeners(
  16. message.getFrom(),
  17. messageEvent.getPacketID(),
  18. ((String) it.next()).concat("Notification"));
  19. };

代码示例来源:origin: tiandawu/IotXmpp

  1. public void processPacket(Packet packet) {
  2. Message message = (Message) packet;
  3. MessageEvent messageEvent =
  4. (MessageEvent) message.getExtension("x", "jabber:x:event");
  5. if (messageEvent.isMessageEventRequest()) {
  6. // Fire event for requests of message events
  7. for (Iterator<String> it = messageEvent.getEventTypes(); it.hasNext();)
  8. fireMessageEventRequestListeners(
  9. message.getFrom(),
  10. message.getPacketID(),
  11. it.next().concat("NotificationRequested"));
  12. } else
  13. // Fire event for notifications of message events
  14. for (Iterator<String> it = messageEvent.getEventTypes(); it.hasNext();)
  15. fireMessageEventNotificationListeners(
  16. message.getFrom(),
  17. messageEvent.getPacketID(),
  18. it.next().concat("Notification"));
  19. };

代码示例来源:origin: org.littleshoot/smack-xmpp-3-2-2

  1. public void processPacket(Packet packet) {
  2. Message message = (Message) packet;
  3. MessageEvent messageEvent =
  4. (MessageEvent) message.getExtension("x", "jabber:x:event");
  5. if (messageEvent.isMessageEventRequest()) {
  6. // Fire event for requests of message events
  7. for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
  8. fireMessageEventRequestListeners(
  9. message.getFrom(),
  10. message.getPacketID(),
  11. ((String) it.next()).concat("NotificationRequested"));
  12. } else
  13. // Fire event for notifications of message events
  14. for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
  15. fireMessageEventNotificationListeners(
  16. message.getFrom(),
  17. messageEvent.getPacketID(),
  18. ((String) it.next()).concat("Notification"));
  19. };

代码示例来源:origin: org.igniterealtime.smack/smack

  1. buf.append(" xml:lang=\"").append(getLanguage()).append("\"");
  2. if (getPacketID() != null) {
  3. buf.append(" id=\"").append(getPacketID()).append("\"");

代码示例来源:origin: org.littleshoot/smack-xmpp-3-2-2

  1. buf.append(" xml:lang=\"").append(getLanguage()).append("\"");
  2. if (getPacketID() != null) {
  3. buf.append(" id=\"").append(getPacketID()).append("\"");

代码示例来源:origin: tiandawu/IotXmpp

  1. buf.append(" xml:lang=\"").append(getLanguage()).append("\"");
  2. if (getPacketID() != null) {
  3. buf.append(" id=\"").append(getPacketID()).append("\"");

代码示例来源:origin: org.mobicents.resources/mobicents-slee-ra-xmpp-library

  1. private void sendCancelMessage(Message message) {
  2. IQ error = FileTransferNegotiator.createIQ(message.getPacketID(), message.getFrom(), message.getTo(),
  3. IQ.Type.ERROR);
  4. error.setError(new XMPPError(504));
  5. connection.sendPacket(error);
  6. }

代码示例来源:origin: org.geoserver.community/gs-wps-remote

  1. + origin
  2. + "','"
  3. + message.getPacketID()
  4. + "');");

相关文章