Reference to the broker connector.
Reference to fabric API.
Reference to Store API.
Reference to ngZone.
Get instance of syslog
singleton logger bound to bus.
Close a channel. If the closer is the last subscriber, then the channel is destroyed.
channel name you want to close.
optional calling actor (for logging)
true if channel can be closed or not.
Unsubscribe from a Galactic Channel. Will send an UNSUBSCRIBE message to broker.
optional calling actor (for logging)
Connect up the bridge to a new broker.
fires once the bridge is connected correctly.
of the broker you're connecting to
topic prefix (defaults to /topic)
queue prefic (defaults to /queue)
defaults to 1, handles multi-connect states according to relay count
the host of the STOMP broker you want to connect to
the port of the STOMP broker you want to connect to
set the prefix for app published (galactic) messages (i.e. /pub) channels are postpended to this (i.e. /pub/mychannel)
username (if required)
passwowrd (if required)
run over WSS?
Automaticallty reconnect on loss of socket? Defaults to true.
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.
type of transaction you want, synchonrous or asynchronous (default).
the name of the transaction, helps you track progress in the console (if enabled)
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.
name of the channel to check
true if mapped.
Listen to all inbound messages send on local broker mapped channel. All messages will be responses.
name of the broker mapped destination
optional calling actor (for logging)
optional galactic configuration containing broker destination and channel publicity
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.
channel to listen to for responses.
optional name of actor implementing (for logging)
optional ID of message you're looking for, will filter out all other messages
{MessageHandler
Listen to a channel for a single command, handle the command then stop online for any other new requests.
the channel to listen to for requests
optional name of actor implementing (for logging)
optional ID of message you're looking for, will filter out all other messages
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.
the channel to listen to for requests
optional name of actor implementing (for logging)
optional ID of message you're looking for, will filter out all other messages
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.
the channel to listen to for responses.
optional name of the actor implementing (for logging)
optional ID of message you're looking for, will filter out all other messages
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.
name of the channel
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.
name of the channel
Marks channels as galactic.
a collection of channel names.
Marks channels as local.
a collection of channel names.
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.
the channel to send the initial command to
the payload to be sent as the command
the return channel to listen for responses on (defaults to sendChannel)
optional name of the actor implementing (for logging)
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.
the UUID of the message.
the channel to send the command to
the payload you want to send.
the return channel to listen for responses on (defaults to send channel)
options name of the actor implementing (for logging)
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.
the channel to send the initial command to
the paylaod to be sent as the command
the return channel to listen for responses on (defaults to sendChannel)
optional name of the actor implementing (for logging)
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.
UUID of the message you want to sent, can also be used as a filter for incoming messages.
the channel on which you want to send your payload
the payload you want to send.
the return channel on which you want to listen.
optional name of the actor implementing (for logging)
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.
the channel to listen for requests
the channel to send responses to (defaults to sendChannel if left blank
optional name of actor implementing method (for logging)
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.
the channel to listen for requests
the channel to send responses to (defaults to sendChannel if left blank)
optional name of actor implementing method (for logging)
reference to MessageResponder, generate() function returns response payload.
Send error payload to channel.
the channel to send the payload to
the payload to be send
optional name of sending actor (for logging)
optional flag, only required when messages originated in another bus.
Send error payload to channel, with an ID.
the channel to send the payload to
the payload to be send
optional name of sending actor (for logging)
optional flag, only required when messages originated in another bus.
Send error payload to channel, with an ID, and a version.
the channel to send the payload to
the payload to be send
the UUID you want to send with this error.
version of the error you want to sent.
optional name of sending actor (for logging)
optional flag, only required when messages originated in another bus.
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.
galactic channel name to send to
payload of message
optional calling actor (for logging)
Send command payload to channel.
channel name to send payload to
the payload to be sent
option name of sending actor (for logging)
Send a command payload to a channel with a supplied ID in the command
channel to send the payload to
the payload to be sent
the ID you want to attach to your command
optional name of the sending actor (for logging)
optional flag, only required when messages originated in another bus.
Send a command payload to a channel with a supplied ID in the command
channel to send the payload to
the payload to be sent
the ID you want to attach to your command
version of command you want to sent (defaults to 1)
optional name of the sending actor (for logging)
optional flag, only required when messages originated in another bus.
Send response payload to a channel.
channel name to send payload to
the payload to be sent
optional name of sending actor (for logging)
Send a response payload to a channel with a supplied ID in the response.
the channel name to send the response payload to
the payload you want to send in response
the ID you want to attach to your response
optional name of the sending actor (for logging)
optional flag, only required when messages originated in another bus.
Send a response payload to a channel with a supplied ID in the response.
the channel name to send the response payload to
the payload you want to send in response
the ID you want to attach to your response
version of command you want to sent (defaults to 1)
optional name of the sending actor (for logging)
optional flag, only required when messages originated in another bus.
Set NgZone reference for efficient macro task scheduling in Angular apps
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.