cmf-core
  1. Injectables
  2. MessageBusService

File

src/lib/extensions/message-bus.service.ts

Index

Properties
Methods
Accessors

Constructor

constructor(mediator: MediatorService, config: ConfigService, loadBalancer: LoadBalancerService, security: SecurityCacheService, JSON: JSONService, zone: NgZone)

Initialization function

Parameters :
Name Type Optional
mediator MediatorService No
config ConfigService No
loadBalancer LoadBalancerService No
security SecurityCacheService No
JSON JSONService No
zone NgZone No

Methods

publish
publish(subject: string, message: any)
Parameters :
Name Type Optional
subject string No
message any No
Returns : void
publishWithReply
publishWithReply(subject: string, replySubject: string, message: any)
Parameters :
Name Type Optional
subject string No
replySubject string No
message any No
Returns : void
reply
reply(requestMessage: MbMessage, replyMessage: any)
Parameters :
Name Type Optional
requestMessage MbMessage No
replyMessage any No
Returns : void
sendRequest
sendRequest(subject: string, message: any, timeout: number)
Parameters :
Name Type Optional Default value
subject string No
message any No
timeout number No 10000
Returns : Promise<MbMessage>
subscribe
subscribe(subject: string, callback: MessageBusCallback<any>)
Parameters :
Name Type Optional
subject string No
callback MessageBusCallback<any> No
Returns : void
unsubscribe
unsubscribe(subject: string, callback: MessageBusCallback<any>)
Parameters :
Name Type Optional
subject string No
callback MessageBusCallback<any> No
Returns : void

Properties

Public client
Type : Transport

Accessors

PROTOCOL
getPROTOCOL()
HOST_ADDRESS
getHOST_ADDRESS()
HOST_PORT
getHOST_PORT()
CURRENT_ENDPOINT
getCURRENT_ENDPOINT()
isConnected
getisConnected()
transportId
gettransportId()

Transport Unique Id

Returns : string

results matching ""

    No results matching ""