Constructor and Description |
---|
MDCAwareDispatcher(reactor.core.Dispatcher delegate) |
Modifier and Type | Method and Description |
---|---|
boolean |
alive() |
boolean |
awaitAndShutdown() |
boolean |
awaitAndShutdown(long l,
TimeUnit timeUnit) |
long |
backlogSize() |
<E> void |
dispatch(E e,
reactor.fn.Consumer<E> consumer,
reactor.fn.Consumer<Throwable> consumer1) |
void |
execute(Runnable command) |
void |
forceShutdown() |
boolean |
inContext() |
long |
remainingSlots() |
void |
shutdown() |
boolean |
supportsOrdering() |
<E> void |
tryDispatch(E e,
reactor.fn.Consumer<E> consumer,
reactor.fn.Consumer<Throwable> consumer1) |
public <E> void dispatch(E e, reactor.fn.Consumer<E> consumer, reactor.fn.Consumer<Throwable> consumer1)
dispatch
in interface reactor.core.Dispatcher
public <E> void tryDispatch(E e, reactor.fn.Consumer<E> consumer, reactor.fn.Consumer<Throwable> consumer1)
tryDispatch
in interface reactor.core.Dispatcher
public long remainingSlots()
remainingSlots
in interface reactor.core.Dispatcher
public long backlogSize()
backlogSize
in interface reactor.core.Dispatcher
public boolean supportsOrdering()
supportsOrdering
in interface reactor.core.Dispatcher
public boolean inContext()
inContext
in interface reactor.core.Dispatcher
public boolean alive()
alive
in interface reactor.fn.Resource
public void shutdown()
shutdown
in interface reactor.fn.Resource
public boolean awaitAndShutdown()
awaitAndShutdown
in interface reactor.fn.Resource
public boolean awaitAndShutdown(long l, TimeUnit timeUnit)
awaitAndShutdown
in interface reactor.fn.Resource
public void forceShutdown()
forceShutdown
in interface reactor.fn.Resource
Copyright © 2015 SemaGrow - FP7. All rights reserved.