|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectbiz.hammurapi.metrics.SocketSliceConsumerServer
public class SocketSliceConsumerServer
Constructor Summary | |
---|---|
SocketSliceConsumerServer()
|
Method Summary | |
---|---|
protected void |
consumeException(java.lang.Exception e)
Consumes exceptions in processing threads. |
protected biz.hammurapi.metrics.SliceConsumer |
getDelegate()
|
static void |
main(java.lang.String[] args)
|
protected void |
process(java.lang.Runnable job)
Spawns a new thread for each job. |
protected void |
process(java.net.Socket socket)
Spawns a new thread for each socket |
protected void |
processSlices(java.util.List slices,
java.net.InetAddress address,
java.lang.String id)
This method iterates over slices in the batch and sends them to the delegate SliceConsumer returned by getDelegate() method. |
void |
setOwner(java.lang.Object owner)
|
void |
setPort(int port)
Set server listening port |
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public SocketSliceConsumerServer()
Method Detail |
---|
public void setPort(int port)
port
- public void setOwner(java.lang.Object owner)
setOwner
in interface biz.hammurapi.config.Component
public void start() throws biz.hammurapi.config.ConfigurationException
start
in interface biz.hammurapi.config.Component
biz.hammurapi.config.ConfigurationException
public void stop() throws biz.hammurapi.config.ConfigurationException
stop
in interface biz.hammurapi.config.Component
biz.hammurapi.config.ConfigurationException
protected biz.hammurapi.metrics.SliceConsumer getDelegate()
protected void processSlices(java.util.List slices, java.net.InetAddress address, java.lang.String id)
slices
- List of slice entries obtained from clientsprotected void process(java.net.Socket socket)
socket
- protected void process(java.lang.Runnable job)
job
- protected void consumeException(java.lang.Exception e)
e
- public static void main(java.lang.String[] args) throws biz.hammurapi.config.ConfigurationException
biz.hammurapi.config.ConfigurationException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |