public class ThriftSource extends AbstractSource implements Configurable, EventDrivenSource
Modifier and Type | Field and Description |
---|---|
static String |
CONFIG_BIND
Config param for the hostname to listen on.
|
static String |
CONFIG_PORT
Config param for the port to listen on.
|
static String |
CONFIG_THREADS
Config param for the maximum number of threads this source should use to
handle incoming data.
|
static org.slf4j.Logger |
logger |
Constructor and Description |
---|
ThriftSource() |
Modifier and Type | Method and Description |
---|---|
void |
configure(Context context)
Request the implementing class to (re)configure itself.
|
void |
start()
Starts a service or component.
|
void |
stop()
Stops a service or component.
|
getChannelProcessor, getLifecycleState, getName, setChannelProcessor, setName, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getChannelProcessor, setChannelProcessor
getLifecycleState
getName, setName
public static final org.slf4j.Logger logger
public static final String CONFIG_THREADS
public static final String CONFIG_BIND
public static final String CONFIG_PORT
public void configure(Context context)
Configurable
Request the implementing class to (re)configure itself.
When configuration parameters are changed, they must be reflected by the component asap.
There are no thread safety guarrantees on when configure might be called.
configure
in interface Configurable
public void start()
LifecycleAware
Starts a service or component.
Implementations should determine the result of any start logic and effect
the return value of LifecycleAware.getLifecycleState()
accordingly.
start
in interface LifecycleAware
start
in class AbstractSource
public void stop()
LifecycleAware
Stops a service or component.
Implementations should determine the result of any stop logic and effect
the return value of LifecycleAware.getLifecycleState()
accordingly.
stop
in interface LifecycleAware
stop
in class AbstractSource
Copyright © 2009-2014 Apache Software Foundation. All Rights Reserved.