You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by mc...@apache.org on 2015/01/14 19:35:29 UTC
[05/17] incubator-nifi git commit: NIFI-258: - Ensuring connection
stays up to date when processor configuration changes.
NIFI-258:
- Ensuring connection stays up to date when processor configuration changes.
Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/80793ccb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/80793ccb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/80793ccb
Branch: refs/heads/NIFI-250
Commit: 80793ccbb829e079ef8cc2fe703bad6397a71d48
Parents: b142d7a
Author: Matt Gilman <ma...@gmail.com>
Authored: Tue Jan 13 15:54:21 2015 -0500
Committer: Matt Gilman <ma...@gmail.com>
Committed: Tue Jan 13 15:54:21 2015 -0500
----------------------------------------------------------------------
.../js/nf/canvas/nf-processor-configuration.js | 23 +++++++++++++++++++-
1 file changed, 22 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/80793ccb/nar-bundles/framework-bundle/framework/web/nifi-web-ui/src/main/webapp/js/nf/canvas/nf-processor-configuration.js
----------------------------------------------------------------------
diff --git a/nar-bundles/framework-bundle/framework/web/nifi-web-ui/src/main/webapp/js/nf/canvas/nf-processor-configuration.js b/nar-bundles/framework-bundle/framework/web/nifi-web-ui/src/main/webapp/js/nf/canvas/nf-processor-configuration.js
index 4dec734..14ffa95 100644
--- a/nar-bundles/framework-bundle/framework/web/nifi-web-ui/src/main/webapp/js/nf/canvas/nf-processor-configuration.js
+++ b/nar-bundles/framework-bundle/framework/web/nifi-web-ui/src/main/webapp/js/nf/canvas/nf-processor-configuration.js
@@ -363,6 +363,20 @@ nf.ProcessorConfiguration = (function () {
return true;
}
};
+
+ /**
+ * Reloads the outgoing connections for the specified processor.
+ *
+ * @param {object} processor
+ */
+ var reloadProcessorConnections = function (processor) {
+ var connections = nf.Connection.getComponentConnections(processor.id);
+ $.each(connections, function (_, connection) {
+ if (connection.source.id === processor.id) {
+ nf.Connection.reload(connection);
+ }
+ });
+ };
return {
/**
@@ -601,8 +615,11 @@ nf.ProcessorConfiguration = (function () {
// update the revision
nf.Client.setRevision(response.revision);
- // set the new processor state
+ // set the new processor state based on the response
nf.Processor.set(response.processor);
+
+ // reload the processor's outgoing connections
+ reloadProcessorConnections(processor);
// close the details panel
$('#processor-configuration').modal('hide');
@@ -632,7 +649,11 @@ nf.ProcessorConfiguration = (function () {
// show the custom ui
nf.CustomProcessorUi.showCustomUi($('#processor-id').text(), processor.config.customUiUrl, true).done(function () {
+ // once the custom ui is closed, reload the processor
nf.Processor.reload(processor);
+
+ // and reload the processor's outgoing connections
+ reloadProcessorConnections(processor);
});
};