Merge pull request #3 from jankronquist/master

Added support to set AWSCredentialsProvider

src/main/java/com/gu/logback/appender/kinesis/KinesisAppender.java

@@ -72,7 +72,7 @@ public class KinesisAppender extends AppenderBase<ILoggingEvent> {
     private AmazonKinesisAsyncClient kinesisClient;
     private AsyncPutCallStatsReporter asyncCallHander;
     private LayoutBase layout;
-    private AWSCredentialsProvider credentials;
+    private AWSCredentialsProvider credentials = new CustomCredentialsProviderChain();
 
     public LayoutBase getLayout() {
         return layout;
@@ -107,18 +107,6 @@ public void start() {
             return;
         }
 
-        CustomCredentialsProviderChain localAccountCredentials = new CustomCredentialsProviderChain();
-
-        if (Validator.isBlank(roleToAssumeArn)) {
-            credentials = localAccountCredentials; 
-        } else {
-            String sessionId = "session" + Math.random(); 
-            STSAssumeRoleSessionCredentialsProvider remoteAccountCredentials = new 
-                STSAssumeRoleSessionCredentialsProvider(localAccountCredentials, roleToAssumeArn, sessionId);
-
-            credentials = remoteAccountCredentials;
-        }
-
         ClientConfiguration clientConfiguration = new ClientConfiguration();
         clientConfiguration.setMaxErrorRetry(maxRetries);
         clientConfiguration.setRetryPolicy(new RetryPolicy(PredefinedRetryPolicies.DEFAULT_RETRY_CONDITION,
@@ -378,6 +366,17 @@ public String getRoleToAssumeArn() {
 
     public void setRoleToAssumeArn(String roleToAssumeArn) {
         this.roleToAssumeArn = roleToAssumeArn;
+        if (!Validator.isBlank(roleToAssumeArn)) {
+            String sessionId = "session" + Math.random(); 
+            STSAssumeRoleSessionCredentialsProvider remoteAccountCredentials = new 
+                STSAssumeRoleSessionCredentialsProvider(credentials, roleToAssumeArn, sessionId);
+
+            credentials = remoteAccountCredentials;
+        }
+    }
+
+    public void setCredentialsProvider(AWSCredentialsProvider credentialsProvider) {
+        this.credentials = credentialsProvider;
     }
 
     /**