Uses of Class
com.iohao.net.framework.communication.eventbus.EventBusMessage

Packages that use EventBusMessage

Package	Description
com.iohao.net.framework.communication	Provides communication contracts and adapters used for request/response delivery, broadcasts, and cross-service messaging within the framework runtime.
com.iohao.net.framework.communication.eventbus	Provides distributed EventBus contracts for publishing and subscribing cross-service events within ionet applications.
com.iohao.net.framework.core.flow	Provides the action invocation flow model, context propagation, and execution pipeline contracts used to process business requests end to end.
com.iohao.net.server	Net-server bootstrap, routing, load-balancing, and connection coordination components.
com.iohao.net.server.codec	SBE encoders used by net-server for center registration and peer events.

Uses of EventBusMessage in com.iohao.net.framework.communication

Methods in com.iohao.net.framework.communication with parameters of type EventBusMessage

Modifier and Type	Method	Description
void	EventBusMessageCommunication.fireRemote(EventBusMessage message)	Fire an event bus message to remote logic servers.

Uses of EventBusMessage in com.iohao.net.framework.communication.eventbus

Methods in com.iohao.net.framework.communication.eventbus that return EventBusMessage

Modifier and Type	Method	Description
EventBusMessage	EventBusMessageCreator.create(Object eventSource)	Create an EventBusMessage from the given event source.
default EventBusMessage	EventBus.createEventBusMessage(Object eventSource)	Create an event message
EventBusMessage	EventBusMessage.ofClone(int serverId)	Create a shallow clone of this message targeting a different server ID.

Methods in com.iohao.net.framework.communication.eventbus with parameters of type EventBusMessage

Modifier and Type	Method	Description
void	EventBusListener.emptySubscribe(EventBusMessage eventBusMessage, EventBus eventBus)	Listener callback triggered when the event message has no corresponding subscriber
void	EventBus.fire(EventBusMessage eventBusMessage)	[Asynchronous] Send an event to all subscribers
void	EventBus.fireAny(EventBusMessage eventBusMessage)	[Asynchronous] Send event messages to subscribers in the current process and subscribers in remote processes.
void	EventBus.fireAnySync(EventBusMessage eventBusMessage)	[Synchronous] Send event messages to subscribers in the current process and subscribers in remote processes.
void	EventBus.fireLocal(EventBusMessage eventBusMessage)	[Asynchronous] Send event messages to subscribers of all logic servers in the current process
void	EventBus.fireLocalSync(EventBusMessage eventBusMessage)	[Synchronous] Send event messages to subscribers of all logic servers in the current process
void	EventBus.fireMe(EventBusMessage eventBusMessage)	[Asynchronous] Send event messages only to the subscribers of the current EventBus
void	EventBus.fireMeSync(EventBusMessage eventBusMessage)	[Synchronous] Send event messages only to the subscribers of the current EventBus
void	EventBus.fireSync(EventBusMessage eventBusMessage)	[Synchronous] Send an event to all subscribers
void	SubscriberInvoke.invoke(EventBusMessage eventBusMessage)	Execute subscriber method
void	EventBusListener.invokeException(Throwable e, Object eventSource, EventBusMessage eventBusMessage)	Subscriber exception handling
List<Subscriber>	EventBusRegion.listLocalSubscriber(EventBusMessage eventBusMessage)	Gets all subscribers in the current process based on the event message
Set<EventServerMessage>	EventBusRegion.listRemoteEventServerMessage(EventBusMessage eventBusMessage)	Get remote server messages that have subscribers for the given event.
Collection<Subscriber>	EventBus.listSubscriber(EventBusMessage eventBusMessage)	Subscribers corresponding to the event message
ThreadExecutor	SubscribeExecutorStrategy.select(Subscriber subscriber, EventBusMessage eventBusMessage, ExecutorRegion executorRegion)	Get the corresponding thread executor

Uses of EventBusMessage in com.iohao.net.framework.core.flow

Methods in com.iohao.net.framework.core.flow that return EventBusMessage

Modifier and Type	Method	Description
default EventBusMessage	FlowCommunicationEventBus.ofEventBusMessage(Object eventSource)

Uses of EventBusMessage in com.iohao.net.server

Methods in com.iohao.net.server with parameters of type EventBusMessage

Modifier and Type	Method	Description
void	DefaultCommunicationAggregation.fireRemote(EventBusMessage message)

Uses of EventBusMessage in com.iohao.net.server.codec

Classes in com.iohao.net.server.codec that implement interfaces with type arguments of type EventBusMessage

Modifier and Type	Class	Description
final class	EventBusMessageSbe	SBE encoder for cross-server event-bus messages.

Methods in com.iohao.net.server.codec with parameters of type EventBusMessage

Modifier and Type	Method	Description
void	EventBusMessageSbe.encoder(EventBusMessage message, MessageHeaderEncoder headerEncoder, org.agrona.MutableDirectBuffer buffer)