Fixing Layers

This commit is contained in:
Martin Karkowski 2021-03-04 12:33:53 +01:00
parent 11a580677f
commit 13cddb909e
4 changed files with 9 additions and 9 deletions

View File

@ -2,7 +2,7 @@
* @author Martin Karkowski * @author Martin Karkowski
* @email m.karkowski@zema.de * @email m.karkowski@zema.de
* @create date 2020-11-04 17:36:04 * @create date 2020-11-04 17:36:04
* @modify date 2021-03-01 17:20:03 * @modify date 2021-03-01 17:41:45
* @desc [description] * @desc [description]
*/ */
@ -59,7 +59,7 @@ export class IoSocketClient extends Bridge implements ICommunicationInterface {
new EventEmitter(), new EventEmitter(),
"individual", "individual",
"individual", "individual",
getNopeLogger("io-socket-server-internal") this._logger
), ),
false, false,
true true

View File

@ -2,7 +2,7 @@
* @author Martin Karkowski * @author Martin Karkowski
* @email m.karkowski@zema.de * @email m.karkowski@zema.de
* @create date 2020-11-06 08:52:42 * @create date 2020-11-06 08:52:42
* @modify date 2021-03-01 17:17:56 * @modify date 2021-03-01 17:43:12
* @desc [description] * @desc [description]
*/ */
@ -46,7 +46,7 @@ export class IoSocketServer extends Bridge {
// Add a default Event-Layer // Add a default Event-Layer
// Perhaps that can be removed. // Perhaps that can be removed.
this.addLayer(new DebuggedEventLayer(new EventEmitter(), "individual","individual",getNopeLogger("io-socket-server-internal", "debug")),false, true); this.addLayer(new DebuggedEventLayer(new EventEmitter(), "individual","individual",null),false, true);
this._logger.info( this._logger.info(
"waiting for connection. Listening on port: " + port.toString() "waiting for connection. Listening on port: " + port.toString()
@ -61,7 +61,7 @@ export class IoSocketServer extends Bridge {
_this._sockets.add(client); _this._sockets.add(client);
// Add the socket as new layer: // Add the socket as new layer:
const _layer = new DebuggedEventLayer(client, "individual","individual", getNopeLogger("io-client-" + client.id, "debug")); const _layer = new DebuggedEventLayer(client, "individual","individual", getNopeLogger("io-client-" + client.id, "info"));
_this.addLayer(_layer, true); _this.addLayer(_layer, true);
// Subscribe to Loosing connection: // Subscribe to Loosing connection:

View File

@ -2,7 +2,7 @@
* @author Martin Karkowski * @author Martin Karkowski
* @email m.karkowski@zema.de * @email m.karkowski@zema.de
* @create date 2021-03-01 15:05:09 * @create date 2021-03-01 15:05:09
* @modify date 2021-03-01 17:20:19 * @modify date 2021-03-01 17:42:12
* @desc [description] * @desc [description]
*/ */
import { EventEmitter } from "events"; import { EventEmitter } from "events";
@ -25,7 +25,7 @@ export class DebuggedEventLayer extends EventLayer {
_emitter: IEmitter = new EventEmitter(), _emitter: IEmitter = new EventEmitter(),
subscriptionMode: "individual" | "generic" = "individual", subscriptionMode: "individual" | "generic" = "individual",
resultSharing: "individual" | "generic" = "individual", resultSharing: "individual" | "generic" = "individual",
_logger = getNopeLogger("debug-layer", "debug") _logger = getNopeLogger("debug-layer", "info")
) { ) {
super(_emitter,subscriptionMode,resultSharing,_logger); super(_emitter,subscriptionMode,resultSharing,_logger);

View File

@ -2,7 +2,7 @@
* @author Martin Karkowski * @author Martin Karkowski
* @email m.karkowski@zema.de * @email m.karkowski@zema.de
* @create date 2020-11-06 16:53:43 * @create date 2020-11-06 16:53:43
* @modify date 2020-12-30 18:37:18 * @modify date 2021-03-01 17:38:11
* @desc [description] * @desc [description]
*/ */
@ -30,7 +30,7 @@ export const DESCRIPTION: IPackageDescription<typeof TYPES> = {
providedClasses: [ providedClasses: [
{ {
description: { description: {
name: "helloworld", name: HelloWorldModuleWithDecorators.prototype.constructor.name.toString(),
selector: TYPES.helloworld, selector: TYPES.helloworld,
type: HelloWorldModuleWithDecorators type: HelloWorldModuleWithDecorators
}, },