Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-12 21:15:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-6916 - handle null text message in JMSConsumer

Browse Source 
This closes #3919.

Signed-off-by: Mark Payne <markap14@hotmail.com>
This commit is contained in:
Pierre Villard 2019-12-06 05:43:39 +01:00 committed by Mark Payne
parent 442858127b
commit 3c3eba1909
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-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/MessageBodyToBytesConverter.java
View File

@ -48,6 +48,9 @@ abstract class MessageBodyToBytesConverter {
*/ */
public static byte[] toBytes(TextMessage message, Charset charset) { public static byte[] toBytes(TextMessage message, Charset charset) {
try { try {
if (message.getText() == null) {
return new byte[0];
}
if (charset == null) { if (charset == null) {
return message.getText().getBytes(); return message.getText().getBytes();
} else { } else {
@ -72,7 +75,6 @@ abstract class MessageBodyToBytesConverter {
} }
} }
private static class BytesMessageInputStream extends InputStream { private static class BytesMessageInputStream extends InputStream {
private BytesMessage message; private BytesMessage message;
@ -112,7 +114,6 @@ abstract class MessageBodyToBytesConverter {
} }
} }
static class MessageConversionException extends RuntimeException { static class MessageConversionException extends RuntimeException {
private static final long serialVersionUID = -1464448549601643887L; private static final long serialVersionUID = -1464448549601643887L;