Options
All
  • Public
  • Public/Protected
  • All
Menu

Class MessagingContribution

Hierarchy

Implements

Index

Properties

Protected Readonly channelHandlers

channelHandlers: ConnectionHandlers<WebSocketChannel> = new MessagingContribution.ConnectionHandlers<WebSocketChannel>()

Protected checkAliveTimeout

checkAliveTimeout: number = 30000

Protected Readonly connectionModules

connectionModules: ContributionProvider<ContainerModule>

Protected Readonly container

container: Container

Protected Readonly contributions

Protected webSocketServer

webSocketServer: ws.Server | undefined

Protected Readonly wsHandlers

wsHandlers: ConnectionHandlers<WebSocket> = new MessagingContribution.ConnectionHandlers<ws>()

Protected Readonly wsRequestValidator

wsRequestValidator: WsRequestValidator

Methods

Protected createChannel

Protected createSocketContainer

  • createSocketContainer(socket: ws): Container

forward

  • forward(spec: string, callback: (params: PathParams, connection: IConnection) => void): void

Protected getConnectionChannelHandlers

Protected handleChannels

  • handleChannels(socket: ws): void

Protected handleConnection

  • handleConnection(socket: ws, request: IncomingMessage): void

Protected handleHttpUpgrade

  • handleHttpUpgrade(request: IncomingMessage, socket: Socket, head: Buffer): void

Protected init

  • init(): void

listen

  • listen(spec: string, callback: (params: PathParams, connection: MessageConnection) => void): void

onStart

  • onStart(server: Server | Server): void

ws

  • ws(spec: string, callback: (params: PathParams, socket: ws) => void): void

wsChannel