Reference to the broker connector.
Reference to fabric API.
Reference to Store API.
Reference to ngZone.
Close a channel. If the closer is the last subscriber, then the channel is destroyed.
true if channel can be closed or not.
Unsubscribe from a Galactic Channel. Will send an UNSUBSCRIBE message to broker.
Connect up the bridge to a new broker.
connected commands will auto trigger the readyHandler().
Create a new transaction that can be composed of bus requests, cache initializations or both. Asynchronous transactions will all fire at once and return once all requests return. Syrnchonrous transactions will fire in sequence and only proceed to the next transaction event once the preceeding response has returned.
Perform any cleanups to free up any resources for garbage collection
Enable Fake Socket for broker connector
Enable message proxying between frames, or what ever else we can think of.
Check if a channel is marked as Galactic (mapped to broker) or not.
true if mapped.
Listen to all inbound messages send on local broker mapped channel. All messages will be responses.
reference to MessageHandler. All responses will be handled via the handle() method.
Listen for a single response on a channel, process then automatically stop handling any more.
{MessageHandler
Listen to a channel for a single command, handle the command then stop online for any other new requests.
reference to MessageHandler, then handle() function will only fire once.
Listen to a channel for all requests, continue handling requests until the handler is closed.
reference to MessageHandler, then handle() function will continue to fire until closed.
Listen for all responses on a channel. Continue to handle until the stream is closed via the handler.
reference to MessageHandler. the handle() function will process all responses until closed.
Marks a channel as galactic. All messages sent to the channel with the "channelName" name will be transmitted to the remote destinations.
Marks a channel as local. All messages sent to a local channel will be sent to local destinations and will NOT be sent to remote destinations.
Marks channels as galactic.
Marks channels as local.
Send a command payload to sendChannel and listen for a single response on returnChannel (defaults to sendChannel if left blank). The handle() method on the MessageHandler instance is used to process incoming responses. The handler will stop processing any further responses after the first one.
reference to MessageHandler, handle() function receives any inbound response.
Send a command payload to sendChannel with a message ID. Listens for a single response on returnChannel, but only for a response with the same matching ID. Ideal for multi-message sessions where multiple consumers are requesting at the same time on the same. (defaults to sendChannel if left blank). The handle() method on the MessageHandler instance is used to process incoming responses. The handler will stop processing any further responses after the first one.
reference to MessageHandler handle() function received any inbound responses.
Send a command payload to sendChannel and listen for responses on returnChannel (defaults to sendChannel if left blank). Any additional responses will continue to be handled by the MessageHandler instance returned. The handle() method on the MessageHandler instance is used to process incoming responses. The handler will continue to trigger with each new response, until it is closed.
reference to MessageHandler, handle() function receives any inbound responses.
Send a command payload to sendChannel with and ID and listen for responses (also with that ID) on returnChannel (defaults to sendChannel if left blank). Any additional responses will continue to be handled by the MessageHandler instance returned. The handle() method on the MessageHandler instance is used to process incoming responses. The handler will continue to trigger with each new response, until it is closed.
reference to the MessageHandler, handle() function receives any inbound responses.
Listen for a command on sendChannel and return a single response via the generate() method on MessageResponder. The returned value will be sent as a response message on the return channel (defaults to sendChannel if left blank). Once a single response has been sent, no more command messages will be processed.
reference to MessageResponder, generate() function returns response payload.
Listen for requests on sendChannel and return responses via the generate() method on MessageResponder. The returned value will be sent as a response message on the return channel (defaults to sendChannel if left blank). The responder will continue to stream responses to each command until the unubscribe() method is called.
reference to MessageResponder, generate() function returns response payload.
Send error payload to channel.
Send error payload to channel, with an ID.
Send error payload to channel, with an ID, and a version.
Fire a galactic send notification to the montitor like it was a regular send on Observable. The bridge will then pick this up and fire a SEND frame down the wire to that destination.
Send command payload to channel.
Send a command payload to a channel with a supplied ID in the command
Send a command payload to a channel with a supplied ID in the command
Send response payload to a channel.
Send a response payload to a channel with a supplied ID in the response.
Send a response payload to a channel with a supplied ID in the response.
Set NgZone reference for efficient macro task scheduling in Angular apps
Boot and create a singleton EventBus instance with default options
the bus.
Boot and create a singleton EventBus instance with custom options for logging level and boot message
log level to set
set to true to turn off the boot message.
enable dark theme logging (defaults to false)
the bus
Destroy the bus completely.
Reboot the bus, critical for tests, reboot destroys the singleton and re-creates it.
the newly rebooted event bus.
Reboot the bus, critical for tests, reboot destroys the singleton and re-creates it.
log level to set
set true to turn off the boot message.
the newly rebooted bus
If you need to reset the ID of this bus, call this, but it may have undesirable effects. This should only be called when re-booting the bus.
Generated using TypeDoc
Reference to Low Level API.