Modifier and Type | Class and Description |
---|---|
class |
ReactorBuilder.NestedReactorBuilder |
class |
ReactorBuilder.SelectorProcessor |
Constructor and Description |
---|
ReactorBuilder(String name,
Map<String,ReactorBuilder> reactorMap) |
ReactorBuilder(String name,
Map<String,ReactorBuilder> reactorMap,
EventBus reactor) |
Modifier and Type | Method and Description |
---|---|
void |
addConsumersFrom(ReactorBuilder from) |
ReactorBuilder |
dispatcher(String dispatcher) |
Object |
ext(String k) |
void |
ext(String k,
Object v) |
void |
exts(Map<String,Object> map) |
EventBus |
get()
Get an object.
|
Dispatcher |
getDispatcher() |
Environment |
getEnv() |
Filter |
getFilter() |
static String |
getFIRST() |
groovy.lang.MetaClass |
getMetaClass() |
String |
getName() |
boolean |
getOverride() |
Object |
getProperty(String property) |
static String |
getPUB_SUB() |
static String |
getRANDOM() |
static String |
getROUND_ROBIN() |
Router |
getRouter() |
void |
init() |
Object |
invokeMethod(String method,
Object arguments) |
boolean |
isOverride() |
ReactorBuilder |
on(groovy.lang.Closure closure) |
ReactorBuilder |
on(Consumer consumer) |
ReactorBuilder |
on(Selector selector,
groovy.lang.Closure closure) |
ReactorBuilder |
on(Selector selector,
Consumer closure) |
ReactorBuilder |
on(String selector,
groovy.lang.Closure closure) |
ReactorBuilder |
on(String selector,
Consumer closure) |
void |
processor(Selector selector,
org.reactivestreams.Processor<?,Event> _processor) |
void |
processor(String selector,
org.reactivestreams.Processor<?,Event> _processor) |
ReactorBuilder |
reactor(groovy.lang.Closure c) |
ReactorBuilder |
reactor(String reactorName,
groovy.lang.Closure c) |
void |
rehydrate(ReactorBuilder r) |
Filter |
routingStrategy(String strategy) |
void |
setDispatcher(Dispatcher value) |
void |
setEnv(Environment value) |
void |
setFilter(Filter value) |
void |
setMetaClass(groovy.lang.MetaClass mc) |
void |
setOverride(boolean value) |
void |
setProperty(String property,
Object value) |
void |
setRouter(Router value) |
void |
stream(groovy.lang.Closure<Action<Event<?>,Event<?>>> closure) |
void |
stream(Selector selector,
groovy.lang.Closure<Action<Event<?>,Event<?>>> closure) |
void |
stream(String selector,
groovy.lang.Closure<Action<Event<?>,Event<?>>> closure) |
public ReactorBuilder(String name, Map<String,ReactorBuilder> reactorMap)
public ReactorBuilder(String name, Map<String,ReactorBuilder> reactorMap, EventBus reactor)
public groovy.lang.MetaClass getMetaClass()
getMetaClass
in interface groovy.lang.GroovyObject
public void setMetaClass(groovy.lang.MetaClass mc)
setMetaClass
in interface groovy.lang.GroovyObject
public Object invokeMethod(String method, Object arguments)
invokeMethod
in interface groovy.lang.GroovyObject
public Object getProperty(String property)
getProperty
in interface groovy.lang.GroovyObject
public void setProperty(String property, Object value)
setProperty
in interface groovy.lang.GroovyObject
public static final String getROUND_ROBIN()
public static final String getPUB_SUB()
public static final String getRANDOM()
public static final String getFIRST()
public Environment getEnv()
public void setEnv(Environment value)
public Router getRouter()
public void setRouter(Router value)
public Dispatcher getDispatcher()
public void setDispatcher(Dispatcher value)
public Filter getFilter()
public void setFilter(Filter value)
public boolean getOverride()
public boolean isOverride()
public void setOverride(boolean value)
public final String getName()
public void rehydrate(ReactorBuilder r)
public void init()
public ReactorBuilder dispatcher(String dispatcher)
public ReactorBuilder on(@DelegatesTo(strategy=1,value=ClosureEventConsumer.ReplyDecorator.class) groovy.lang.Closure closure)
public ReactorBuilder on(String selector, @DelegatesTo(strategy=1,value=ClosureEventConsumer.ReplyDecorator.class) groovy.lang.Closure closure)
public ReactorBuilder on(Consumer consumer)
public ReactorBuilder on(String selector, Consumer closure)
public ReactorBuilder on(Selector selector, @DelegatesTo(strategy=1,value=ClosureEventConsumer.ReplyDecorator.class) groovy.lang.Closure closure)
public ReactorBuilder on(Selector selector, Consumer closure)
public void stream(@DelegatesTo(strategy=1,value=Stream.class) groovy.lang.Closure<Action<Event<?>,Event<?>>> closure)
public void stream(String selector, @DelegatesTo(strategy=1,value=Stream.class) groovy.lang.Closure<Action<Event<?>,Event<?>>> closure)
public void stream(Selector selector, @DelegatesTo(strategy=1,value=Stream.class) groovy.lang.Closure<Action<Event<?>,Event<?>>> closure)
public void processor(Selector selector, org.reactivestreams.Processor<?,Event> _processor)
public void addConsumersFrom(ReactorBuilder from)
public ReactorBuilder reactor(@DelegatesTo(strategy=1,value=ReactorBuilder.NestedReactorBuilder.class) groovy.lang.Closure c)
public ReactorBuilder reactor(String reactorName, @DelegatesTo(strategy=1,value=ReactorBuilder.NestedReactorBuilder.class) groovy.lang.Closure c)
Copyright © 2016. All rights reserved.