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

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

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

Message.getType介绍

[英]Returns the type of the message. If no type has been set this method will return Type#normal.
[中]返回消息的类型。如果未设置类型，此方法将返回类型#normal。

代码示例

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

  1. @Override
  2.   public void processStanza(Stanza packet) {
  3.     Message message = (Message) packet;
  4.     // if it's not an error message, reset the idle time
  5.     if (message.getType() == Message.Type.error) return;
  6.     resetIdleTime();
  7.   }
  8. }, StanzaTypeFilter.MESSAGE);

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

  1. @Override
  2. protected boolean acceptSpecific(Message message) {
  3.   return message.getType() == type;
  4. }

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

  1. @Override
  2. protected boolean acceptSpecific(Message message) {
  3.   return normalIncluded ? message.getType() == Type.normal : false;
  4. }

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

  1. public void send(Message message) throws NotConnectedException, InterruptedException {
  2.   switch (message.getType()) {
  3.   case normal:
  4.   case chat:
  5.     break;
  6.   default:
  7.     throw new IllegalArgumentException("Message must be of type 'normal' or 'chat'");
  8.   }
  9.   Jid to = lockedResource;
  10.   if (to == null) {
  11.     to = jid;
  12.   }
  13.   message.setTo(to);
  14.   connection().sendStanza(message);
  15. }

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

  1. packetTypeIcon = messagePacketIcon;
  2. messageType = "Message Received";
  3. type = ((Message) packet).getType().toString();
  4. receivedMessagePackets++;

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

  1. packetTypeIcon = messagePacketIcon;
  2. messageType = "Message Sent";
  3. type = ((Message) packet).getType().toString();
  4. sentMessagePackets++;

代码示例来源：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. @Test
  2. public void setMessageTypeTest() throws IOException, SAXException {
  3.   Message.Type type = Message.Type.chat;
  4.   Message.Type type2 = Message.Type.headline;
  5.   StringBuilder controlBuilder = new StringBuilder();
  6.   controlBuilder.append("<message")
  7.       .append(" type=\"")
  8.       .append(type)
  9.       .append("\">")
  10.       .append("</message>");
  11.   String control = controlBuilder.toString();
  12.   Message messageTypeInConstructor = new Message(null, Message.Type.chat);
  13.   messageTypeInConstructor.setStanzaId(null);
  14.   assertEquals(type, messageTypeInConstructor.getType());
  15.   assertXMLEqual(control, messageTypeInConstructor.toXML(StreamOpen.CLIENT_NAMESPACE).toString());
  16.   controlBuilder = new StringBuilder();
  17.   controlBuilder.append("<message")
  18.       .append(" type=\"")
  19.       .append(type2)
  20.       .append("\">")
  21.       .append("</message>");
  22.   control = controlBuilder.toString();
  23.   Message messageTypeSet = getNewMessage();
  24.   messageTypeSet.setType(type2);
  25.   assertEquals(type2, messageTypeSet.getType());
  26.   assertXMLEqual(control, messageTypeSet.toXML(StreamOpen.CLIENT_NAMESPACE).toString());
  27. }

代码示例来源：origin: spring-projects/spring-integration

  1. @Override
  2. protected Map<String, Object> extractStandardHeaders(Message source) {
  3.   Map<String, Object> headers = new HashMap<>();
  4.   Jid from = source.getFrom();
  5.   if (from != null) {
  6.     headers.put(XmppHeaders.FROM, from.toString());
  7.   }
  8.   String subject = source.getSubject();
  9.   if (StringUtils.hasText(subject)) {
  10.     headers.put(XmppHeaders.SUBJECT, subject);
  11.   }
  12.   String thread = source.getThread();
  13.   if (StringUtils.hasText(thread)) {
  14.     headers.put(XmppHeaders.THREAD, thread);
  15.   }
  16.   Jid to = source.getTo();
  17.   if (to != null) {
  18.     headers.put(XmppHeaders.TO, to.toString());
  19.   }
  20.   Message.Type type = source.getType();
  21.   if (type != null) {
  22.     headers.put(XmppHeaders.TYPE, type);
  23.   }
  24.   return headers;
  25. }

代码示例来源：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. }

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

  1. public boolean accept(Packet packet) {
  2.     if (!(packet instanceof Message)) {
  3.       return false;
  4.     }
  5.     Message.Type messageType = ((Message) packet).getType();
  6.     return messageType != Message.Type.groupchat &&
  7.         messageType != Message.Type.headline;
  8.   }
  9. };

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

  1. public boolean accept(Packet packet) {
  2.     if (!(packet instanceof Message)) {
  3.       return false;
  4.     }
  5.     Message.Type messageType = ((Message) packet).getType();
  6.     return messageType != Message.Type.groupchat &&
  7.         messageType != Message.Type.headline;
  8.   }
  9. };

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

  1. public boolean accept(Packet packet) {
  2.     Message msg = (Message)packet;
  3.     return msg.getType() == Message.Type.GROUP_CHAT;
  4.   }
  5. });

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

  1. public boolean accept(Packet packet) {
  2.     if (!(packet instanceof Message)) {
  3.       return false;
  4.     }
  5.     Message.Type messageType = ((Message) packet).getType();
  6.     return messageType != Message.Type.groupchat &&
  7.         messageType != Message.Type.headline;
  8.   }
  9. };

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

  1. public boolean accept(Packet packet) {
  2.   if (!(packet instanceof Message)) {
  3.     return false;
  4.   }
  5.   else {
  6.     return ((Message) packet).getType().equals(this.type);
  7.   }
  8. }

代码示例来源：origin: spring-projects/spring-integration

  1. @Test
  2. public void fromHeadersStandardOutbound() {
  3.   DefaultXmppHeaderMapper mapper = new DefaultXmppHeaderMapper();
  4.   Map<String, Object> headerMap = new HashMap<>();
  5.   headerMap.put("userDefined1", "foo");
  6.   headerMap.put("userDefined2", "bar");
  7.   headerMap.put(XmppHeaders.THREAD, "test.thread");
  8.   headerMap.put(XmppHeaders.TO, "test.to");
  9.   headerMap.put(XmppHeaders.FROM, "test.from");
  10.   headerMap.put(XmppHeaders.SUBJECT, "test.subject");
  11.   headerMap.put(XmppHeaders.TYPE, "headline");
  12.   MessageHeaders headers = new MessageHeaders(headerMap);
  13.   Message target = new Message();
  14.   mapper.fromHeadersToRequest(headers, target);
  15.   // "standard" XMPP headers
  16.   assertEquals("test.thread", target.getThread());
  17.   assertEquals("test.to", target.getTo().toString());
  18.   assertEquals("test.from", target.getFrom().toString());
  19.   assertEquals("test.subject", target.getSubject());
  20.   assertEquals(Message.Type.headline, target.getType());
  21.   // user-defined headers not included by default
  22.   assertNull(JivePropertiesManager.getProperty(target, "userDefined1"));
  23.   assertNull(JivePropertiesManager.getProperty(target, "userDefined2"));
  24.   // transient headers should not be copied
  25.   assertNull(JivePropertiesManager.getProperty(target, "id"));
  26.   assertNull(JivePropertiesManager.getProperty(target, "timestamp"));
  27. }

代码示例来源：origin: spring-projects/spring-integration

  1. assertNull(target.getFrom());
  2. assertNull(target.getSubject());
  3. assertEquals(Message.Type.normal, target.getType());

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

  1. public boolean accept(Packet packet) {
  2.   if (!(packet instanceof Message)) {
  3.     return false;
  4.   }
  5.   else {
  6.     return ((Message) packet).getType().equals(this.type);
  7.   }
  8. }

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

  1. public boolean accept(Packet packet) {
  2.   if (!(packet instanceof Message)) {
  3.     return false;
  4.   }
  5.   else {
  6.     return ((Message) packet).getType().equals(this.type);
  7.   }
  8. }

代码示例来源：origin: org.springframework.ws/spring-ws-support

  1. public static String getErrorMessage(Message message) {
  2.   if (message == null || !Message.Type.error.equals(message.getType())) {
  3.     return null;
  4.   }
  5.   else {
  6.     return message.getBody();
  7.   }
  8. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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