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

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

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

Message.setFrom介绍

暂无

代码示例

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

  1. private static Message createChatPacket(final String threadId, final boolean isEntityFullJid) {
  2.   Message chatMsg = new Message(JidTestUtil.BARE_JID_1, Message.Type.chat);
  3.   chatMsg.setBody("the body message - " + System.currentTimeMillis());
  4.   Jid jid;
  5.   if (isEntityFullJid) {
  6.     jid = JidTestUtil.DUMMY_AT_EXAMPLE_ORG_SLASH_DUMMYRESOURCE;
  7.   } else {
  8.     jid = JidTestUtil.DUMMY_AT_EXAMPLE_ORG;
  9.   }
  10.   chatMsg.setFrom(jid);
  11.   chatMsg.setThread(threadId);
  12.   return chatMsg;
  13. }

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

  1. message.setStanzaId(parser.getAttributeValue("", "id"));
  2. message.setTo(ParserUtils.getJidAttribute(parser, "to"));
  3. message.setFrom(ParserUtils.getJidAttribute(parser, "from"));
  4. String typeString = parser.getAttributeValue("", "type");
  5. if (typeString != null) {

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

  1. /**
  2.  * Send a ratchet update message. This can be used to advance the ratchet of a session in order to maintain forward
  3.  * secrecy.
  4.  *
  5.  * @param recipient recipient
  6.  * @throws CorruptedOmemoKeyException           When the used identityKeys are corrupted
  7.  * @throws CryptoFailedException                When something fails with the crypto
  8.  * @throws CannotEstablishOmemoSessionException When we can't establish a session with the recipient
  9.  * @throws SmackException.NotLoggedInException
  10.  * @throws InterruptedException
  11.  * @throws SmackException.NoResponseException
  12.  * @throws NoSuchAlgorithmException
  13.  * @throws SmackException.NotConnectedException
  14.  */
  15. public void sendRatchetUpdateMessage(OmemoDevice recipient)
  16.     throws SmackException.NotLoggedInException, CorruptedOmemoKeyException, InterruptedException,
  17.     SmackException.NoResponseException, NoSuchAlgorithmException, SmackException.NotConnectedException,
  18.     CryptoFailedException, CannotEstablishOmemoSessionException {
  19.   synchronized (LOCK) {
  20.     Message message = new Message();
  21.     message.setFrom(getOwnJid());
  22.     message.setTo(recipient.getJid());
  23.     OmemoElement element = getOmemoService()
  24.         .createRatchetUpdateElement(new LoggedInOmemoManager(this), recipient);
  25.     message.addExtension(element);
  26.     // Set MAM Storage hint
  27.     StoreHint.set(message);
  28.     connection().sendStanza(message);
  29.   }
  30. }

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

  1. @Test
  2. public void receiptManagerListenerTest() throws Exception {
  3.   DummyConnection c = new DummyConnection();
  4.   c.connect();
  5.   DeliveryReceiptManager drm = DeliveryReceiptManager.getInstanceFor(c);
  6.   TestReceiptReceivedListener rrl = new TestReceiptReceivedListener();
  7.   drm.addReceiptReceivedListener(rrl);
  8.   Message m = new Message(JidCreate.from("romeo@montague.com"), Message.Type.normal);
  9.   m.setFrom(JidCreate.from("julia@capulet.com"));
  10.   m.setStanzaId("reply-id");
  11.   m.addExtension(new DeliveryReceipt("original-test-id"));
  12.   c.processStanza(m);
  13.   rrl.waitUntilInvocationOrTimeout();
  14. }

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

  1. @Test
  2.   public void receiptManagerAutoReplyTest() throws Exception {
  3.     DummyConnection c = new DummyConnection();
  4.     c.connect();
  5.     DeliveryReceiptManager drm = DeliveryReceiptManager.getInstanceFor(c);
  7.     drm.setAutoReceiptMode(AutoReceiptMode.always);
  8.     assertEquals(AutoReceiptMode.always, drm.getAutoReceiptMode());
  10.     // test auto-receipts
  11.     Message m = new Message(JidCreate.from("julia@capulet.com"), Message.Type.normal);
  12.     m.setFrom(JidCreate.from("romeo@montague.com"));
  13.     m.setStanzaId("test-receipt-request");
  14.     DeliveryReceiptRequest.addTo(m);
  16.     // the DRM will send a reply-packet
  17.     c.processStanza(m);
  19.     Stanza reply = c.getSentPacket();
  20.     DeliveryReceipt r = DeliveryReceipt.from((Message) reply);
  21.     assertThat("romeo@montague.com", equalsCharSequence(reply.getTo()));
  22.     assertEquals("test-receipt-request", r.getId());
  23.   }
  24. }

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

  1. if (StringUtils.hasText(from)) {
  2.   try {
  3.     target.setFrom(JidCreate.from(from));

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

  1. @Test
  2. public void toHeadersStandardOnly() throws XmppStringprepException {
  3.   DefaultXmppHeaderMapper mapper = new DefaultXmppHeaderMapper();
  4.   Message source = new Message(JidCreate.from("test.to"), Message.Type.headline);
  5.   source.setFrom(JidCreate.from("test.from"));
  6.   source.setSubject("test.subject");
  7.   source.setThread("test.thread");
  8.   JivePropertiesManager.addProperty(source, "userDefined1", "foo");
  9.   JivePropertiesManager.addProperty(source, "userDefined2", "bar");
  10.   Map<String, Object> headers = mapper.toHeadersFromRequest(source);
  11.   assertEquals("test.to", headers.get(XmppHeaders.TO).toString());
  12.   assertEquals("test.from", headers.get(XmppHeaders.FROM).toString());
  13.   assertEquals("test.subject", headers.get(XmppHeaders.SUBJECT));
  14.   assertEquals("test.thread", headers.get(XmppHeaders.THREAD));
  15.   assertEquals(Message.Type.headline, headers.get(XmppHeaders.TYPE));
  16.   assertNull(headers.get("userDefined1"));
  17.   assertNull(headers.get("userDefined2"));
  18. }

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

  1. @Test
  2. public void toHeadersUserDefinedOnly() throws XmppStringprepException {
  3.   DefaultXmppHeaderMapper mapper = new DefaultXmppHeaderMapper();
  4.   mapper.setReplyHeaderNames("userDefined*");
  5.   Message source = new Message(JidCreate.from("test.to"), Message.Type.headline);
  6.   source.setFrom(JidCreate.from("test.from"));
  7.   source.setSubject("test.subject");
  8.   source.setThread("test.thread");
  9.   JivePropertiesManager.addProperty(source, "userDefined1", "foo");
  10.   JivePropertiesManager.addProperty(source, "userDefined2", "bar");
  11.   Map<String, Object> headers = mapper.toHeadersFromReply(source);
  12.   assertNull(headers.get(XmppHeaders.TO));
  13.   assertNull(headers.get(XmppHeaders.FROM));
  14.   assertNull(headers.get(XmppHeaders.SUBJECT));
  15.   assertNull(headers.get(XmppHeaders.THREAD));
  16.   assertNull(headers.get(XmppHeaders.TYPE));
  17.   assertEquals("foo", headers.get("userDefined1"));
  18.   assertEquals("bar", headers.get("userDefined2"));
  19. }

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

  1. @Override
  2. protected void onSendAfterWrite(WebServiceMessage message) throws IOException {
  3.   requestMessage.setFrom(connection.getUser());
  4.   try {
  5.     connection.sendStanza(requestMessage);
  6.   } catch (SmackException.NotConnectedException e) {
  7.     throw new IOException(e);
  8.   } catch (InterruptedException e) {
  9.     throw new IOException(e);
  10.   }
  11. }

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

  1. @Override
  2. protected void onSendAfterWrite(WebServiceMessage message) throws IOException {
  3.   requestMessage.setFrom(connection.getUser());
  4.   try {
  5.     connection.sendStanza(requestMessage);
  6.   } catch (SmackException.NotConnectedException e) {
  7.     throw new IOException(e);
  8.   } catch (InterruptedException e) {
  9.     throw new IOException(e);
  10.   }
  11. }

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

  1. @Override
  2. protected void onSendAfterWrite(WebServiceMessage message) throws IOException {
  3.   requestMessage.setFrom(connection.getUser());
  4.   try {
  5.     connection.sendStanza(requestMessage);
  6.   } catch (SmackException.NotConnectedException e) {
  7.     throw new IOException(e);
  8.   } catch (InterruptedException e) {
  9.     throw new IOException(e);
  10.   }
  11. }

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

  1. void sendMessage(Chat chat, Message message) {
  2.   for(Map.Entry<PacketInterceptor, PacketFilter> interceptor : interceptors.entrySet()) {
  3.     PacketFilter filter = interceptor.getValue();
  4.     if(filter != null && filter.accept(message)) {
  5.       interceptor.getKey().interceptPacket(message);
  6.     }
  7.   }
  8.   // Ensure that messages being sent have a proper FROM value
  9.   if (message.getFrom() == null) {
  10.     message.setFrom(connection.getUser());
  11.   }
  12.   connection.sendPacket(message);
  13. }

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

  1. void sendMessage(Chat chat, Message message) {
  2.   for(Map.Entry<PacketInterceptor, PacketFilter> interceptor : interceptors.entrySet()) {
  3.     PacketFilter filter = interceptor.getValue();
  4.     if(filter != null && filter.accept(message)) {
  5.       interceptor.getKey().interceptPacket(message);
  6.     }
  7.   }
  8.   // Ensure that messages being sent have a proper FROM value
  9.   if (message.getFrom() == null) {
  10.     message.setFrom(connection.getUser());
  11.   }
  12.   connection.sendPacket(message);
  13. }

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

  1. void sendMessage(Chat chat, Message message) {
  2.   for(Map.Entry<PacketInterceptor, PacketFilter> interceptor : interceptors.entrySet()) {
  3.     PacketFilter filter = interceptor.getValue();
  4.     if(filter != null && filter.accept(message)) {
  5.       interceptor.getKey().interceptPacket(message);
  6.     }
  7.   }
  8.   // Ensure that messages being sent have a proper FROM value
  9.   if (message.getFrom() == null) {
  10.     message.setFrom(connection.getUser());
  11.   }
  12.   connection.sendPacket(message);
  13. }

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

  1. /**
  2.  * Adds a new message to the transcript history.
  3.  *
  4.  * @param to   who the message is to.
  5.  * @param from who the message was from.
  6.  * @param body the body of the message.
  7.  * @param date when the message was received.
  8.  */
  9. public void addToTranscript(String to, String from, String body, Date date) {
  10.   final Message newMessage = new Message();
  11.   newMessage.setTo(to);
  12.   newMessage.setFrom(from);
  13.   newMessage.setBody(body);
  14.   final Map<String, Object> properties = new HashMap<>();
  15.   properties.put( "date", new Date() );
  16.   newMessage.addExtension( new JivePropertiesExtension( properties ) );
  17.   transcript.add(newMessage);
  18. }

代码示例来源：origin: loldevs/riotapi

  1. public void sendToUser(String to, String message) throws Exception {
  2.   Message packet = new Message(to);
  3.   packet.setBody(message);
  4.   packet.setType(Message.Type.chat);
  5.   packet.setFrom(getUser().split("/")[0]);
  6.   sendPacket(packet);
  7. }

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

  1. @Override
  2. protected void onSendBeforeWrite(WebServiceMessage message) throws IOException {
  3.   responseMessage = new Message(requestMessage.getFrom(), Message.Type.chat);
  4.   responseMessage.setFrom(connection.getUser());
  5.   responseMessage.setThread(requestMessage.getThread());
  6. }

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

  1. @Override
  2. protected void onSendBeforeWrite(WebServiceMessage message) throws IOException {
  3.   responseMessage = new Message(requestMessage.getFrom(), Message.Type.chat);
  4.   responseMessage.setFrom(connection.getUser());
  5.   responseMessage.setThread(requestMessage.getThread());
  6. }

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

  1. @Override
  2. protected void onSendBeforeWrite(WebServiceMessage message) throws IOException {
  3.   responseMessage = new Message(requestMessage.getFrom(), Message.Type.chat);
  4.   responseMessage.setFrom(connection.getUser());
  5.   responseMessage.setThread(requestMessage.getThread());
  6. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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