Class DisruptorManager

java.lang.Object

com.iohao.net.extension.domain.DisruptorManager

public class DisruptorManager
extends Object

Responsible for managing the Disruptor

Author:

渔民小镇

date:

2021-12-26

Constructor Summary

Constructors

Constructor	Description
DisruptorManager()

Method Summary

Modifier and Type	Method	Description
void	forEach(Consumer<com.lmax.disruptor.dsl.Disruptor<CommonEvent>> action)
com.lmax.disruptor.dsl.Disruptor<CommonEvent>	getDisruptor(Class<?> topic)	Get the Disruptor corresponding to the domain message topic
Collection<com.lmax.disruptor.dsl.Disruptor<CommonEvent>>	listDisruptor()	Get all Disruptor
void	put(Class<?> topic, com.lmax.disruptor.dsl.Disruptor<CommonEvent> disruptor)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DisruptorManager

public DisruptorManager()

Method Details

listDisruptor

public Collection<com.lmax.disruptor.dsl.Disruptor<CommonEvent>> listDisruptor()

Get all Disruptor

Returns:

List of Disruptor

forEach

public void forEach(Consumer<com.lmax.disruptor.dsl.Disruptor<CommonEvent>> action)

getDisruptor

public com.lmax.disruptor.dsl.Disruptor<CommonEvent> getDisruptor(Class<?> topic)

Get the Disruptor corresponding to the domain message topic

Parameters:

topic - Domain message topic

Returns:

Disruptor

put

public void put(Class<?> topic,
 com.lmax.disruptor.dsl.Disruptor<CommonEvent> disruptor)