ActiveBrokerInterface class abstract
The ActiveBrokerInterface is the baseclass for all broker interfaces which inform the user asynchronous (via a callback) when a new message is available.
- Inheritance
-
- Object
- BrokerInterface
- ActiveBrokerInterface
- Implementers
Constructors
- ActiveBrokerInterface.new(AuthenticationManager authManager)
-
Creates a new ActiveBrokerInterface with the given
authManager.
Properties
- authManager → AuthenticationManager
-
The authentication manager used by this instance to get
valid access tokens.
finalinherited
- hashCode → int
-
The hash code for this object.
no setterinherited
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
Methods
-
newMessageReceived(
String messageString) → void - PROTECTED: DO NOT USE THIS METHOD UNLESS YOU ARE AN ActiveBrokerInterface !
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
notifyConsumingFailed(
String endpoint, Exception error) → void - PROTECTED: DO NOT USE UNLESS YOU ARE AN ActiveBrokerInterface.
-
notifySendMessageFailed(
Message message, Exception error) → void - PROTECTED: DO NOT USE UNLESS YOU ARE AN ActiveBrokerInterface.
-
notifySendMessageSucceeded(
Message message) → void - PROTECTED: DO NOT USE UNLESS YOU ARE AN ActiveBrokerInterface.
-
sendMessage(
Message message, Set< String> endpoints) → void -
Publishes the given
messageto allendpoints.inherited -
startConsuming(
String endpoint) → Future< void> - Starts consuming on the endpoint.
-
stopConsuming(
String endpoint) → void - Stops consuming on the endpoint.
-
subscribeConsumingFailed(
dynamic callback(String, Exception)) → void - Subscribes to all errors during consuming from the endpoints. (ConsumingFailed-Event).
-
subscribeEventMessageReceived(
dynamic callback(EventMessage)) → void - Subscribes to all received event messages (EventMessageReceived-Event).
-
subscribeEventSubscriptionRequestReceived(
dynamic callback(EventSubscriptionRequest)) → void - Subscribes to all received EventSubscriptionRequest (EventSubscriptionRequestReceived-Event).
-
subscribeEventSubscriptionResponseReceived(
dynamic callback(EventSubscriptionResponse)) → void - Subscribes to all received EventSubscriptionResponse (EventSubscriptionResponseReceived-Event).
-
subscribeGetValueReplyReceived(
dynamic callback(GetValueReply)) → void - Subscribes to all GetValueReplyReceived-Events.
-
subscribeGetValueRequestReceived(
dynamic callback(GetValueRequest)) → void - Subscribes to all GetValueRequestReceived-Events.
-
subscribeInvalidMessageReceived(
dynamic callback(String, Exception)) → void - Subscribes to all received messages which can't be parsed correctly (InvalidMessageReceived-Event).
-
subscribeSendMessageFailed(
dynamic callback(Message, Exception)) → void - Subscribes to all messages which couldn't be sent correctly (SendMessageFailed-Event).
-
subscribeSendMessageSucceeded(
dynamic callback(Message)) → void - Subscribes to all received messages which can't be parsed correctly (SendMessageSucceeded-Event).
-
subscribeServiceReplyReceived(
dynamic callback(ServiceReply)) → void - Subscribes to all ServiceReplyReceived-Events.
-
subscribeServiceRequestReceived(
dynamic callback(ServiceRequest)) → void - Subscribes to all ServiceRequestReceived-Events.
-
subscribeUserMessageReceived(
dynamic callback(UserMessage)) → void - Subscribes to all received user messages (UserMessageReceived-Event).
-
toString(
) → String -
A string representation of this object.
inherited
-
unsubscribeConsumingFailed(
dynamic callback(String, Exception)) → void - Unsubscribes the callback from the ConsumingFailed-Event.
-
unsubscribeEventMessageReceived(
dynamic callback(EventMessage)) → void - Unsubscribes the callback from the EventMessageReceived-Event.
-
unsubscribeEventSubscriptionRequestReceived(
dynamic callback(EventSubscriptionRequest)) → void - Unsubscribes the callback from the EventSubscriptionRequestReceived-Event.
-
unsubscribeEventSubscriptionResponseReceived(
dynamic callback(EventSubscriptionResponse)) → void - Unsubscribes the callback from the EventSubscriptionResponseReceived-Event.
-
unsubscribeGetValueReplyReceived(
dynamic callback(GetValueReply)) → void - Unsubscribes the callback from the GetValueReplyReceived-Event.
-
unsubscribeGetValueRequestReceived(
dynamic callback(GetValueRequest)) → void - Unsubscribes the callback from the GetValueRequestReceived-Event.
-
unsubscribeInvalidMessageReceived(
dynamic callback(String, Exception)) → void - Unsubscribes the callback from the InvalidMessageReceived-Event.
-
unsubscribeSendMessageFailed(
dynamic callback(Message, Exception)) → void - Unsubscribes the callback from the SendMessageFailed-Event.
-
unsubscribeSendMessageSucceeded(
dynamic callback(Message)) → void - Unsubscribes the callback from the SendMessageSucceeded-Event.
-
unsubscribeServiceReplyReceived(
dynamic callback(ServiceReply)) → void - Unsubscribes the callback from the ServiceReplyReceived-Event.
-
unsubscribeServiceRequestReceived(
dynamic callback(ServiceRequest)) → void - Unsubscribes the callback from the ServiceRequestReceived-Event.
-
unsubscribeUserMessageReceived(
dynamic callback(UserMessage)) → void - Unsubscribes the callback from the UserMessageReceived-Event.
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited