Class MessageBusImpl

core/src/main/java/io/questdb/MessageBusImpl.java:60–628

import org.jetbrains.annotations.TestOnly;

public class MessageBusImpl implements MessageBus {
    private final MPSequence columnPurgePubSeq;
    private final RingQueue<ColumnPurgeTask> columnPurgeQueue;
    private final SCSequence columnPurgeSubSeq;
    private final MPSequence columnTaskPubSeq;
    private final RingQueue<ColumnTask> columnTaskQueue;
    private final MCSequence columnTaskSubSeq;
    private final CairoConfiguration configuration;
    private final MPSequence copyExportRequestPubSeq;
    private final RingQueue<CopyExportRequestTask> copyExportRequestQueue;
    private final MCSequence copyExportRequestSubSeq;
    private final SCSequence copyImportColSeq;
    private final SPSequence copyImportPubSeq;
    private final RingQueue<CopyImportTask> copyImportQueue;
    private final SPSequence copyImportRequestPubSeq;
    private final RingQueue<CopyImportRequestTask> copyImportRequestQueue;
    private final SCSequence copyImportRequestSubSeq;
    private final MCSequence copyImportSubSeq;
    private final MPSequence groupByLongTopKPubSeq;
    private final RingQueue<GroupByLongTopKTask> groupByLongTopKQueue;
    private final MCSequence groupByLongTopKSubSeq;
    private final MPSequence groupByMergeShardPubSeq;
    private final RingQueue<GroupByMergeShardTask> groupByMergeShardQueue;
    private final MCSequence groupByMergeShardSubSeq;
    private final MPSequence indexerPubSeq;
    private final RingQueue<ColumnIndexerTask> indexerQueue;
    private final MCSequence indexerSubSeq;
    private final MPSequence latestByPubSeq;
    private final RingQueue<LatestByTask> latestByQueue;
    private final MCSequence latestBySubSeq;
    private final MPSequence o3CopyPubSeq;
    private final RingQueue<O3CopyTask> o3CopyQueue;
    private final MCSequence o3CopySubSeq;
    private final MPSequence o3OpenColumnPubSeq;
    private final RingQueue<O3OpenColumnTask> o3OpenColumnQueue;
    private final MCSequence o3OpenColumnSubSeq;
    private final MPSequence o3PartitionPubSeq;
    private final RingQueue<O3PartitionTask> o3PartitionQueue;
    private final MCSequence o3PartitionSubSeq;
    private final MPSequence o3PurgeDiscoveryPubSeq;
    private final RingQueue<O3PartitionPurgeTask> o3PurgeDiscoveryQueue;
    private final MCSequence o3PurgeDiscoverySubSeq;
    private final FanOut[] pageFrameCollectFanOut;
    private final MPSequence[] pageFrameReducePubSeq;
    private final RingQueue<PageFrameReduceTask>[] pageFrameReduceQueue;
    private final int pageFrameReduceShardCount;
    private final MCSequence[] pageFrameReduceSubSeq;
    private final MPSequence postingSealPurgePubSeq;
    private final RingQueue<PostingSealPurgeTask> postingSealPurgeQueue;
    private final SCSequence postingSealPurgeSubSeq;
    private final MPSequence queryCacheEventPubSeq;
    private final MCSequence queryCacheEventSubSeq;
    private final ConcurrentQueue<QueryTrace> queryTraceQueue;
    private final MPSequence tableWriterEventPubSeq;
    private final RingQueue<TableWriterTask> tableWriterEventQueue;
    private final FanOut tableWriterEventSubSeq;
    private final MPSequence unorderedPageFrameReducePubSeq;
    private final RingQueue<UnorderedPageFrameReduceTask> unorderedPageFrameReduceQueue;