From fa7063e2c816a5f45cacc56037e5150d9767d6ad Mon Sep 17 00:00:00 2001
From: Andrew Grande <aperepel@gmail.com>
Date: Mon, 30 Jan 2017 14:57:15 -0500
Subject: [PATCH] Merge remote-tracking branch 'remotes/simon/NIFI-1833' into
 NIFI-1833

Made some dependency changes, tested List/FetchAzureBlob with NiFi 1.2.0-SNAPSHOT
---
 .../azure/storage/ListAzureBlobStorage.java          | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage.java b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage.java
index 547f2fc3935e..a9c7e365beb4 100644
--- a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage.java
+++ b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage.java
@@ -8,8 +8,10 @@
 import java.util.Collections;
 import java.util.EnumSet;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 import java.util.TreeMap;
 import java.util.concurrent.TimeUnit;
 
@@ -92,6 +94,9 @@ public class ListAzureBlobStorage extends AbstractProcessor {
             .description("All FlowFiles that are received are routed to success")
             .build();
 
+    public static final Set<Relationship> relationships = Collections.unmodifiableSet(
+            new HashSet<>(Collections.singletonList(REL_SUCCESS)));
+
     public static final List<PropertyDescriptor> properties = Collections.unmodifiableList(Arrays.asList(AzureConstants.ACCOUNT_NAME, AzureConstants.ACCOUNT_KEY, AzureConstants.CONTAINER, PREFIX));
 
     @Override
@@ -111,7 +116,12 @@ public void onPropertyModified(final PropertyDescriptor descriptor, final String
     public void onPrimaryNodeChange(final PrimaryNodeState newState) {
         justElectedPrimaryNode = (newState == PrimaryNodeState.ELECTED_PRIMARY_NODE);
     }
-    
+
+    @Override
+    public Set<Relationship> getRelationships() {
+        return relationships;
+    }
+
     @OnScheduled
     public final void updateState(final ProcessContext context) throws IOException {
         // Check if state already exists for this path. If so, we have already migrated the state.