org.apache.hadoop.chukwa.datacollection.connector.http

Class HttpConnector

java.lang.Object

org.apache.hadoop.chukwa.datacollection.connector.http.HttpConnector

All Implemented Interfaces:

Runnable, Connector

public class HttpConnector
extends Object
implements Connector, Runnable

Field Summary

Fields

Modifier and Type	Field and Description
static String	ASYNC_ACKS_OPT
protected ChukwaSender	connectorClient
static String	MAX_SIZE_PER_POST_OPT
static String	MIN_POST_INTERVAL_OPT

Fields inherited from interface org.apache.hadoop.chukwa.datacollection.connector.Connector

adaptorTimestampField, adaptorURIField, logApplicationField, logEventField, logSourceField, logTimestampField, proxyRetryField, proxyTimestampField, proxyURIField

Constructor Summary

Constructors

Constructor and Description
HttpConnector(ChukwaAgent agent)
HttpConnector(ChukwaAgent agent, String destination)

Method Summary

Modifier and Type	Method and Description
ChukwaSender	getSender()
void	reloadConfiguration()
void	run()
void	setCollectors(Iterator<String> list)
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MIN_POST_INTERVAL_OPT

public static final String MIN_POST_INTERVAL_OPT

See Also:

Constant Field Values

MAX_SIZE_PER_POST_OPT

public static final String MAX_SIZE_PER_POST_OPT

See Also:

Constant Field Values

ASYNC_ACKS_OPT

public static final String ASYNC_ACKS_OPT

See Also:

Constant Field Values

connectorClient

protected ChukwaSender connectorClient

Constructor Detail

HttpConnector

public HttpConnector(ChukwaAgent agent)

HttpConnector

public HttpConnector(ChukwaAgent agent,
                     String destination)

Method Detail

start

public void start()

Specified by:

start in interface Connector

shutdown

public void shutdown()

Specified by:

shutdown in interface Connector

run

public void run()

Specified by:

run in interface Runnable

reloadConfiguration

public void reloadConfiguration()

Specified by:

reloadConfiguration in interface Connector

getSender

public ChukwaSender getSender()

setCollectors

public void setCollectors(Iterator<String> list)