You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by he...@apache.org on 2016/02/01 18:46:49 UTC
[31/50] brooklyn-library git commit: Use new method in Entities class
to get download resolver
Use new method in Entities class to get download resolver
Project: http://git-wip-us.apache.org/repos/asf/brooklyn-library/repo
Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-library/commit/400e17f2
Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-library/tree/400e17f2
Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-library/diff/400e17f2
Branch: refs/heads/0.5.0
Commit: 400e17f2274307e087f8725a3ca476e1ca634da4
Parents: 317363a
Author: Andrew Kennedy <an...@cloudsoftcorp.com>
Authored: Thu Apr 4 12:08:34 2013 +0100
Committer: Andrew Kennedy <an...@cloudsoftcorp.com>
Committed: Fri Apr 19 10:37:17 2013 +0100
----------------------------------------------------------------------
.../brooklyn/entity/messaging/kafka/AbstractfKafkaSshDriver.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/brooklyn-library/blob/400e17f2/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/AbstractfKafkaSshDriver.java
----------------------------------------------------------------------
diff --git a/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/AbstractfKafkaSshDriver.java b/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/AbstractfKafkaSshDriver.java
index 21e7092..2686140 100644
--- a/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/AbstractfKafkaSshDriver.java
+++ b/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/AbstractfKafkaSshDriver.java
@@ -26,6 +26,7 @@ import org.slf4j.LoggerFactory;
import brooklyn.BrooklynVersion;
import brooklyn.config.ConfigKey;
+import brooklyn.entity.basic.Entities;
import brooklyn.entity.basic.EntityLocal;
import brooklyn.util.ssh.CommonCommands;
import brooklyn.entity.drivers.downloads.DownloadResolver;
@@ -69,7 +70,7 @@ public abstract class AbstractfKafkaSshDriver extends JavaSoftwareProcessSshDriv
@Override
public void install() {
- DownloadResolver resolver = entity.getManagementContext().getEntityDownloadsManager().newDownloader(this);
+ DownloadResolver resolver = Entities.newDownloader(this);
List<String> urls = resolver.getTargets();
String saveAs = resolver.getFilename();
expandedInstallDir = getInstallDir()+"/"+resolver.getUnpackedDirectoryName(format("kafka-%s-src", getVersion()));