use a different session

aws/session/session.go

@@ -1,11 +1,16 @@
 package session
 
-import "github.com/aws/aws-sdk-go/aws/session"
+import (
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/session"
+)
 
 // NewDynamicSession is a factory to emit sessions
 // relevant to the current config, ie:
 //
 // dev, local, sandbox, production
 func NewDynamicSession() *session.Session {
-	return session.Must(session.NewSession())
+	return session.Must(session.NewSession(
+		aws.NewConfig().WithRegion("us-east-1"),
+	))
 }

events/publishers/aws/kinesis/kinesis.go

@@ -3,25 +3,24 @@ package kinesis
 import (
 	"time"
 
+	"github.com/edobtc/cloudkit/aws/session"
 	"github.com/edobtc/cloudkit/config"
 
 	"github.com/aws/aws-sdk-go/aws"
-	"github.com/aws/aws-sdk-go/aws/session"
+
 	"github.com/aws/aws-sdk-go/service/kinesis"
 
 	log "github.com/sirupsen/logrus"
 )
 
-var ApplicationPublisher = NewPublisher()
-
 type Publisher struct {
 	Name   string
 	Buffer []byte
 	svc    *kinesis.Kinesis
 }
 
 func NewPublisher() *Publisher {
-	s := session.Must(session.NewSession())
+	s := session.NewDynamicSession()
 
 	return &Publisher{
 		Buffer: []byte{},
@@ -40,7 +39,6 @@ func (s *Publisher) Send(data []byte) error {
 	if err != nil {
 		return err
 	}
-
 	log.Debug("Publisher debug: ", po.SequenceNumber)
 
 	return nil

events/subscribers/lightning/eclair/ws/ws.go

@@ -53,7 +53,6 @@ func (s *EclairSubscriber) Start() chan bool {
 		for {
 			select {
 			case msg := <-channel:
-				fmt.Println("message received: ", msg)
 				s.listener <- msg
 			case <-s.Close:
 				s.Wait <- true