Merge pull request #54 from dandalf/master

v 1.5.1 fix silent error on subsequent invocations
awslabs · Sep 20, 2017 · caa66c5 · caa66c5
2 parents 938a38c + c32e920
commit caa66c5
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 3 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -0,0 +1,2 @@
+# 1.5.1
+* Fixed bug where only the first event would write to Firehose.
diff --git a/dist/LambdaStreamToFirehose-1.5.1.zip b/dist/LambdaStreamToFirehose-1.5.1.zip
diff --git a/index.js b/index.js
@@ -41,7 +41,7 @@ var useTransformer;
 function setTransformer(transformer) {
     useTransformer = transformer
 }
-exports.setTransformer = setTransformer
+exports.setTransformer = setTransformer;
 
 /*
  * Configure destination router. By default all records route to the configured
@@ -57,7 +57,7 @@ var useRouter = router.defaultRouting.bind(undefined);
 function setRouter(router) {
     useRouter = router
 }
-exports.setRouter = setRouter
+exports.setRouter = setRouter;
 // example for using routing based on messages attributes
 // var attributeMap = {
 // "binaryValue" : {
@@ -137,6 +137,8 @@ function init(callback) {
 		callback(null);
 	    }
 	});
+    } else {
+      callback(null);
     }
 }
 exports.init = init;

diff --git a/package.json b/package.json
@@ -1,7 +1,7 @@
 {
 	"name": "lambda-stream-to-firehose",
 	"description": "An AWS Lambda function that forwards data from a Kinesis or DynamoDB Update Stream to a Kinesis Firehose Delivery Stream",
-	"version": "1.5.0",
+	"version": "1.5.1",
 	"dependencies": 
 	{
 		"async": "2.1.4",
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		# 1.5.1
		* Fixed bug where only the first event would write to Firehose.