Merge pull request #2 from moleculerjs/master

update

.eslintrc.js

@@ -52,6 +52,18 @@ module.exports = {
 		"security/detect-non-literal-require": ["off"],
 		"security/detect-non-literal-fs-filename": ["off"],
 		"no-process-exit": ["off"],
-		"node/no-unpublished-require": 0
+		"node/no-unpublished-require": 0,
+		"space-before-function-paren": [
+			"warn",
+			{
+				"anonymous": "never",
+				"named": "never",
+				"asyncArrow": "always"
+			}
+		],
+		"object-curly-spacing": [
+			"warn",
+			"always"
+		]
 	}
 };

dev/dev.js

@@ -1,19 +1,11 @@
-"use strict";
-
+const ApiGateway = require
 const ServiceBroker = require("../src/service-broker");
 const util = require("util");
 
 const broker = new ServiceBroker({
 	nodeID: "dev",// + process.pid,
 	//transporter: "mqtt://localhost:1833",
-	transporter: {
-		type: "MQTT",
-		options: {
-			host: "localhost",
-			qos: 1,
-			topicSeparator: "/"
-		}
-	},
+	transporter: "TCP",
 	metrics: true,
 	//logLevel: "debug",
 	//logObjectPrinter: o => util.inspect(o, { depth: 4, colors: true, breakLength: 50 }), // `breakLength: 50` activates multi-line object
@@ -22,7 +14,8 @@ const broker = new ServiceBroker({
 broker.createService({
 	name: "test",
 	actions: {
-		hello(ctx) {
+		async hello(ctx) {
+			await this.broker.cacher.del('test.*');
 			return "Hello Moleculer";
 		}
 	}

index.d.ts

@@ -206,6 +206,7 @@ declare namespace Moleculer {
 	}
 
 	interface BrokerTransitOptions {
+		disableReconnect?: boolean;
 		maxQueueSize?: number;
 	}