Package org.opennms.netmgt.collection.persistence.tcp

Class QueuingTcpOutputStrategy

java.lang.Object

org.opennms.netmgt.collection.persistence.tcp.QueuingTcpOutputStrategy

All Implemented Interfaces:

TcpOutputStrategy

public class QueuingTcpOutputStrategy
extends Object
implements TcpOutputStrategy

Provides a queued implementation of TcpOutputStrategy that pushes update commands in multiple readings 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	Description
QueuingTcpOutputStrategy(SimpleTcpOutputStrategy delegate, int queueSize)	Constructor for QueuingTcpOutputStrategy.

Method Summary

Modifier and Type	Method	Description
void	clearOfferStats()
void	countOfferStats(boolean goodOffer)
long	getBadOffers()
long	getGoodOffers()
long	getTotalOffers()
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

QueuingTcpOutputStrategy

public QueuingTcpOutputStrategy(SimpleTcpOutputStrategy delegate,
                                int queueSize)

Constructor for QueuingTcpOutputStrategy.

Parameters:

delegate - a org.opennms.netmgt.rrd.tcp.SimpleTcpOutputStrategy object.

Method Detail

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

countOfferStats

public void countOfferStats(boolean goodOffer)

clearOfferStats

public void clearOfferStats()

getTotalOffers

public long getTotalOffers()

getGoodOffers

public long getGoodOffers()

getBadOffers

public long getBadOffers()