Added logging capability.

README.md

@@ -124,7 +124,7 @@ rm -rf gatling-charts-highcharts-bundle-${GATLING_VERSION}/user-files/simulation
   </properties>
 ```
 
-5. Add the following two dependencies:
+5. Add the following dependencies:
 
 ```xml
   <dependencies>

bitbucket-pipelines.yml

@@ -0,0 +1,18 @@
+image: maven:3.3.9
+pipelines:
+  default:
+    - step:
+        caches:
+          - maven
+        script:
+          - mvn -B verify
+  tags:
+    v*:
+      - step:
+          caches:
+            - maven
+          script:
+            - bash configure-maven.sh
+            - VERSION=$(echo "$BITBUCKET_TAG" | sed -e 's/^v//')
+            - mvn versions:set -DnewVersion=$VERSION
+            - mvn deploy

pom.xml

@@ -3,7 +3,7 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
     <artifactId>gatling-aws-maven-plugin</artifactId>
-    <groupId>com.ea.gatling</groupId>
+    <groupId>com.fr</groupId>
     <version>1.0.18-SNAPSHOT</version>
     <name>Gatling AWS Maven Plugin</name>
     <description>The Gatling AWS Maven plugin takes the pain out of scaling up your Gatling tests. It runs your load test on a configurable number of EC2 instances, aggregates a single load test report, and uploads the results to S3. All EC2 instances are terminated at the end of the test to ensure you are only paying for what you need.</description>
@@ -95,21 +95,26 @@
                 </configuration>
             </plugin>
         </plugins>
+        <extensions>
+            <extension>
+                <groupId>org.kuali.maven.wagons</groupId>
+                <artifactId>maven-s3-wagon</artifactId>
+                <version>1.2.1</version>
+            </extension>
+        </extensions>
     </build>
     <profiles>
         <profile>
             <id>release</id>
             <distributionManagement>
-                <snapshotRepository>
-                    <id>deployment</id>
-                    <name>Snapshots</name>
-                    <url>https://oss.sonatype.org/content/repositories/snapshots</url>
-                </snapshotRepository>
                 <repository>
-                    <id>deployment</id>
-                    <name>Staging</name>
-                    <url>https://oss.sonatype.org/service/local/staging/deploy/maven2</url>
+                    <id>fr-maven-release</id>
+                    <url>s3://maven.flexreceipts.com/release</url>
                 </repository>
+                <snapshotRepository>
+                    <id>fr-maven-snapshot</id>
+                    <url>s3://maven.flexreceipts.com/snapshot</url>
+                </snapshotRepository>
             </distributionManagement>
             <build>
                 <plugins>

src/main/java/com/ea/gatling/AwsGatlingExecutor.java

@@ -33,8 +33,10 @@ public class AwsGatlingExecutor implements Runnable {
     private final String inheritedGatlingJavaOpts;
     private final boolean debugOutputEnabled;
     private final boolean runDetached;
+    private final String remoteLogfile;
+    private final boolean getRemoteLogFile;
 
-    public AwsGatlingExecutor(final String host,final String sshUser, final File sshPrivateKey, final String testName, final File installScript, final File gatlingSourceDir, final String gatlingSimulation, final File simulationConfig, final File gatlingResourcesDir, final File gatlingLocalResultsDir, final List<String> additionalFiles, final int numInstance, final int instanceCount, final ConcurrentHashMap<String, Integer> completedHosts, final String gatlingRoot, final String inheritedGatlingJavaOpts, final boolean debugOutputEnabled, final boolean runDetached) {
+    public AwsGatlingExecutor(final String host,final String sshUser, final File sshPrivateKey, final String testName, final File installScript, final File gatlingSourceDir, final String gatlingSimulation, final File simulationConfig, final File gatlingResourcesDir, final File gatlingLocalResultsDir, final List<String> additionalFiles, final int numInstance, final int instanceCount, final ConcurrentHashMap<String, Integer> completedHosts, final String gatlingRoot, final String inheritedGatlingJavaOpts, final boolean debugOutputEnabled, final boolean runDetached, final boolean getRemoteLogFile, final String remoteLogFile) {
         this.host = host;
         this.sshUser = sshUser;
         this.sshPrivateKey = sshPrivateKey.getAbsolutePath();
@@ -53,6 +55,8 @@ public AwsGatlingExecutor(final String host,final String sshUser, final File ssh
         this.inheritedGatlingJavaOpts = inheritedGatlingJavaOpts;
         this.debugOutputEnabled = debugOutputEnabled;
         this.runDetached = runDetached;
+        this.remoteLogfile = remoteLogFile;
+        this.getRemoteLogFile = getRemoteLogFile;
     }
 
     public void runGatlingTest() throws IOException {
@@ -131,6 +135,11 @@ private int runProcess(final SshClient.HostInfo hostInfo) throws IOException {
                     this.debugOutputEnabled);
             SshClient.scpDownload(hostInfo, new SshClient.FromTo("simulation.log",
                     String.format("%s/%s/simulation-%s.log", this.gatlingLocalResultsDir.getAbsolutePath(), this.testName, this.host)));
+            if(this.getRemoteLogFile) {
+                this.log("Downloading remote log");
+                SshClient.scpDownload(hostInfo, new SshClient.FromTo(remoteLogfile,
+                        String.format("%s/%s/remote-log-%s.log", this.gatlingLocalResultsDir.getAbsolutePath(), this.testName, this.host)));
+            }
         }
 
         return resultCode;

src/main/java/com/ea/gatling/GatlingAwsMojo.java

@@ -62,6 +62,12 @@ public class GatlingAwsMojo extends BaseAwsMojo {
     @Parameter(property = "gatling.local.results", defaultValue = "${project.build.directory}/gatling/results")
     private File gatlingLocalResultsDir;
 
+    @Parameter(property = "gatling.remote.log", defaultValue = "gatling-charts-highcharts-bundle-2.1.4/target/logs/logfile.txt")
+    private String gatlingRemoteLog;
+
+    @Parameter(property = "gatling.remote.download", defaultValue = "false")
+    private boolean downloadRemoteLog;
+
     @Parameter(property = "gatling.local.home", defaultValue = "${user.home}/gatling/gatling-charts-highcharts-bundle-2.1.4/bin/gatling.sh")
     private String gatlingLocalHome;
 
@@ -95,6 +101,7 @@ public class GatlingAwsMojo extends BaseAwsMojo {
     @Parameter(property = "prefer.private.ip.hostnames", defaultValue = "false")
     private boolean preferPrivateIpHostnames;
 
+
     /**
      * When true, this will run Gatling detached, and disconnect from SSH while Gatling is running.  Leaves a
      *    file called 'gatling.pid' with the pid of the java process in it.
@@ -146,7 +153,9 @@ public void execute() throws MojoExecutionException {
                     this.gatlingRoot,
                     this.gatlingJavaOpts,
                     this.debugOutputEnabled,
-                    this.ec2ExecuteDetached);
+                    this.ec2ExecuteDetached,
+                    this.downloadRemoteLog,
+                    this.gatlingRemoteLog);
             executor.execute(worker);
         }
         executor.shutdown();