javax.mail.Message.setFlag()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(13.6k)|赞(0)|评价(0)|浏览(332)

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

Message.setFlag介绍

[英]Set the specified flag on this message to the specified value. This will result in a MessageChangedEvent being delivered to any MessageChangedListener registered on this Message's containing folder.

The default implementation uses the setFlags method.
[中]将此消息上的指定标志设置为指定值。这将导致MessageChangedEvent被传递到在此邮件包含文件夹中注册的任何MessageChangedListener。
默认实现使用setFlags方法。

代码示例

代码示例来源：origin: apache/nifi

  1. emailMessage.setFlag(Flags.Flag.DELETED, this.shouldSetDeleteFlag);
  2. } catch (MessagingException e) {
  3.   this.logger.warn("Failed to set DELETE Flag on the message, data duplication may occur.");

代码示例来源：origin: oblac/jodd

  1. msg.setFlag(Flags.Flag.SEEN, false);

代码示例来源：origin: pentaho/pentaho-kettle

  1. /**
  2.  * PDI-10942 - Job get emails JobEntry does not mark emails as 'read' when load emails content.
  3.  *
  4.  * Test that we always open remote folder in rw mode, and after email attachment is loaded email is marked as read.
  5.  * Set for openFolder rw mode if this is pop3.
  6.  *
  7.  * @throws KettleException
  8.  * @throws MessagingException
  9.  */
  10. @Test
  11. public void testFetchOneFolderModePop3() throws KettleException, MessagingException {
  12.  entry.fetchOneFolder( mailConn, true, "junitImapFolder", "junitRealOutputFolder", "junitTargetAttachmentFolder",
  13.    "junitRealMoveToIMAPFolder", "junitRealFilenamePattern", 0, Mockito.mock( SimpleDateFormat.class ) );
  14.  Mockito.verify( mailConn ).openFolder( true );
  15.  Mockito.verify( message ).setFlag( Flag.SEEN, true );
  16. }

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

  1. private void setMessageFlags(Message[] filteredMessages) throws MessagingException {
  2.   boolean recentFlagSupported = false;
  3.   Flags flags = getFolder().getPermanentFlags();
  4.   if (flags != null) {
  5.     recentFlagSupported = flags.contains(Flags.Flag.RECENT);
  6.   }
  7.   for (Message message : filteredMessages) {
  8.     if (!recentFlagSupported) {
  9.       if (flags != null && flags.contains(Flags.Flag.USER)) {
  10.         if (this.logger.isDebugEnabled()) {
  11.           this.logger.debug("USER flags are supported by this mail server. Flagging message with '"
  12.               + this.userFlag + "' user flag");
  13.         }
  14.         Flags siFlags = new Flags();
  15.         siFlags.add(this.userFlag);
  16.         message.setFlags(siFlags, true);
  17.       }
  18.       else {
  19.         this.logger.debug("USER flags are not supported by this mail server. " +
  20.             "Flagging message with system flag");
  21.         message.setFlag(Flags.Flag.FLAGGED, true);
  22.       }
  23.     }
  24.     setAdditionalFlags(message);
  25.   }
  26. }

代码示例来源：origin: pentaho/pentaho-kettle

  1. /**
  2.  * PDI-10942 - Job get emails JobEntry does not mark emails as 'read' when load emails content.
  3.  *
  4.  * Test that we always open remote folder in rw mode, and after email attachment is loaded email is marked as read.
  5.  * protocol IMAP and default remote folder is overridden
  6.  *
  7.  * @throws KettleException
  8.  * @throws MessagingException
  9.  */
  10. @Test
  11. public void testFetchOneFolderModeIMAPWithNonDefFolder() throws KettleException, MessagingException {
  12.  entry.fetchOneFolder( mailConn, false, "junitImapFolder", "junitRealOutputFolder", "junitTargetAttachmentFolder",
  13.    "junitRealMoveToIMAPFolder", "junitRealFilenamePattern", 0, Mockito.mock( SimpleDateFormat.class ) );
  14.  Mockito.verify( mailConn ).openFolder( "junitImapFolder", true );
  15.  Mockito.verify( message ).setFlag( Flag.SEEN, true );
  16. }

代码示例来源：origin: pentaho/pentaho-kettle

  1. /**
  2.  * Delete current fetched message
  3.  *
  4.  * @throws KettleException
  5.  */
  6. public void deleteMessage() throws KettleException {
  7.  try {
  8.   this.message.setFlag( Flags.Flag.DELETED, true );
  9.   updateDeletedMessagesCounter();
  10.  } catch ( Exception e ) {
  11.   throw new KettleException( BaseMessages.getString( PKG, "MailConnection.Error.DeletingMessage", ""
  12.    + getMessage().getMessageNumber() ), e );
  13.  }
  14. }

代码示例来源：origin: pentaho/pentaho-kettle

  1. /**
  2.  * PDI-10942 - Job get emails JobEntry does not mark emails as 'read' when load emails content.
  3.  *
  4.  * Test that we always open remote folder in rw mode, and after email attachment is loaded email is marked as read.
  5.  * protocol IMAP and default remote folder is NOT overridden
  6.  *
  7.  * @throws KettleException
  8.  * @throws MessagingException
  9.  */
  10. @Test
  11. public void testFetchOneFolderModeIMAPWithIsDefFolder() throws KettleException, MessagingException {
  12.  entry.fetchOneFolder( mailConn, false, null, "junitRealOutputFolder", "junitTargetAttachmentFolder",
  13.      "junitRealMoveToIMAPFolder", "junitRealFilenamePattern", 0, Mockito.mock( SimpleDateFormat.class ) );
  14.  Mockito.verify( mailConn ).openFolder( true );
  15.  Mockito.verify( message ).setFlag( Flag.SEEN, true );
  16. }

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

  1. /**
  2.  * Deletes the given messages from this receiver's folder.
  3.  * @param messages the messages to delete
  4.  * @throws MessagingException in case of JavaMail errors
  5.  */
  6. protected void deleteMessages(Message[] messages) throws MessagingException {
  7.   for (Message message : messages) {
  8.     message.setFlag(Flags.Flag.DELETED, true);
  9.   }
  10. }

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

  1. @Override
  2. protected void setAdditionalFlags(Message message) throws MessagingException {
  3.   super.setAdditionalFlags(message);
  4.   if (this.shouldMarkMessagesAsRead) {
  5.     message.setFlag(Flag.SEEN, true);
  6.   }
  7. }

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

  1. @Test
  2. public void receiveAndMarkAsReadDontDelete() throws Exception {
  3.   AbstractMailReceiver receiver = new ImapMailReceiver();
  4.   Message msg1 = mock(MimeMessage.class);
  5.   Message msg2 = mock(MimeMessage.class);
  6.   receiver = receiveAndMarkAsReadDontDeleteGuts(receiver, msg1, msg2);
  7.   verify(msg1, times(1)).setFlag(Flag.SEEN, true);
  8.   verify(msg2, times(1)).setFlag(Flag.SEEN, true);
  9.   verify(receiver, times(0)).deleteMessages(Mockito.any());
  10. }

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

  1. @Test // INT-2991 Flag.SEEN was set twice when a filter is used
  2. public void receiveAndMarkAsReadDontDeletePassingFilter() throws Exception {
  3.   AbstractMailReceiver receiver = new ImapMailReceiver();
  4.   Message msg1 = mock(MimeMessage.class);
  5.   Message msg2 = mock(MimeMessage.class);
  6.   Expression selectorExpression = new SpelExpressionParser().parseExpression("true");
  7.   receiver.setSelectorExpression(selectorExpression);
  8.   receiver = receiveAndMarkAsReadDontDeleteGuts(receiver, msg1, msg2);
  9.   verify(msg1, times(1)).setFlag(Flag.SEEN, true);
  10.   verify(msg2, times(1)).setFlag(Flag.SEEN, true);
  11.   verify(receiver, times(0)).deleteMessages(Mockito.any());
  12. }

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

  1. @Test // INT-2991 filtered messages were marked SEEN
  2. public void receiveAndMarkAsReadDontDeleteFiltered() throws Exception {
  3.   AbstractMailReceiver receiver = new ImapMailReceiver();
  4.   Message msg1 = mock(MimeMessage.class);
  5.   Message msg2 = mock(MimeMessage.class);
  6.   given(msg2.getSubject()).willReturn("foo"); // should not be marked seen
  7.   Expression selectorExpression = new SpelExpressionParser()
  8.       .parseExpression("subject == null OR !subject.equals('foo')");
  9.   receiver.setSelectorExpression(selectorExpression);
  10.   receiver = receiveAndMarkAsReadDontDeleteGuts(receiver, msg1, msg2);
  11.   verify(msg1, times(1)).setFlag(Flag.SEEN, true);
  12.   verify(msg2, never()).setFlag(Flag.SEEN, true);
  13.   verify(receiver, times(0)).deleteMessages(Mockito.any());
  14. }

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

  1. @Test
  2. public void receiveAndDontSetDeleteWithUrl() throws Exception {
  3.   AbstractMailReceiver receiver = new Pop3MailReceiver("pop3://some.host");
  4.   receiver = spy(receiver);
  5.   receiver.setBeanFactory(mock(BeanFactory.class));
  6.   receiver.afterPropertiesSet();
  7.   Field folderField = AbstractMailReceiver.class.getDeclaredField("folder");
  8.   folderField.setAccessible(true);
  9.   Folder folder = mock(Folder.class);
  10.   when(folder.getPermanentFlags()).thenReturn(new Flags(Flags.Flag.USER));
  11.   folderField.set(receiver, folder);
  12.   Message msg1 = mock(MimeMessage.class);
  13.   Message msg2 = mock(MimeMessage.class);
  14.   final Message[] messages = new Message[] { msg1, msg2 };
  15.   doAnswer(invocation -> null).when(receiver).openFolder();
  16.   doAnswer(invocation -> messages).when(receiver).searchForNewMessages();
  17.   doAnswer(invocation -> null).when(receiver).fetchMessages(messages);
  18.   receiver.afterPropertiesSet();
  19.   receiver.receive();
  20.   verify(msg1, times(0)).setFlag(Flag.DELETED, true);
  21.   verify(msg2, times(0)).setFlag(Flag.DELETED, true);
  22. }

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

  1. @Test
  2. public void receiveAndDontSetDeleteWithoutUrl() throws Exception {
  3.   AbstractMailReceiver receiver = new Pop3MailReceiver();
  4.   receiver = spy(receiver);
  5.   receiver.setBeanFactory(mock(BeanFactory.class));
  6.   receiver.afterPropertiesSet();
  7.   Field folderField = AbstractMailReceiver.class.getDeclaredField("folder");
  8.   folderField.setAccessible(true);
  9.   Folder folder = mock(Folder.class);
  10.   when(folder.getPermanentFlags()).thenReturn(new Flags(Flags.Flag.USER));
  11.   folderField.set(receiver, folder);
  12.   Message msg1 = mock(MimeMessage.class);
  13.   Message msg2 = mock(MimeMessage.class);
  14.   final Message[] messages = new Message[] { msg1, msg2 };
  15.   doAnswer(invocation -> null).when(receiver).openFolder();
  16.   doAnswer(invocation -> messages).when(receiver).searchForNewMessages();
  17.   doAnswer(invocation -> null).when(receiver).fetchMessages(messages);
  18.   receiver.afterPropertiesSet();
  19.   receiver.receive();
  20.   verify(msg1, times(0)).setFlag(Flag.DELETED, true);
  21.   verify(msg2, times(0)).setFlag(Flag.DELETED, true);
  22. }

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

  1. @Test
  2. public void receiveAndDontDelete() throws Exception {
  3.   AbstractMailReceiver receiver = new Pop3MailReceiver();
  4.   receiver.setShouldDeleteMessages(false);
  5.   receiver = spy(receiver);
  6.   receiver.setBeanFactory(mock(BeanFactory.class));
  7.   receiver.afterPropertiesSet();
  8.   Field folderField = AbstractMailReceiver.class.getDeclaredField("folder");
  9.   folderField.setAccessible(true);
  10.   Folder folder = mock(Folder.class);
  11.   when(folder.getPermanentFlags()).thenReturn(new Flags(Flags.Flag.USER));
  12.   folderField.set(receiver, folder);
  13.   Message msg1 = mock(MimeMessage.class);
  14.   Message msg2 = mock(MimeMessage.class);
  15.   final Message[] messages = new Message[] { msg1, msg2 };
  16.   doAnswer(invocation -> null).when(receiver).openFolder();
  17.   doAnswer(invocation -> messages).when(receiver).searchForNewMessages();
  18.   doAnswer(invocation -> null).when(receiver).fetchMessages(messages);
  19.   receiver.afterPropertiesSet();
  20.   receiver.receive();
  21.   verify(msg1, times(0)).setFlag(Flag.DELETED, true);
  22.   verify(msg2, times(0)).setFlag(Flag.DELETED, true);
  23. }

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

  1. @Test
  2. public void receiveAndDelete() throws Exception {
  3.   AbstractMailReceiver receiver = new Pop3MailReceiver();
  4.   receiver.setShouldDeleteMessages(true);
  5.   receiver = spy(receiver);
  6.   receiver.setBeanFactory(mock(BeanFactory.class));
  7.   receiver.afterPropertiesSet();
  8.   Field folderField = AbstractMailReceiver.class.getDeclaredField("folder");
  9.   folderField.setAccessible(true);
  10.   Folder folder = mock(Folder.class);
  11.   when(folder.getPermanentFlags()).thenReturn(new Flags(Flags.Flag.USER));
  12.   folderField.set(receiver, folder);
  13.   Message msg1 = mock(MimeMessage.class);
  14.   Message msg2 = mock(MimeMessage.class);
  15.   final Message[] messages = new Message[] { msg1, msg2 };
  16.   doAnswer(invocation -> {
  17.     DirectFieldAccessor accessor = new DirectFieldAccessor(invocation.getMock());
  18.     int folderOpenMode = (Integer) accessor.getPropertyValue("folderOpenMode");
  19.     if (folderOpenMode != Folder.READ_WRITE) {
  20.       throw new IllegalArgumentException("Folder had to be open in READ_WRITE mode");
  21.     }
  22.     return null;
  23.   }).when(receiver).openFolder();
  24.   doAnswer(invocation -> messages).when(receiver).searchForNewMessages();
  25.   doAnswer(invocation -> null).when(receiver).fetchMessages(messages);
  26.   receiver.afterPropertiesSet();
  27.   receiver.receive();
  28.   verify(msg1, times(1)).setFlag(Flag.DELETED, true);
  29.   verify(msg2, times(1)).setFlag(Flag.DELETED, true);
  30. }

代码示例来源：origin: pentaho/pentaho-kettle

  1. mailConn.getMessage().setFlag( Flag.SEEN, true );

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

  1. @Test
  2. public void receiveAndDontMarkAsRead() throws Exception {
  3.   AbstractMailReceiver receiver = new ImapMailReceiver();
  4.   ((ImapMailReceiver) receiver).setShouldMarkMessagesAsRead(false);
  5.   receiver = spy(receiver);
  6.   receiver.setBeanFactory(mock(BeanFactory.class));
  7.   receiver.afterPropertiesSet();
  8.   Field folderField = AbstractMailReceiver.class.getDeclaredField("folder");
  9.   folderField.setAccessible(true);
  10.   Folder folder = mock(Folder.class);
  11.   given(folder.getPermanentFlags()).willReturn(new Flags(Flags.Flag.USER));
  12.   folderField.set(receiver, folder);
  13.   Message msg1 = mock(MimeMessage.class);
  14.   Message msg2 = mock(MimeMessage.class);
  15.   final Message[] messages = new Message[] { msg1, msg2 };
  16.   willAnswer(invocation -> null).given(receiver).openFolder();
  17.   willAnswer(invocation -> messages).given(receiver).searchForNewMessages();
  18.   willAnswer(invocation -> null).given(receiver).fetchMessages(messages);
  19.   receiver.afterPropertiesSet();
  20.   receiver.receive();
  21.   verify(msg1, times(0)).setFlag(Flag.SEEN, true);
  22.   verify(msg2, times(0)).setFlag(Flag.SEEN, true);
  23. }

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

  1. @Test
  2. public void receiveAndIgnoreMarkAsReadDontDelete() throws Exception {
  3.   AbstractMailReceiver receiver = new ImapMailReceiver();
  4.   receiver = spy(receiver);
  5.   receiver.setBeanFactory(mock(BeanFactory.class));
  6.   receiver.afterPropertiesSet();
  7.   Field folderField = AbstractMailReceiver.class.getDeclaredField("folder");
  8.   folderField.setAccessible(true);
  9.   Folder folder = mock(Folder.class);
  10.   given(folder.getPermanentFlags()).willReturn(new Flags(Flags.Flag.USER));
  11.   folderField.set(receiver, folder);
  12.   Message msg1 = mock(MimeMessage.class);
  13.   Message msg2 = mock(MimeMessage.class);
  14.   final Message[] messages = new Message[] { msg1, msg2 };
  15.   willAnswer(invocation -> {
  16.     DirectFieldAccessor accessor = new DirectFieldAccessor(invocation.getMock());
  17.     int folderOpenMode = (int) accessor.getPropertyValue("folderOpenMode");
  18.     if (folderOpenMode != Folder.READ_WRITE) {
  19.       throw new IllegalArgumentException("Folder had to be open in READ_WRITE mode");
  20.     }
  21.     return null;
  22.   }).given(receiver).openFolder();
  23.   willAnswer(invocation -> messages).given(receiver).searchForNewMessages();
  24.   willAnswer(invocation -> null).given(receiver).fetchMessages(messages);
  25.   receiver.receive();
  26.   verify(msg1, times(1)).setFlag(Flag.SEEN, true);
  27.   verify(msg2, times(1)).setFlag(Flag.SEEN, true);
  28.   verify(receiver, times(0)).deleteMessages(Mockito.any());
  29. }

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

  1. verify(msg1, times(1)).setFlag(Flag.SEEN, true);
  2. verify(msg2, times(1)).setFlag(Flag.SEEN, true);
  3. verify(receiver, times(1)).deleteMessages(Mockito.any());

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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