NatsClient class
Constructors
- NatsClient(String _currentHost, int _currentPort, {Level logLevel = Level.INFO})
Properties
- currentHost → String
-
no setter
- currentPort → int
-
no setter
- hashCode → int
-
The hash code for this object.
no setterinherited
- log → Logger
-
final
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
- tcpClient ↔ TcpClient
-
getter/setter pair
Methods
-
connect(
{ConnectionOptions? connectionOptions, void onClusterupdate(ServerInfo? info)?}) → Future< void> - Connects to the given NATS url
-
matchesRegex(
String listeningSubject, String incomingSubject) → bool -
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
publish(
String message, String subject, {String? replyTo}) → void -
Publishes the
message
to thesubject
with an optionalreplyTo
set to receive the response -
subscribe(
String subscriberId, String subject, {String? queueGroup}) → Stream< NatsMessage> -
Subscribes to the
subject
with a givensubscriberId
and an optionalqueueGroup
set to group the responses -
toString(
) → String -
A string representation of this object.
inherited
-
unsubscribe(
String subscriberId, {int? waitUntilMessageCount}) → void
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited