Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-11 04:25:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-11977 Set UTF-8 Character Set in Subject for PutEmail (#9170)

Browse Source 
Signed-off-by: David Handermann <exceptionfactory@apache.org>
This commit is contained in:
Michael Akinyemi 2024-08-13 12:03:41 -04:00 committed by GitHub
parent 265ef593a6
commit 39a1ccc191
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutEmail.java
View File

@ -415,7 +415,7 @@ public class PutEmail extends AbstractProcessor {
final Properties properties = this.getMailPropertiesFromFlowFile(context, flowFile); final Properties properties = this.getMailPropertiesFromFlowFile(context, flowFile);
final Session mailSession = this.createMailSession(properties); final Session mailSession = this.createMailSession(properties);
final Message message = new MimeMessage(mailSession); final MimeMessage message = new MimeMessage(mailSession);
try { try {
message.addFrom(toInetAddresses(context, flowFile, FROM)); message.addFrom(toInetAddresses(context, flowFile, FROM));
@ -431,7 +431,8 @@ public class PutEmail extends AbstractProcessor {
} }
} }
this.setMessageHeader("X-Mailer", context.getProperty(HEADER_XMAILER).evaluateAttributeExpressions(flowFile).getValue(), message); this.setMessageHeader("X-Mailer", context.getProperty(HEADER_XMAILER).evaluateAttributeExpressions(flowFile).getValue(), message);
message.setSubject(context.getProperty(SUBJECT).evaluateAttributeExpressions(flowFile).getValue());
message.setSubject(context.getProperty(SUBJECT).evaluateAttributeExpressions(flowFile).getValue(), StandardCharsets.UTF_8.name());
final String messageText = getMessage(flowFile, context, session); final String messageText = getMessage(flowFile, context, session);