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

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

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

Message.getTo介绍

暂无

代码示例

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

  1. @Override
  2.   public void processStanza(Stanza stanza) throws NotConnectedException, InterruptedException {
  3.     Message message = (Message) stanza;
  4.     if (!shouldAcceptMessage(message)) {
  5.       return;
  6.     }
  7.     final EntityBareJid to = message.getTo().asEntityBareJidOrThrow();
  8.     final Chat chat = chatWith(to);
  9.     for (OutgoingChatMessageListener listener : outgoingListeners) {
  10.       listener.newOutgoingMessage(to, message, chat);
  11.     }
  12.   }
  13. }, OUTGOING_MESSAGE_FILTER);

代码示例来源：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(messageBody, mamMessage.getBody());
  2. assertEquals(conOne.getUser(), mamMessage.getFrom());
  3. assertEquals(userTwo, mamMessage.getTo());

代码示例来源：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: spring-projects/spring-integration

  1. @Test //INT-2275
  2. public void testOutboundChannelAdapterInsideChain() throws Exception {
  3.   MessageChannel channel = context.getBean("outboundChainChannel", MessageChannel.class);
  4.   Message<?> message = MessageBuilder.withPayload("hello").setHeader(XmppHeaders.TO, "artem").build();
  5.   XMPPConnection connection = context.getBean("testConnection", XMPPConnection.class);
  6.   doAnswer(invocation -> {
  7.     Object[] args = invocation.getArguments();
  8.     org.jivesoftware.smack.packet.Message xmppMessage = (org.jivesoftware.smack.packet.Message) args[0];
  9.     assertEquals("artem", xmppMessage.getTo().toString());
  10.     assertEquals("hello", xmppMessage.getBody());
  11.     return null;
  12.   }).when(connection).sendStanza(Mockito.any(org.jivesoftware.smack.packet.Message.class));
  13.   channel.send(message);
  14.   verify(connection, times(1)).sendStanza(Mockito.any(org.jivesoftware.smack.packet.Message.class));
  15.   Mockito.reset(connection);
  16. }

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

  1. @SuppressWarnings("rawtypes")
  2. @Test
  3. public void withHeaderMapper() throws Exception {
  4.   Object pollingConsumer = context.getBean("withHeaderMapper");
  5.   assertTrue(pollingConsumer instanceof PollingConsumer);
  6.   assertEquals(headerMapper, TestUtils.getPropertyValue(pollingConsumer, "handler.headerMapper"));
  7.   MessageChannel channel = context.getBean("outboundEventChannel", MessageChannel.class);
  8.   Message<?> message = MessageBuilder.withPayload("hello").setHeader(XmppHeaders.TO, "oleg").
  9.       setHeader("foobar", "foobar").build();
  10.   XMPPConnection connection = context.getBean("testConnection", XMPPConnection.class);
  11.   doAnswer(invocation -> {
  12.     Object[] args = invocation.getArguments();
  13.     org.jivesoftware.smack.packet.Message xmppMessage = (org.jivesoftware.smack.packet.Message) args[0];
  14.     assertEquals("oleg", xmppMessage.getTo().toString());
  15.     assertEquals("foobar", JivePropertiesManager.getProperty(xmppMessage, "foobar"));
  16.     return null;
  17.   }).when(connection).sendStanza(Mockito.any(org.jivesoftware.smack.packet.Message.class));
  18.   channel.send(message);
  19.   verify(connection, times(1)).sendStanza(Mockito.any(org.jivesoftware.smack.packet.Message.class));
  20.   Mockito.reset(connection);
  21. }

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

  1. @Test
  2. public void testExtensionProvider() throws Exception {
  3.   XMPPConnection connection = mock(XMPPConnection.class);
  4.   ChatMessageSendingMessageHandler handler = new ChatMessageSendingMessageHandler(connection);
  5.   GcmExtensionProvider extensionElementProvider = spy(new GcmExtensionProvider());
  6.   handler.setExtensionProvider(extensionElementProvider);
  7.   handler.setBeanFactory(mock(BeanFactory.class));
  8.   handler.afterPropertiesSet();
  9.   final String json = "{\"foo\": \"bar\"}";
  10.   Message<?> message = MessageBuilder.withPayload("  <f foo='foo'>" + json + "</f>  ")
  11.       .setHeader(XmppHeaders.TO, "kermit@frog.com")
  12.       .build();
  13.   handler.handleMessage(message);
  14.   ArgumentCaptor<org.jivesoftware.smack.packet.Message> argumentCaptor =
  15.       ArgumentCaptor.forClass(org.jivesoftware.smack.packet.Message.class);
  16.   verify(connection).sendStanza(argumentCaptor.capture());
  17.   org.jivesoftware.smack.packet.Message smackMessage = argumentCaptor.getValue();
  18.   assertNull(smackMessage.getBody());
  19.   assertEquals("kermit@frog.com", smackMessage.getTo().toString());
  20.   GcmPacketExtension gcmPacketExtension = GcmPacketExtension.from(smackMessage);
  21.   assertNotNull(gcmPacketExtension);
  22.   assertEquals(json, gcmPacketExtension.getJson());
  23.   verify(extensionElementProvider).from(eq(json));
  24. }

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

  1. .sendStanza(Mockito.argThat((org.jivesoftware.smack.packet.Message smackMessage) -> {
  2.   boolean bodyMatches = smackMessage.getBody().equals("Test Message");
  3.   boolean toMatches = smackMessage.getTo().equals("kermit@frog.com");
  4.   return bodyMatches & toMatches;
  5. }));
  6. .sendStanza(Mockito.argThat((org.jivesoftware.smack.packet.Message smackMessage) -> {
  7.   boolean bodyMatches = smackMessage.getBody().equals("Hello Kitty");
  8.   boolean toMatches = smackMessage.getTo().equals("kermit@frog.com");
  9.   boolean threadIdMatches = smackMessage.getThread().equals("123");
  10.   return bodyMatches & toMatches & threadIdMatches;
  11. .sendStanza(Mockito.argThat((org.jivesoftware.smack.packet.Message smackMessage) -> {
  12.   boolean bodyMatches = smackMessage.getBody() == null;
  13.   boolean toMatches = smackMessage.getTo().equals("kermit@frog.com");
  14.   GcmPacketExtension gcmPacketExtension = GcmPacketExtension.from(smackMessage);
  15.   boolean jsonMatches = gcmPacketExtension != null && gcmPacketExtension.getJson().equals(json);

代码示例来源：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.getTo());
  2. assertNull(target.getFrom());
  3. assertNull(target.getSubject());

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

  1. /**
  2.  * Converts the given XMPP destination into a {@code xmpp} URI.
  3.  */
  4. public static URI toUri(Message requestMessage) throws URISyntaxException {
  5.   return new URI(XmppTransportConstants.XMPP_URI_SCHEME,
  6.       requestMessage.getTo().asUnescapedString(), null);
  7. }

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

  1. /**
  2.  * Converts the given XMPP destination into a {@code xmpp} URI.
  3.  */
  4. public static URI toUri(Message requestMessage) throws URISyntaxException {
  5.   return new URI(XmppTransportConstants.XMPP_URI_SCHEME,
  6.       requestMessage.getTo().asUnescapedString(), null);
  7. }

代码示例来源：origin: apache/servicemix-bundles

  1. /**
  2.  * Converts the given XMPP destination into a {@code xmpp} URI.
  3.  */
  4. public static URI toUri(Message requestMessage) throws URISyntaxException {
  5.   return new URI(XmppTransportConstants.XMPP_URI_SCHEME,
  6.       requestMessage.getTo().asUnescapedString(), null);
  7. }

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

  1. public void fireOutgoingMessageSending( Message message )
  2. {
  3.   for ( final MessageEventListener listener : messageEventListeners )
  4.   {
  5.     try
  6.     {
  7.       listener.sendingMessage( message );
  8.     }
  9.     catch ( Exception e )
  10.     {
  11.       Log.error( "A MessageEventListener ('" + listener + "') threw an exception while processing an outgoing message (to '" + message.getTo() + "').", e );
  12.     }
  13.   }
  14. }

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

  1. /**
  2.  * Notifies all <code>GlobalMessageListeners</code> of a new message sent.
  3.  *
  4.  * @param chatRoom the <code>ChatRoom</code> where the message was sent from.
  5.  * @param message  the <code>Message</code> sent.
  6.  */
  7. public void fireGlobalMessageSentListeners( ChatRoom chatRoom, Message message )
  8. {
  9.   for ( GlobalMessageListener listener : globalMessageListeners )
  10.   {
  11.     try
  12.     {
  13.       listener.messageSent( chatRoom, message );
  14.     }
  15.     catch ( Exception e )
  16.     {
  17.       Log.error( "A GlobalMessageListener ('" + listener + "') threw an exception while processing an outgoing chat message (to '" + message.getTo() + "') in a chat room ('" + chatRoom + "').", e );
  18.     }
  19.   }
  20. }

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

  1. public Object answer(InvocationOnMock invocation) {
  2.   Object[] args = invocation.getArguments();
  3.   org.jivesoftware.smack.packet.Message xmppMessage = (org.jivesoftware.smack.packet.Message) args[0];
  4.   assertEquals("artem", xmppMessage.getTo());
  5.   assertEquals("hello", xmppMessage.getBody());
  6.   return null;
  7. }

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

  1. public Object answer(InvocationOnMock invocation) {
  2.     Object[] args = invocation.getArguments();
  3.     org.jivesoftware.smack.packet.Message xmppMessage = (org.jivesoftware.smack.packet.Message) args[0];
  4.     assertEquals("oleg", xmppMessage.getTo());
  5.     assertEquals("foobar", JivePropertiesManager.getProperty(xmppMessage, "foobar"));
  6.     return null;
  7.   }
  8. })

代码示例来源：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: igniterealtime/Spark

  1. private void checkEvents(Jid from, String packetID, MessageEvent messageEvent) {
  2.   if (messageEvent.isDelivered() || messageEvent.isDisplayed()) {
  3.     // Create the message to send
  4.     Message msg = new Message(from);
  5.     // Create a MessageEvent Package and add it to the message
  6.     MessageEvent event = new MessageEvent();
  7.     if (messageEvent.isDelivered()) {
  8.       event.setDelivered(true);
  9.     }
  10.     if (messageEvent.isDisplayed()) {
  11.       event.setDisplayed(true);
  12.     }
  13.     event.setStanzaId(packetID);
  14.     msg.addExtension(event);
  15.     // Send the packet
  16.     try
  17.     {
  18.       SparkManager.getConnection().sendStanza(msg);
  19.     }
  20.     catch ( SmackException.NotConnectedException | InterruptedException e )
  21.     {
  22.       Log.warning( "Unable to send message to " + msg.getTo(), e );
  23.     }
  24.   }
  25. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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