Options
All
  • Public
  • Public/Protected
  • All
Menu

Class StompClient

Hierarchy

  • StompClient

Implements

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Properties

Static STOMP_ABORT

STOMP_ABORT: string = 'ABORT'

Static STOMP_ACK

STOMP_ACK: string = 'ACK'

Static STOMP_BEGIN

STOMP_BEGIN: string = 'BEGIN'

Static STOMP_COMMIT

STOMP_COMMIT: string = 'COMMIT'

Static STOMP_CONFIGURED

STOMP_CONFIGURED: string = 'CONFIGURED'

Static STOMP_CONNECT

STOMP_CONNECT: string = 'CONNECT'

Static STOMP_CONNECTED

STOMP_CONNECTED: string = 'CONNECTED'

Static STOMP_CONNECTED_DUPLICATE

STOMP_CONNECTED_DUPLICATE: string = 'CONNECTED_DUPLICATE'

Static STOMP_DISCONNECT

STOMP_DISCONNECT: string = 'DISCONNECT'

Static STOMP_DISCONNECTED

STOMP_DISCONNECTED: string = 'DISCONNECTED'

Static STOMP_DISCONNECTING

STOMP_DISCONNECTING: string = 'DISCONNECTING'

Static STOMP_ERROR

STOMP_ERROR: string = 'ERROR'

Static STOMP_INVALIDMONITOR

STOMP_INVALIDMONITOR: string = 'INVALID_MONITOR'

Static STOMP_MESSAGE

STOMP_MESSAGE: string = 'MESSAGE'

Static STOMP_RECEIPT

STOMP_RECEIPT: string = 'RECEIPT'

Static STOMP_SEND

STOMP_SEND: string = 'SEND'

Static STOMP_SUBSCRIBE

STOMP_SUBSCRIBE: string = 'SUBSCRIBE'

Static STOMP_SUBSCRIBED

STOMP_SUBSCRIBED: string = 'SUBSCRIBED'

Static STOMP_UNSUBSCRIBE

STOMP_UNSUBSCRIBE: string = 'UNSUBSCRIBE'

Static STOMP_UNSUBSCRIBED

STOMP_UNSUBSCRIBED: string = 'UNSUBSCRIBED'

Accessors

clientSocket

  • get clientSocket(): any

connectionState

socketACKObserver

socketCloseObserver

  • get socketCloseObserver(): Observable<CloseEvent>

socketConnectedObserver

  • get socketConnectedObserver(): Subject<Boolean>

socketErrorObserver

  • get socketErrorObserver(): Observable<Error>

socketMessageObserver

  • get socketMessageObserver(): Observable<MessageEvent<any>>

socketOpenObserver

  • get socketOpenObserver(): Observable<Event>

socketSubscriptionObserver

Methods

abort

  • abort(txId: string): void

beginTransaction

connect

  • connect(config: StompConfig, messageHeaders?: any): Subject<Boolean>

disconnect

  • disconnect(messageHeaders?: any): void

getName

  • getName(): string

getSubscription

send

  • send(destination: string, messageHeaders?: any, body?: any): boolean

sendHeartbeat

  • sendHeartbeat(): void

subscribeToDestination

  • subscribeToDestination(destination: string, id: string, headers?: any): Subject<StompMessage>

unsubscribeFromDestination

  • unsubscribeFromDestination(id: string, headers?: any): void

useMockSocket

  • useMockSocket(): void

Generated using TypeDoc