You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@nifi.apache.org by ma...@apache.org on 2020/01/14 22:07:57 UTC

[nifi] branch master updated (421bfdd -> 1033253)

This is an automated email from the ASF dual-hosted git repository.

markap14 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git.


    from 421bfdd  NIFI-6919: Added relationship attribute to DistributeLoad
     add 1033253  NIFI-7015 - ConsumeJMS now supports ObjectMessage, MapMessage and StreamMessage types as well. Added optional ERROR_QUEUE property. Result flowfiles get a 'jms.messagetype' attribute that contains the incoming message type (TextMessage, BytesMessage, ObjectMessage, MapMessage or StreamMessage).

No new revisions were added by this update.

Summary of changes:
 .../nifi/jms/processors/AbstractJMSProcessor.java  |   2 +
 .../org/apache/nifi/jms/processors/ConsumeJMS.java |  42 ++++-
 .../apache/nifi/jms/processors/JMSConsumer.java    |  43 ++++-
 .../processors/MessageBodyToBytesConverter.java    | 121 +++++++++++++-
 .../apache/nifi/jms/processors/ConsumeJMSIT.java   | 186 +++++++++++++++++++++
 .../nifi/jms/processors/ConsumeJMSManualTest.java  | 149 +++++++++++++++++
 .../jms/processors/JMSPublisherConsumerIT.java     | 178 +++++++++++++++++++-
 7 files changed, 704 insertions(+), 17 deletions(-)
 create mode 100644 nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/test/java/org/apache/nifi/jms/processors/ConsumeJMSManualTest.java