org.apache.camel.component.splunk.support
Class SplunkDataWriter

java.lang.Object
  org.apache.camel.component.splunk.support.SplunkDataWriter

All Implemented Interfaces:

DataWriter

Direct Known Subclasses:

StreamDataWriter, SubmitDataWriter, TcpDataWriter

public abstract class SplunkDataWriter
extends Object
implements DataWriter

Field Summary

protected com.splunk.Args	args
protected SplunkEndpoint	endpoint

Constructor Summary

SplunkDataWriter(SplunkEndpoint endpoint, com.splunk.Args args)

Method Summary

protected abstract Socket	createSocket(com.splunk.Service service)
protected void	doWrite(SplunkEvent event)
boolean	isConnected()
void	start()
void	stop()
void	write(SplunkEvent event)

Methods inherited from class java.lang.Object

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

Field Detail

endpoint

protected SplunkEndpoint endpoint

args

protected com.splunk.Args args

Constructor Detail

SplunkDataWriter

public SplunkDataWriter(SplunkEndpoint endpoint,
                        com.splunk.Args args)

Method Detail

createSocket

protected abstract Socket createSocket(com.splunk.Service service)
                                throws IOException

Throws:

IOException

write

public void write(SplunkEvent event)
           throws Exception

Specified by:

write in interface DataWriter

Throws:

Exception

doWrite

protected void doWrite(SplunkEvent event)
                throws IOException

Throws:

IOException

start

public void start()

Specified by:

start in interface DataWriter

stop

public void stop()

Specified by:

stop in interface DataWriter

isConnected

public boolean isConnected()

Specified by:

isConnected in interface DataWriter