fix: passing event without value to listener

tomasAlabes · Dec 31, 2019 · dba2dfa · dba2dfa
1 parent b9b0bff
commit dba2dfa
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/dist/kafka-pubsub.js b/dist/kafka-pubsub.js
diff --git a/dist/kafka-pubsub.js.map b/dist/kafka-pubsub.js.map
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "graphql-kafkajs-subscriptions",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Apollo graphql subscription over Kafka protocol",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",

diff --git a/src/kafka-pubsub.ts b/src/kafka-pubsub.ts
@@ -58,7 +58,7 @@ export class KafkaPubSub implements PubSubEngine {
 		} // no subscribers, don't publish msg
 		for (const subId of subscriptions) {
 			const [cnl, listener] = this.subscriptionMap[subId];
-			listener(message.value);
+			listener(message);
 		}
 	}