org.opennms.netmgt.collection.persistence.tcp

Class SimpleTcpOutputStrategy

java.lang.Object

org.opennms.netmgt.collection.persistence.tcp.SimpleTcpOutputStrategy

All Implemented Interfaces:

TcpOutputStrategy

public class SimpleTcpOutputStrategy
extends Object
implements TcpOutputStrategy

Provides a simple non-queued implementation of TcpOutputStrategy that pushes data to the stream one reading at a time.

The receiver of this strategy is not defined in any way. This is just a fire and forget strategy. There is no way to read data back into opennms.

Constructor Summary

Constructors

Constructor and Description
SimpleTcpOutputStrategy()

Method Summary

Modifier and Type	Method and Description
String	getHost() getHost
int	getPort() getPort
void	setHost(String host) setHost
void	setPort(int port) setPort
void	updateData(String path, String owner, Long timestamp, List<Double> dblValues, List<String> strValues) Updates the TCP output stream with the supplied values

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleTcpOutputStrategy

public SimpleTcpOutputStrategy()

Method Detail

getHost

public String getHost()

getHost

Returns:

a String object.

setHost

public void setHost(String host)

setHost

Parameters:

host - a String object.

getPort

public int getPort()

getPort

Returns:

a int.

setPort

public void setPort(int port)

setPort

Parameters:

port - a int.

updateData

public void updateData(String path,
                       String owner,
                       Long timestamp,
                       List<Double> dblValues,
                       List<String> strValues)
                throws Exception

Updates the TCP output stream with the supplied values

Specified by:

updateData in interface TcpOutputStrategy

Parameters:

path - the hierarchy path for the data

owner - the owner of the data

dblValues - a list of Double values

strValues - a list of String values

Throws:

Exception - if an error occurs updating the file