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

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

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

Message.getFrom介绍

暂无

代码示例

代码示例来源：origin: igniterealtime/Smack

  1. @Override
  2.   public void processStanza(Stanza packet) {
  3.     Message message = (Message) packet;
  4.     RosterExchange rosterExchange = message.getExtension(ELEMENT, NAMESPACE);
  5.     // Fire event for roster exchange listeners
  6.     fireRosterExchangeListeners(message.getFrom(), rosterExchange.getRosterEntries());
  7.   }
  8. };

代码示例来源：origin: igniterealtime/Smack

  1. @Override
  2.   public void processStanza(Stanza packet) {
  3.     Message message = (Message) packet;
  4.     MessageEvent messageEvent = message.getExtension("x", "jabber:x:event");
  5.     if (messageEvent.isMessageEventRequest()) {
  6.       // Fire event for requests of message events
  7.       for (String eventType : messageEvent.getEventTypes())
  8.         fireMessageEventRequestListeners(
  9.           message.getFrom(),
  10.           message.getStanzaId(),
  11.           eventType.concat("NotificationRequested"));
  12.     } else
  13.       // Fire event for notifications of message events
  14.       for (String eventType : messageEvent.getEventTypes())
  15.         fireMessageEventNotificationListeners(
  16.           message.getFrom(),
  17.           messageEvent.getStanzaId(),
  18.           eventType.concat("Notification"));
  19.   }
  20. }, PACKET_FILTER);

代码示例来源：origin: igniterealtime/Smack

  1. @Override
  2.   public void processStanza(Stanza stanza) {
  3.     final Message message = (Message) stanza;
  4.     final EventElement event = EventElement.from(stanza);
  5.     assert (event != null);
  6.     final EntityBareJid from = message.getFrom().asEntityBareJidIfPossible();
  7.     assert (from != null);
  8.     asyncButOrdered.performAsyncButOrdered(from, new Runnable() {
  9.       @Override
  10.       public void run() {
  11.         for (PepListener listener : pepListeners) {
  12.           listener.eventReceived(from, event, message);
  13.         }
  14.       }
  15.     });
  16.   }
  17. };

代码示例来源：origin: igniterealtime/Smack

  1. OmemoMessage.Received omemoMessage = decryptMessage(managerGuard, message.getFrom().asBareJid(), element);
  2.   result.add(new MessageOrOmemoMessage(omemoMessage));
  3. } catch (NoRawSessionException | CorruptedOmemoKeyException | CryptoFailedException e) {
  4.   LOGGER.log(Level.WARNING, "decryptMamQueryResult failed to decrypt message from "
  5.       + message.getFrom() + " due to corrupted session/key: " + e.getMessage());
  6.   result.add(new MessageOrOmemoMessage(message));

代码示例来源：origin: igniterealtime/Smack

  1. @Override
  2.   public void processStanza(Stanza packet) {
  3.     final Message msg = (Message) packet;
  4.     final EntityFullJid from = msg.getFrom().asEntityFullJidIfPossible();
  5.     // Update the room subject
  6.     subject = msg.getSubject();
  7.     asyncButOrdered.performAsyncButOrdered(MultiUserChat.this, new Runnable() {
  8.       @Override
  9.       public void run() {
  10.         // Fire event for subject updated listeners
  11.         for (SubjectUpdatedListener listener : subjectUpdatedListeners) {
  12.           listener.subjectUpdated(msg.getSubject(), from);
  13.         }
  14.       }
  15.     });
  16.   }
  17. };

代码示例来源：origin: igniterealtime/Smack

  1. @Override
  2.   public void processStanza(Stanza packet) {
  3.     Message message = (Message) packet;
  4.     Chat chat;
  5.     if (message.getThread() == null) {
  6.       // CHECKSTYLE:OFF
  7.       chat = getUserChat(message.getFrom());
  8.       // CHECKSTYLE:ON
  9.     }
  10.     else {
  11.       chat = getThreadChat(message.getThread());
  12.     }
  13.     if (chat == null) {
  14.       chat = createChat(message);
  15.     }
  16.     // The chat could not be created, abort here
  17.     if (chat == null)
  18.       return;
  19.     // TODO: Use AsyncButOrdered (with Chat as Key?)
  20.     deliverMessage(chat, message);
  21.   }
  22. }, packetFilter);

代码示例来源：origin: igniterealtime/Smack

  1. EntityBareJid bareFrom = message.getFrom().asEntityBareJidOrThrow();

代码示例来源：origin: igniterealtime/Smack

  1. @Override
  2.   public void processStanza(Stanza stanza) {
  3.     final Message message = (Message) stanza;
  4.     if (!shouldAcceptMessage(message)) {
  5.       return;
  6.     }
  7.     final Jid from = message.getFrom();
  8.     final EntityFullJid fullFrom = from.asEntityFullJidOrThrow();
  9.     final EntityBareJid bareFrom = fullFrom.asEntityBareJid();
  10.     final Chat chat = chatWith(bareFrom);
  11.     chat.lockedResource = fullFrom;
  12.     asyncButOrdered.performAsyncButOrdered(chat, new Runnable() {
  13.       @Override
  14.       public void run() {
  15.         for (IncomingChatMessageListener listener : incomingListeners) {
  16.           listener.newIncomingMessage(bareFrom, message, chat);
  17.         }
  18.       }
  19.     });
  20.   }
  21. }, INCOMING_MESSAGE_FILTER);

代码示例来源：origin: igniterealtime/Smack

  1. /**
  2.  * Creates a new {@link Chat} based on the message. May returns null if no chat could be
  3.  * created, e.g. because the message comes without from.
  4.  *
  5.  * @param message
  6.  * @return a Chat or null if none can be created
  7.  */
  8. private Chat createChat(Message message) {
  9.   Jid from = message.getFrom();
  10.   // According to RFC6120 8.1.2.1 4. messages without a 'from' attribute are valid, but they
  11.   // are of no use in this case for ChatManager
  12.   if (from == null) {
  13.     return null;
  14.   }
  15.   EntityJid userJID = from.asEntityJidIfPossible();
  16.   if (userJID == null) {
  17.     LOGGER.warning("Message from JID without localpart: '" + message.toXML(null) + "'");
  18.     return null;
  19.   }
  20.   String threadID = message.getThread();
  21.   if (threadID == null) {
  22.     threadID = nextID();
  23.   }
  24.   return createChat(userJID, threadID, false);
  25. }

代码示例来源：origin: igniterealtime/Smack

  1. final Message message = (Message) stanza;
  2. EntityFullJid fullFrom = message.getFrom().asEntityFullJidIfPossible();
  3. EntityBareJid bareFrom = fullFrom.asEntityBareJid();

代码示例来源：origin: igniterealtime/Smack

  1. @Override
  2.   public void processStanza(final Stanza stanza) throws NotConnectedException, InterruptedException {
  3.     final Message wrappingMessage = (Message) stanza;
  4.     final CarbonExtension carbonExtension = CarbonExtension.from(wrappingMessage);
  5.     final Direction direction = carbonExtension.getDirection();
  6.     final Forwarded forwarded = carbonExtension.getForwarded();
  7.     final Message carbonCopy = (Message) forwarded.getForwardedStanza();
  8.     final BareJid from = carbonCopy.getFrom().asBareJid();
  9.     carbonsListenerAsyncButOrdered.performAsyncButOrdered(from, new Runnable() {
  10.       @Override
  11.       public void run() {
  12.         for (CarbonCopyReceivedListener listener : listeners) {
  13.           listener.onCarbonCopyReceived(direction, carbonCopy, wrappingMessage);
  14.         }
  15.       }
  16.     });
  17.   }
  18. };

代码示例来源：origin: igniterealtime/Smack

  1. /**
  2.    * Create and return a new message including a delivery receipt extension for the given message.
  3.    * <p>
  4.    * If {@code messageWithReceiptRequest} does not have a Stanza ID set, then {@code null} will be returned.
  5.    * </p>
  6.    *
  7.    * @param messageWithReceiptRequest the given message with a receipt request extension.
  8.    * @return a new message with a receipt or <code>null</code>.
  9.    * @since 4.1
  10.    */
  11.   public static Message receiptMessageFor(Message messageWithReceiptRequest) {
  12.     String stanzaId = messageWithReceiptRequest.getStanzaId();
  13.     if (StringUtils.isNullOrEmpty(stanzaId)) {
  14.       return null;
  15.     }
  16.     Message message = new Message(messageWithReceiptRequest.getFrom(), messageWithReceiptRequest.getType());
  17.     message.addExtension(new DeliveryReceipt(stanzaId));
  18.     return message;
  19.   }
  20. }

代码示例来源：origin: igniterealtime/Smack

  1. BareJid sender = carbonCopy.getFrom().asBareJid();

代码示例来源：origin: igniterealtime/Smack

  1. @Override
  2.   public void processStanza(Stanza packet) {
  3.     final Message message = (Message) packet;
  4.     // Get the MUCUser extension
  5.     final MUCUser mucUser = MUCUser.from(message);
  6.     // Check if the MUCUser extension includes an invitation
  7.     if (mucUser.getInvite() != null) {
  8.       EntityBareJid mucJid = message.getFrom().asEntityBareJidIfPossible();
  9.       if (mucJid == null) {
  10.         LOGGER.warning("Invite to non bare JID: '" + message.toXML(null) + "'");
  11.         return;
  12.       }
  13.       // Fire event for invitation listeners
  14.       final MultiUserChat muc = getMultiUserChat(mucJid);
  15.       final XMPPConnection connection = connection();
  16.       final MUCUser.Invite invite = mucUser.getInvite();
  17.       final EntityJid from = invite.getFrom();
  18.       final String reason = invite.getReason();
  19.       final String password = mucUser.getPassword();
  20.       for (final InvitationListener listener : invitationsListeners) {
  21.         listener.invitationReceived(connection, muc, from, reason, password, message, invite);
  22.       }
  23.     }
  24.   }
  25. };

代码示例来源：origin: igniterealtime/Smack

  1. BareJid bareFrom = friendMessage.getFrom().asBareJid();
  2. if (!friendshipDeniedCache.containsKey(bareFrom)) {
  3.   LOGGER.log(Level.WARNING, "Ignoring friendship recommendation "

代码示例来源：origin: igniterealtime/Smack

  1. WorkgroupInvitation inv = new WorkgroupInvitation(connection.getUser(), msg.getFrom(),
  2.     workgroupJID, sessionID, msg.getBody(),
  3.     msg.getFrom(), metaData);

代码示例来源：origin: igniterealtime/Smack

  1. @Test
  2. public void checkResultsParse() throws Exception {
  3.   Message message = PacketParserUtils.parseStanza(exampleResultMessage);
  4.   MamResultExtension mamResultExtension = MamResultExtension.from(message);
  5.   Assert.assertEquals(mamResultExtension.getQueryId(), "f27");
  6.   Assert.assertEquals(mamResultExtension.getId(), "28482-98726-73623");
  7.   GregorianCalendar calendar = new GregorianCalendar(2010, 7 - 1, 10, 23, 8, 25);
  8.   calendar.setTimeZone(TimeZone.getTimeZone("UTC"));
  9.   Date date = calendar.getTime();
  10.   Forwarded forwarded = mamResultExtension.getForwarded();
  11.   Assert.assertEquals(forwarded.getDelayInformation().getStamp(), date);
  12.   Message forwardedMessage = (Message) forwarded.getForwardedStanza();
  13.   Assert.assertEquals(forwardedMessage.getFrom().toString(), "witch@shakespeare.lit");
  14.   Assert.assertEquals(forwardedMessage.getTo().toString(), "macbeth@shakespeare.lit");
  15.   Assert.assertEquals(forwardedMessage.getBody(), "Hail to thee");
  16. }

代码示例来源：origin: igniterealtime/Smack

  1. @Test
  2. public void checkMamResultProvider() throws Exception {
  3.   XmlPullParser parser = PacketParserUtils.getParserFor(exampleMamResultXml);
  4.   MamResultExtension mamResultExtension = new MamResultProvider().parse(parser);
  5.   Assert.assertEquals(mamResultExtension.getQueryId(), "f27");
  6.   Assert.assertEquals(mamResultExtension.getId(), "28482-98726-73623");
  7.   GregorianCalendar calendar = new GregorianCalendar(2010, 7 - 1, 10, 23, 8, 25);
  8.   calendar.setTimeZone(TimeZone.getTimeZone("UTC"));
  9.   Date date = calendar.getTime();
  10.   Forwarded forwarded = mamResultExtension.getForwarded();
  11.   Assert.assertEquals(forwarded.getDelayInformation().getStamp(), date);
  12.   Message message = (Message) forwarded.getForwardedStanza();
  13.   Assert.assertEquals(message.getFrom().toString(), "romeo@montague.lit/orchard");
  14.   Assert.assertEquals(message.getTo().toString(), "juliet@capulet.lit/balcony");
  15.   Assert.assertEquals(message.getBody(),
  16.       "Call me but love, and I'll be new baptized; Henceforth I never will be Romeo.");
  17. }

代码示例来源：origin: igniterealtime/Smack

  1. assertEquals(conOne.getUser(), mamMessage.getFrom());
  2. assertEquals(userTwo, mamMessage.getTo());

代码示例来源：origin: igniterealtime/Smack

  1. @Test
  2. public void checkMamQueryResults() throws Exception {
  3.   Message message = new Message();
  4.   message.setStanzaId("iasd207");
  5.   message.setFrom(JidCreate.from("coven@chat.shakespeare.lit"));
  6.   message.setTo(JidCreate.from("hag66@shakespeare.lit/pda"));
  7.   GregorianCalendar calendar = new GregorianCalendar(2002, 10 - 1, 13, 23, 58, 37);
  8.   calendar.setTimeZone(TimeZone.getTimeZone("UTC"));
  9.   Date date = calendar.getTime();
  10.   DelayInformation delay = new DelayInformation(date);
  11.   Message forwardedMessage = new Message();
  12.   forwardedMessage.setFrom(JidCreate.from("coven@chat.shakespeare.lit/firstwitch"));
  13.   forwardedMessage.setStanzaId("162BEBB1-F6DB-4D9A-9BD8-CFDCC801A0B2");
  14.   forwardedMessage.setType(Type.chat);
  15.   forwardedMessage.setBody("Thrice the brinded cat hath mew.");
  16.   Forwarded forwarded = new Forwarded(delay, forwardedMessage);
  17.   message.addExtension(new MamResultExtension("g27", "34482-21985-73620", forwarded));
  18.   // FIXME: The order of assertEquals is reversed, fix it by switching it.
  19.   Assert.assertEquals(message.toXML(StreamOpen.CLIENT_NAMESPACE).toString(), mamQueryResultExample);
  20.   MamResultExtension mamResultExtension = MamResultExtension.from(message);
  21.   Assert.assertEquals(mamResultExtension.getId(), "34482-21985-73620");
  22.   Assert.assertEquals(mamResultExtension.getForwarded().getDelayInformation().getStamp(), date);
  23.   Message resultMessage = (Message) mamResultExtension.getForwarded().getForwardedStanza();
  24.   Assert.assertEquals(resultMessage.getFrom(), JidCreate.from("coven@chat.shakespeare.lit/firstwitch"));
  25.   Assert.assertEquals(resultMessage.getStanzaId(), "162BEBB1-F6DB-4D9A-9BD8-CFDCC801A0B2");
  26.   Assert.assertEquals(resultMessage.getType(), Type.chat);
  27.   Assert.assertEquals(resultMessage.getBody(), "Thrice the brinded cat hath mew.");
  28. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Message类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com