T
- The type of the beans to be collected.public class BusCollect<T> extends AbstractFilter<T,T> implements Resettable, Service
BasicBusService
so can act as a Wire Tap.Modifier and Type | Class and Description |
---|---|
static class |
BusCollect.Conversions |
static class |
BusCollect.ListContainer<E> |
static class |
BusCollect.MapContainer<K,E> |
Constructor and Description |
---|
BusCollect() |
Modifier and Type | Method and Description |
---|---|
protected T |
filter(T from) |
BusCollect.ListContainer<T> |
getBeans() |
int |
getCount() |
java.util.function.Function<? super T,java.lang.Object> |
getKeyMapper() |
BusCollect.ListContainer<T> |
getList() |
BusCollect.MapContainer<java.lang.Object,java.lang.Object> |
getMap() |
java.io.OutputStream |
getOutput() |
java.util.function.Function<? super T,java.lang.Object> |
getValueMapper() |
boolean |
hardReset()
Perform a hard reset.
|
void |
setKeyMapper(java.util.function.Function<? super T,java.lang.Object> keyMapper) |
void |
setOutput(java.io.OutputStream output) |
void |
setValueMapper(java.util.function.Function<? super T,java.lang.Object> valueMapper) |
boolean |
softReset()
Perform a soft reset.
|
void |
start()
Start the service.
|
void |
stop()
Stop executing.
|
accept, getName, getTo, setName, setTo, toString
public boolean softReset()
Resettable
softReset
in interface Resettable
public boolean hardReset()
Resettable
hardReset
in interface Resettable
public void start()
Service
public void stop() throws FailedToStopException
Stoppable
stop
in interface Stoppable
FailedToStopException
public BusCollect.ListContainer<T> getBeans()
Property: beans
Description: The same as list. Prefer list, will be deprecated in future versions.
Required: Read only.
public BusCollect.ListContainer<T> getList()
public BusCollect.MapContainer<java.lang.Object,java.lang.Object> getMap()
public int getCount()
public java.util.function.Function<? super T,java.lang.Object> getKeyMapper()
public void setKeyMapper(java.util.function.Function<? super T,java.lang.Object> keyMapper)
public java.util.function.Function<? super T,java.lang.Object> getValueMapper()
public void setValueMapper(java.util.function.Function<? super T,java.lang.Object> valueMapper)
public java.io.OutputStream getOutput()
public void setOutput(java.io.OutputStream output)