Options
All
  • Public
  • Public/Protected
  • All
Menu

WebSocket Clover Transport

This is a websocket implementation of the Clover Transport.

Hierarchy

Implements

Index

Constructors

constructor

  • new WebSocketCloverTransport(heartbeatInterval: number, reconnectDelay: number, retriesUntilDisconnect: number, webSocketImplClass: any): WebSocketCloverTransport

Properties

Protected logger

logger: Logger = Logger.create()

messageParser

messageParser: RemoteMessageParser

Protected objectMessageSender

objectMessageSender: ObjectMessageSender

Protected observers

observers: CloverTransportObserver[] = []

Protected ready

ready: Boolean = false

Private reconnectDelay

reconnectDelay: number = 3000

reconnector

reconnector: any = function() {if (!this.shutdown) {try {this.initialize();} catch (e) {this.reconnect();}}}.bind(this)

shutdown

shutdown: boolean = false

prevent reconnects if shutdown was requested

status

status: string = "Disconnected"

webSocket

webSocketImplClass

webSocketImplClass: any

This is the WebSocket implementation. This is odd, but it is how we can keep ourselves from being tied to a browser.

A NodeJS app that uses this library would pass in a different object than a browser implementation. NodeJS has an object that satisfies the requirements of the WebSocket (looks the same).

https://www.npmjs.com/package/websocket

Static METHOD

METHOD: string = "method"

Static PAYLOAD

PAYLOAD: string = "payload"

Methods

clearListeners

  • clearListeners(): void

Private clearWebsocket

  • clearWebsocket(): void

connectionError

dispose

  • dispose(): void

Protected initialize

  • initialize(): void

Protected initializeWithUri

  • initializeWithUri(deviceEndpoint: string): void

Protected notifyDeviceConnected

  • notifyDeviceConnected(): void

Protected notifyDeviceDisconnected

  • notifyDeviceDisconnected(): void

Protected notifyDeviceReady

  • notifyDeviceReady(): void

onClose

onMessage

onMessage_cwscl

onNotResponding

onOpen

onPingResponding

onSendError

  • onSendError(payloadText: string): void

reconnect

  • reconnect(): void

reset

  • reset(): void

sendMessage

  • sendMessage(message: string): number

setObjectMessageSender

subscribe

unsubscribe

Generated using TypeDoc