Class BrokerConnector

Service is responsible for handling all STOMP communications over a socket.

Hierarchy

BrokerConnector

Implements

EventBusEnabled

Constructors

constructor

new BrokerConnector(log: Logger): BrokerConnector

- Defined in src/bridge/broker-connector.ts:116
Parameters
- log: Logger
Returns BrokerConnector

Properties

connectDelay

connectDelay: number = 20

connectingMap

connectingMap: Map<string, boolean> = ...

reconnectDelay

reconnectDelay: number = 5000

Static serviceName

serviceName: string = 'stomp.service'

Accessors

galacticChannels

get galacticChannels(): Map<string, { connectedBrokers: number }>

- Defined in src/bridge/broker-connector.ts:174
Returns Map<string, { connectedBrokers: number }>

privateChannels

get privateChannels(): Map<string, {}>

- Defined in src/bridge/broker-connector.ts:178
Returns Map<string, {}>

sessions

get sessions(): Map<string, StompSession>

- Defined in src/bridge/broker-connector.ts:186
Returns Map<string, StompSession>

Methods

connectClient

connectClient(config: StompConfig): void

- Defined in src/bridge/broker-connector.ts:508
Parameters
- config: StompConfig
Returns void

disconnectClient

disconnectClient(sessionId: string): void

- Defined in src/bridge/broker-connector.ts:611
Parameters
- sessionId: string
Returns void

getName

getName(): string

Implementation of EventBusEnabled.getName
- Defined in src/bridge/broker-connector.ts:120
Returns string

getSession

getSession(id: string): StompSession

- Defined in src/bridge/broker-connector.ts:182
Parameters
- id: string
Returns StompSession

init

init(bus: TransportEventBus): void

- Defined in src/bridge/broker-connector.ts:137
Parameters
- bus: TransportEventBus
Returns void

sendPacket

sendPacket(data: StompBusCommand): void

- Defined in src/bridge/broker-connector.ts:624
Parameters
- data: StompBusCommand
Returns void

setBus

setBus(bus: TransportEventBus): void

- Defined in src/bridge/broker-connector.ts:133
Parameters
- bus: TransportEventBus
Returns void

subscribeToDestination

subscribeToDestination(data: StompSubscription): void

- Defined in src/bridge/broker-connector.ts:740
Parameters
- data: StompSubscription
Returns void

unsubscribeFromDestination

unsubscribeFromDestination(data: StompSubscription): void

- Defined in src/bridge/broker-connector.ts:817
Parameters
- data: StompSubscription
Returns void

Static fireConnectCommand

fireConnectCommand(bus: EventBus, config?: StompConfig): void

- Defined in src/bridge/broker-connector.ts:102
Parameters
- bus: EventBus
- config: StompConfig = null
Returns void

Static fireDisconnectCommand

fireDisconnectCommand(bus: EventBus, sessionId: string): void

- Defined in src/bridge/broker-connector.ts:109
Parameters
- bus: EventBus
- sessionId: string
Returns void

Static fireSubscribeCommand

fireSubscribeCommand(bus: EventBus, sessionId: string, destination: string, subscriptionId: string, isQueue: boolean, brokerPrefix: string): void

- Defined in src/bridge/broker-connector.ts:68
Parameters
- bus: EventBus
- sessionId: string
- destination: string
- subscriptionId: string
- isQueue: boolean
- brokerPrefix: string
Returns void

Static fireSubscriptionCommand

fireSubscriptionCommand(bus: EventBus, sessionId: string, destination: string, subscriptionId: string, subType: string, isQueue: boolean, brokerPrefix: string): void

- Defined in src/bridge/broker-connector.ts:42
Parameters
- bus: EventBus
- sessionId: string
- destination: string
- subscriptionId: string
- subType: string
- isQueue: boolean
- brokerPrefix: string
Returns void

Static fireUnSubscribeCommand

fireUnSubscribeCommand(bus: EventBus, sessionId: string, destination: string, subscriptionId: string, isQueue: boolean, brokerPrefix: string): void

- Defined in src/bridge/broker-connector.ts:85
Parameters
- bus: EventBus
- sessionId: string
- destination: string
- subscriptionId: string
- isQueue: boolean
- brokerPrefix: string
Returns void

Generated using TypeDoc