Package | Description |
---|---|
reactor |
Modifier and Type | Method and Description |
---|---|
static DispatcherSupplier |
Environment.cachedDispatchers()
Obtain the default dispatcher supplier from the context environment.
|
static DispatcherSupplier |
Environment.cachedDispatchers(String key)
Obtain a dispatcher supplier into the context environment.
|
static DispatcherSupplier |
Environment.cachedDispatchers(String key,
DispatcherSupplier dispatcherSupplier)
Register a dispatcher supplier into the context environment.
|
static DispatcherSupplier |
Environment.createDispatcherFactory(String name,
int poolsize,
int bufferSize,
Consumer<Throwable> errorHandler,
com.lmax.disruptor.dsl.ProducerType producerType,
com.lmax.disruptor.WaitStrategy waitStrategy)
Create a RingBuffer pool that will clone up to generated dispatcher and return a different one
on a round robin fashion each time
Supplier.get() is called. |
DispatcherSupplier |
Environment.getCachedDispatchers()
Returns the default dispatcher group for this environment.
|
DispatcherSupplier |
Environment.getCachedDispatchers(String name)
Returns the dispatcher factory with the given
name . |
static DispatcherSupplier |
Environment.newCachedDispatchers(int poolsize) |
static DispatcherSupplier |
Environment.newCachedDispatchers(int poolsize,
String name) |
static DispatcherSupplier |
Environment.newFanOutCachedDispatchers(int poolsize,
String name) |
Modifier and Type | Method and Description |
---|---|
Environment |
Environment.addCachedDispatchers(String name,
DispatcherSupplier dispatcherFactory)
Adds the
dispatcherFactory to the environment, storing it using the given name . |
static DispatcherSupplier |
Environment.cachedDispatchers(String key,
DispatcherSupplier dispatcherSupplier)
Register a dispatcher supplier into the context environment.
|
Copyright © 2017. All rights reserved.