Package com.iohao.net.framework.communication.eventbus
package com.iohao.net.framework.communication.eventbus
Provides distributed EventBus contracts for publishing and subscribing cross-service events
within ionet applications.
See Distributed EventBus; it is conceptually similar to Guava EventBus, Redis Publish/Subscribe, or MQ-style messaging.
- Author:
- 渔民小镇
- date:
- 2024-06-06
-
ClassDescriptionEventBus, the relationship between EventBus, the business framework, and the logic server is 1:1:1.The type triggered when an event is publishedEvent listener, triggered conditions: 1. when a subscriber throws an uncaught exception, 2. when an event message has no corresponding subscriber.Event message carrying the event source data, topic, routing info, and fire type flags for the EventBus system.Factory interface for creating
EventBusMessageinstances from event source objects.Event Bus Management DomainConfiguration interface for the EventBus subsystem, providing factory methods for creating EventBus instances and accessing the EventBus region.Utility class providing static access to the globalEventBusSettingandEventBusRegion.Lifecycle status of an EventBus instance.Marker annotation for event subscriber classes.Holds event topic information and server metadata for a logic server participating in the EventBus system.Subscriber annotation, marks a method as an event subscriber (receives events, processes events), configurable with thread executor strategy and execution priority.Subscriber thread executor selection strategy.Strategy interface for selecting the thread executor used to run a subscriber method.Represents a single event subscriber method bound to anEventBusSubscriberinstance.Strategy interface for invoking a subscriber method when an event is dispatched.Factory interface for creatingSubscriberInvokeinstances fromSubscribermetadata.