Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-271

This commit is contained in:
joewitt 2015-04-25 09:13:45 -04:00
parent 269e25e993
commit e93c829191
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
nifi/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/sns/PutSNS.java
View File

@ -55,7 +55,9 @@ public class PutSNS extends AbstractSNSProcessor {
.build(); .build();
public static final PropertyDescriptor USE_JSON_STRUCTURE = new PropertyDescriptor.Builder() public static final PropertyDescriptor USE_JSON_STRUCTURE = new PropertyDescriptor.Builder()
.name("Use JSON Structure") .name("Use JSON Structure")
.description("If true, the contents of the FlowFile must be JSON with a top-level element named 'default'. Additional elements can be used to send different messages to different protocols. See the Amazon SNS Documentation for more information.") .description("If true, the contents of the FlowFile must be JSON with a top-level element named 'default'."
+ " Additional elements can be used to send different messages to different protocols. See the Amazon"
+ " SNS Documentation for more information.")
.defaultValue("false") .defaultValue("false")
.allowableValues("true", "false") .allowableValues("true", "false")
.required(true) .required(true)
@ -147,7 +149,6 @@ public class PutSNS extends AbstractSNSProcessor {
} catch (final Exception e) { } catch (final Exception e) {
getLogger().error("Failed to publish Amazon SNS message for {} due to {}", new Object[]{flowFile, e}); getLogger().error("Failed to publish Amazon SNS message for {} due to {}", new Object[]{flowFile, e});
session.transfer(flowFile, REL_FAILURE); session.transfer(flowFile, REL_FAILURE);
return;
} }
} }

3
nifi/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/sqs/GetSQS.java
View File

@ -195,7 +195,8 @@ public class GetSQS extends AbstractSQSProcessor {
try { try {
client.deleteMessageBatch(deleteRequest); client.deleteMessageBatch(deleteRequest);
} catch (final Exception e) { } catch (final Exception e) {
getLogger().error("Received {} messages from Amazon SQS but failed to delete the messages; these messages may be duplicated. Reason for deletion failure: {}", new Object[]{messages.size(), e}); getLogger().error("Received {} messages from Amazon SQS but failed to delete the messages; these messages"
+ " may be duplicated. Reason for deletion failure: {}", new Object[]{messages.size(), e});
} }
} }