ComputeServiceContext computeContext = new ComputeServiceContextFactory().createContext(
            config.getProvider(),
            config.getAccount(),
            config.getKey(),
            ImmutableSet.of(
                  new Log4JLoggingModule(),
                  new JschSshClientModule()));

      ComputeService computeService = computeContext.getComputeService();

      Map<? extends NodeMetadata, ExecResponse> responses = computeService.runScriptOnNodesMatching(
            NodePredicates.withTag(config.getTag()),
            Payloads.newStringPayload(createScript()),
            RunScriptOptions.Builder.runAsRoot(true));

      for(Map.Entry<? extends NodeMetadata, ExecResponse> response : responses.entrySet())
      {
         System.out.println(response.getKey().getId() + " " +  response.getKey().getName() + " " + response.getKey().getTag());
         System.out.println(response.getValue().getExitCode());
         System.out.println(response.getValue().getError());
         System.out.println(response.getValue().getOutput());
      }
   }

   private String createScript()
   {
      return Statements.newStatementList(
               Statements.createFile(
                 "root.was.here",
                     ImmutableList.of(
                        "root.was.here"
              )),
              Statements.exec("apt get foo"),
              Statements.exec("apt install foo")
       ).render(OsFamily.UNIX);

   }