javax.mail.internet.MimeMessage.getInputStream()方法的使用及代码示例

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

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

MimeMessage.getInputStream介绍

[英]Return a decoded input stream for this Message's "content".

This implementation obtains the input stream from the DataHandler, that is, it invokes getDataHandler().getInputStream().
[中]返回此消息“内容”的解码输入流。
此实现从DataHandler获取输入流,即调用getDataHandler().getInputStream()

代码示例

代码示例来源:origin: com.helger/ph-as4-lib

public InputStream getContent () throws IOException
{
 try
 {
  return m_aMsg.getInputStream ();
 }
 catch (final MessagingException ex)
 {
  throw new IOException ("Error reading MIME message", ex);
 }
}

代码示例来源:origin: org.apache.james/james-server-smtpserver

/**
 * @see org.apache.james.protocols.smtp.MailEnvelope#getMessageInputStream()
 */
public InputStream getMessageInputStream() throws Exception {
  return mail.getMessage().getInputStream();
}

代码示例来源:origin: org.apache.james/james-server-core-library

/**
 * @see javax.mail.Part#getInputStream()
 */
public InputStream getInputStream() throws IOException, MessagingException {
  return getWrappedMessage().getInputStream();
}

代码示例来源:origin: apache/james-project

public MimeMessageBuilder setMultipartWithSubMessage(MimeMessage mimeMessage) throws MessagingException, IOException {
  return setMultipartWithBodyParts(
    new MimeBodyPart(
      new InternetHeaders(new ByteArrayInputStream("Content-Type: multipart/mixed".getBytes(StandardCharsets.US_ASCII))),
      IOUtils.toByteArray(mimeMessage.getInputStream())));
}

代码示例来源:origin: org.apache.james/james-core

public MimeMessageBuilder setMultipartWithSubMessage(MimeMessage mimeMessage) throws MessagingException, IOException {
  return setMultipartWithBodyParts(
    new MimeBodyPart(
      new InternetHeaders(new ByteArrayInputStream("Content-Type: multipart/mixed".getBytes(StandardCharsets.US_ASCII))),
      IOUtils.toByteArray(mimeMessage.getInputStream())));
}

代码示例来源:origin: apache/ofbiz-framework

public String getMessageRawText() {
  MimeMessage message = getMessage();
  try {
    return getTextFromStream(message.getInputStream());
  } catch (Exception e) {
    Debug.logError(e, module);
    return null;
  }
}

代码示例来源:origin: org.apache.james/james-server-jmap

@Test
public void fromShouldNotWriteAMultipartWhenOnlyPlainText() throws Exception {
  assertThat(IOUtils.toString(
    mimeMessageBodyGenerator.from(original,
      Optional.of("Plain text"),
      Optional.empty())
      .getInputStream(), StandardCharsets.UTF_8))
    .isEqualTo("Plain text");
  verifyZeroInteractions(htmlTextExtractor);
}

代码示例来源:origin: org.apache.james/james-server-jmap

@Test
public void fromShouldUseEmptyTextWhenNoPlainTextNorHtmlBody() throws Exception {
  String rowContent = IOUtils.toString(mimeMessageBodyGenerator.from(original,
    Optional.empty(),
    Optional.empty())
    .getInputStream(), StandardCharsets.UTF_8);
  assertThat(rowContent).isEmpty();
}

代码示例来源:origin: org.apache.james/james-server-jmap

@Test
public void fromShouldPreservePreviouslySetHeaders() throws Exception {
  String subject = "Important, I should be kept";
  original.setHeader("Subject", subject);
  mimeMessageBodyGenerator.from(original,
    Optional.of("Plain text"),
    Optional.empty())
    .getInputStream();
  assertThat(original.getSubject()).isEqualTo(subject);
  verifyZeroInteractions(htmlTextExtractor);
}

代码示例来源:origin: org.apache.james/apache-james-spamassassin

@Test
public void learnAsSpamShouldReturnTrueWhenLearningWorks() throws Exception {
  MimeMessage mimeMessage = MimeMessageUtil.mimeMessageFromStream(
      ClassLoader.getSystemResourceAsStream("spamassassin_db/spam/spam2"));
  boolean result = testee.learnAsSpam(mimeMessage.getInputStream(), USER);
  assertThat(result).isTrue();
}

代码示例来源:origin: org.apache.james/apache-james-spamassassin

@Test
public void learnAsHamShouldReturnTrueWhenLearningWorks() throws Exception {
  MimeMessage mimeMessage = MimeMessageUtil.mimeMessageFromStream(
    ClassLoader.getSystemResourceAsStream("spamassassin_db/ham/ham2"));
  boolean result = testee.learnAsHam(mimeMessage.getInputStream(), USER);
  assertThat(result).isTrue();
}

代码示例来源:origin: org.apache.james/james-server-jmap

@Test
public void fromShouldProvideAPlainTextVersionWhenOnlyHtml() throws Exception {
  String htmlText = "<p>HTML text</p>";
  String plainText = "Plain text";
  when(htmlTextExtractor.toPlainText(htmlText)).thenReturn(plainText);
  String rowContent = IOUtils.toString(
    mimeMessageBodyGenerator.from(original,
      Optional.empty(),
      Optional.of(htmlText))
      .getInputStream(), StandardCharsets.UTF_8);
  assertThat(rowContent).containsSequence(htmlText);
  assertThat(rowContent).containsSequence(plainText);
}

代码示例来源:origin: org.apache.james/apache-james-spamassassin

@Test
public void scanMailShouldMarkAsHamWhenMessageAlreadyLearnedAsHam() throws Exception {
  MimeMessage mimeMessage = MimeMessageUtil.mimeMessageFromStream(
    ClassLoader.getSystemResourceAsStream("spamassassin_db/ham/ham1"));
  testee.learnAsHam(mimeMessage.getInputStream(), USER);
  SpamAssassinResult result = testee.scanMail(mimeMessage, USER);
  assertThat(result.getHeadersAsAttribute().get(SpamAssassinResult.FLAG_MAIL_ATTRIBUTE_NAME)).isEqualTo("NO");
}

代码示例来源:origin: org.apache.james/james-server-mailets

@Override
public boolean isInBodyText(List<String> phrasesCaseInsensitive) throws SieveMailException {
  try {
    return MessageMatcher.builder()
      .contentTypes(Lists.newArrayList("text/plain"))
      .includeHeaders(false)
      .caseInsensitive(false)
      .searchContents(Lists.transform(phrasesCaseInsensitive, s -> s)).build()
      .messageMatches(getMail().getMessage().getInputStream());
  } catch (Exception e) {
    throw new SieveMailException("Error searching in the mail content", e);
  }
}

代码示例来源:origin: org.apache.james/james-server-mailets

@Override
public boolean isInBodyRaw(List<String> phrasesCaseInsensitive) throws SieveMailException {
  try {
    return MessageMatcher.builder()
      .includeHeaders(false)
      .caseInsensitive(false)
      .ignoringMime(true)
      .searchContents(Lists.transform(phrasesCaseInsensitive, s -> s)).build()
      .messageMatches(getMail().getMessage().getInputStream());
  } catch (Exception e) {
    throw new SieveMailException("Error searching in the mail content", e);
  }
}

代码示例来源:origin: org.apache.james/james-server-mailets

@Override
public boolean isInBodyContent(List<String> contentTypes, List<String> phrasesCaseInsensitive) throws SieveMailException {
  try {
    return MessageMatcher.builder()
      .contentTypes(contentTypes)
      .includeHeaders(false)
      .caseInsensitive(false)
      .searchContents(Lists.transform(phrasesCaseInsensitive, s -> s)).build()
      .messageMatches(getMail().getMessage().getInputStream());
  } catch (Exception e) {
    throw new SieveMailException("Error searching in the mail content", e);
  }
}

代码示例来源:origin: org.apache.james/apache-mailet-base

@Override
public boolean isMdnSentAutomatically(Mail mail) throws MessagingException {
  ResultCollector resultCollector = new ResultCollector(false);
  MimeStreamParser parser = new MimeStreamParser(MimeConfig.PERMISSIVE);
  parser.setContentHandler(createMdnContentHandler(resultCollector));
  try {
    parser.parse(mail.getMessage().getInputStream());
  } catch (MimeException e) {
    throw new MessagingException("Can not parse Mime", e);
  } catch (IOException e) {
    throw new MessagingException("Can not read content", e);
  }
  return resultCollector.getResult();
}

代码示例来源:origin: io.vertx/vertx-mail-client

private void mailTestText(final String text) {
 MailMessage message = exampleMessage();
 message.setText(text);
 testSuccess(mailClientLogin(), message, () -> {
  final MimeMessage mimeMessage = wiser.getMessages().get(0).getMimeMessage();
  testContext.assertEquals(text, TestUtils.conv2nl(TestUtils.inputStreamToString(mimeMessage.getInputStream())));
 });
}

代码示例来源:origin: io.vertx/vertx-mail-client

@Test
public void mailTestMissingNL(TestContext testContext) {
 this.testContext=testContext;
 MailMessage message = exampleMessage();
 // the protocol adds a newline at the end if there isn't one
 message.setText(".");
 testSuccess(mailClientLogin(), message, () -> {
  final MimeMessage mimeMessage = wiser.getMessages().get(0).getMimeMessage();
  testContext.assertEquals(".\n", TestUtils.conv2nl(TestUtils.inputStreamToString(mimeMessage.getInputStream())));
 });
}

代码示例来源:origin: io.vertx/vertx-mail-client

protected AdditionalAsserts assertExampleMessage() {
 return () -> {
  final WiserMessage message = wiser.getMessages().get(0);
  testContext.assertEquals("from@example.com", message.getEnvelopeSender());
  final MimeMessage mimeMessage = message.getMimeMessage();
  assertThat(mimeMessage.getContentType(), containsString("text/plain"));
  testContext.assertEquals("Subject", mimeMessage.getSubject());
  testContext.assertEquals("Message\n", TestUtils.conv2nl(TestUtils.inputStreamToString(mimeMessage.getInputStream())));
 };
}

相关文章

MimeMessage类方法