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

Packages that use EventBusMessage

Package	Description
com.iohao.net.framework.communication	CoreFramework - Communication
com.iohao.net.framework.communication.eventbus	CoreFramework - Communication - Distributed EventBus, the distributed event bus is similar to products such as Guava EventBus, Redis Publish/Subscribe, and MQ.
com.iohao.net.framework.core.flow	CoreFramework - Flow
com.iohao.net.server	Aeron NetServer
com.iohao.net.server.codec	Aeron NetServer - Codec

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)

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)
default EventBusMessage	EventBus.createEventBusMessage(Object eventSource)	Create an event message
EventBusMessage	EventBusMessage.ofClone(int serverId)

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)
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

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)