Returns the map for monitoring externally (read-only)
Quick access to logger instance for spies and testing.
Subscription to Subject that schedules Angular change detection.
Close a channel. If the closer is the last subscriber, then the channel is destroyed.
channel you want to close
optional calling actor (for logging)
optional id of observer closing (leaving) the channel.
Complete the channel stream.
channel you want to complete. This channel will no longer broadcast to subscribers.
Total number of listeners across all channels.
Destroy all channels, regardless of whether they still have subscribers. This is intended to be used in afterEach during jasmine tests, so that subscribers from previous tests never fire in subsequent tests.
Turn logging on/off
turn logging on/off.
Transmit error on a channel if it exists.
true if error can be sent, false if not.
Get a subscribable stream from channel. If the channel doesn't exist, it will be created. Automatically unpack wrapped messages.
name of the channel you want to subscribe to.
optional calling actor (for logging)
optional - will prevent internal reference counting (defaults to false)
Observable that can be subscribed to, Message object will be ticked on stream.
A new channel is created by the first reference to it. All subsequent references to that channel are handed the same stream to subscribe to. Accessing this method increments the channels reference count. This method subscribes to both command and response messages. See below for specific directional methods. This method is not filtered.
This is a raw object that encapsulates the channel stream.
the name of the channel you want.
optional calling actor (for logging)
optional - will prevent internal reference counting (defaults to false)
choose to broadcast events to the monitor (defaults to true)
Filter bus events that contain error messages only. Returns an Observable with un-marshaled Message payload.
name of the channel you want to listen to.
optional calling actor (for logging)
optional - will prevent internal reference counting (defaults to false)
Observable that will emit an error Message to any subscribers.
Get or create a galactic channel. Channel will be mapped to broker destination and picked up by the bridge.
optional - galactic configuration containing information including broker connection string and whether channel is private or not
optional - will prevent internal reference counting (defaults to false)
Get uuid of the bus.;
Get a subscription to the monitor channel.
live stream of bus events.
Get raw monitor channel object.
Filter bus events that contain command messages only. Returns an Observable with un-marshaled Message payload.
of the channel you want to listen to.
optional calling actor (for logging)
optional - will prevent internal reference counting (defaults to false)
Observable that will emit a command Message to any subscribers.
Filter bus events that contain response messages only. Returns an Observable with un-marshaled Message payload.
name of the channel you want to listen to.
optional calling actor (for logging)
optional - will prevent internal reference counting (defaults to false)
Observable that will emit a response Message to any subscribers.
Increment a channel ref count. This should only be used by extensions manipulating streams.
channel you want to increment
the new refcount.
Get current event bus logging state.
true if enabled.
Used internally to interact with simpler API's in main event bus.
message handler configuration object.
listen to requests? defaults to responses only.
optional calling actor (for logging)
enable message tracking if this is supplied
reference to MessageHandler
Access to private logger so messages can be sequentialized.
reference to the logger service.
For external access to messagebus private logger (so output streams are sequentialized).
log message
optional calling actor (for logging).
Get handle of NgZone
Get a count of how many references there are to a channel.
name of the channel
number of references currently held.
Used internally to send messages to simpler API's in main event bus.
message handler configuration object.
optional calling actor (for logging)
enable message tracking if this is supplied
reference to MessageHandler
Used internally to send messages to simple API's in main event bus.
message handler configuration object.
optional calling actor (for logging)
enable message tracking if this is supplied
reference to MessageResponder
Transmit arbitrary data on a channel on the message bus if it exists. This routine is called with traceback strings to allow for debugging and monitoring bus traffic.
channel to send to.
Message to be sent.
optional calling actor (for logging)
true if message can be sent, false if not.
Send simple API message to MessageResponder enabled calls. (non low-level API's)
Send simple API message to MessageResponder enabled calls. (non low-level API's)
channel name to send response to.
payload to send to simple API.
option name of calling actor (for logging)
Set the log to the desired LogLevel
the level you want to set.
Set up Subject and subscribe to it that will fire as messages are emitted to trigger Angular change detection. As the name implies, should only be used when in Angular apps.
Silence the log.
the flag to true or false
Set the log suppression on or off
the flag
Push function onto the queue for next event loop tick.
function you want to execute asynchronously.
milliseconds you want to delay execution by.
Generated using TypeDoc
Event Bus Lower Level API's are available if more control over channels is required, or building extensions using the Monitor API.