From d746c2529a455bc50510fac00b67336588d4a30b Mon Sep 17 00:00:00 2001
From: dan <dan@ezoic.com>
Date: Fri, 3 Apr 2015 23:14:08 -0700
Subject: [PATCH] more log4go additions

---
 kinesis.go                   | 8 ++++----
 redshift_manifest_emitter.go | 2 +-
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/kinesis.go b/kinesis.go
index 1d66ca7..5475189 100644
--- a/kinesis.go
+++ b/kinesis.go
@@ -1,10 +1,10 @@
 package connector
 
 import (
-	"fmt"
 	"time"
 
 	"github.com/ezoic/go-kinesis"
+	l4g "github.com/ezoic/sol/log4go"
 )
 
 // CreateStream creates a new Kinesis stream (uses existing stream if exists) and
@@ -14,7 +14,7 @@ func CreateStream(k *kinesis.Kinesis, streamName string, shardCount int) {
 		err := k.CreateStream(streamName, shardCount)
 
 		if err != nil {
-			fmt.Printf("CreateStream ERROR: %v\n", err)
+			l4g.Error("CreateStream ERROR: %v", err)
 			return
 		}
 	}
@@ -27,7 +27,7 @@ func CreateStream(k *kinesis.Kinesis, streamName string, shardCount int) {
 		args.Add("StreamName", streamName)
 		resp, _ = k.DescribeStream(args)
 		streamStatus := resp.StreamDescription.StreamStatus
-		fmt.Printf("Stream [%v] is %v\n", streamName, streamStatus)
+		l4g.Info("Stream [%v] is %v", streamName, streamStatus)
 
 		if streamStatus != "ACTIVE" {
 			time.Sleep(4 * time.Second)
@@ -43,7 +43,7 @@ func StreamExists(k *kinesis.Kinesis, streamName string) bool {
 	args := kinesis.NewArgs()
 	resp, err := k.ListStreams(args)
 	if err != nil {
-		fmt.Printf("ListStream ERROR: %v\n", err)
+		l4g.Error("ListStream ERROR: %v", err)
 		return false
 	}
 	for _, s := range resp.StreamNames {
diff --git a/redshift_manifest_emitter.go b/redshift_manifest_emitter.go
index 4780e0a..d633a46 100644
--- a/redshift_manifest_emitter.go
+++ b/redshift_manifest_emitter.go
@@ -123,7 +123,7 @@ func (e RedshiftManifestEmitter) writeManifestToS3(files []string, manifestFileN
 	content := e.generateManifestFile(files)
 	err := bucket.Put(manifestFileName, content, "text/plain", s3.Private, s3.Options{})
 	if err != nil {
-		fmt.Printf("Error occured while uploding to S3: %v\n", err)
+		l4g.Error("Error occured while uploding to S3: %v", err)
 	}
 }