Uses of Class
com.iohao.net.framework.communication.eventbus.EventBusMessage
Packages that use EventBusMessage
Package
Description
CoreFramework - Communication
CoreFramework - Communication - Distributed EventBus, the distributed event bus is similar to products such as Guava EventBus, Redis Publish/Subscribe, and MQ.
CoreFramework - Flow
Aeron NetServer
Aeron NetServer - Codec
-
Uses of EventBusMessage in com.iohao.net.framework.communication
Methods in com.iohao.net.framework.communication with parameters of type EventBusMessageModifier and TypeMethodDescriptionvoidEventBusMessageCommunication.fireRemote(EventBusMessage message) -
Uses of EventBusMessage in com.iohao.net.framework.communication.eventbus
Methods in com.iohao.net.framework.communication.eventbus that return EventBusMessageModifier and TypeMethodDescriptiondefault EventBusMessageEventBus.createEventBusMessage(Object eventSource) Create an event messageEventBusMessage.ofClone(int serverId) Methods in com.iohao.net.framework.communication.eventbus with parameters of type EventBusMessageModifier and TypeMethodDescriptionvoidEventBusListener.emptySubscribe(EventBusMessage eventBusMessage, EventBus eventBus) Listener callback triggered when the event message has no corresponding subscribervoidEventBus.fire(EventBusMessage eventBusMessage) [Asynchronous] Send an event to all subscribersvoidEventBus.fireAny(EventBusMessage eventBusMessage) [Asynchronous] Send event messages to subscribers in the current process and subscribers in remote processes.voidEventBus.fireAnySync(EventBusMessage eventBusMessage) [Synchronous] Send event messages to subscribers in the current process and subscribers in remote processes.voidEventBus.fireLocal(EventBusMessage eventBusMessage) [Asynchronous] Send event messages to subscribers of all logic servers in the current processvoidEventBus.fireLocalSync(EventBusMessage eventBusMessage) [Synchronous] Send event messages to subscribers of all logic servers in the current processvoidEventBus.fireMe(EventBusMessage eventBusMessage) [Asynchronous] Send event messages only to the subscribers of the current EventBusvoidEventBus.fireMeSync(EventBusMessage eventBusMessage) [Synchronous] Send event messages only to the subscribers of the current EventBusvoidEventBus.fireSync(EventBusMessage eventBusMessage) [Synchronous] Send an event to all subscribersvoidSubscriberInvoke.invoke(EventBusMessage eventBusMessage) Execute subscriber methodvoidEventBusListener.invokeException(Throwable e, Object eventSource, EventBusMessage eventBusMessage) Subscriber exception handlingEventBusRegion.listLocalSubscriber(EventBusMessage eventBusMessage) Gets all subscribers in the current process based on the event messageEventBusRegion.listRemoteEventServerMessage(EventBusMessage eventBusMessage) EventBus.listSubscriber(EventBusMessage eventBusMessage) Subscribers corresponding to the event messageSubscribeExecutorStrategy.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 EventBusMessageModifier and TypeMethodDescriptiondefault EventBusMessageFlowCommunicationEventBus.ofEventBusMessage(Object eventSource) -
Uses of EventBusMessage in com.iohao.net.server
Methods in com.iohao.net.server with parameters of type EventBusMessageModifier and TypeMethodDescriptionvoidDefaultCommunicationAggregation.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 EventBusMessageMethods in com.iohao.net.server.codec with parameters of type EventBusMessageModifier and TypeMethodDescriptionvoidEventBusMessageSbe.encoder(EventBusMessage message, MessageHeaderEncoder headerEncoder, org.agrona.MutableDirectBuffer buffer)