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 <[email protected]> Authored: Thu Apr 4 12:08:34 2013 +0100 Committer: Andrew Kennedy <[email protected]> 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()));
