Class QueuingTcpOutputStrategy
- java.lang.Object
-
- org.opennms.netmgt.collection.persistence.tcp.QueuingTcpOutputStrategy
-
- All Implemented Interfaces:
TcpOutputStrategy
public class QueuingTcpOutputStrategy extends java.lang.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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clearOfferStats()
void
countOfferStats(boolean goodOffer)
long
getBadOffers()
long
getGoodOffers()
long
getTotalOffers()
void
updateData(java.lang.String path, java.lang.String owner, java.lang.Long timestamp, java.util.List<java.lang.Double> dblValues, java.util.List<java.lang.String> strValues)
Updates the TCP output stream with the supplied values
-
-
-
Constructor Detail
-
QueuingTcpOutputStrategy
public QueuingTcpOutputStrategy(SimpleTcpOutputStrategy delegate, int queueSize)
Constructor for QueuingTcpOutputStrategy.
- Parameters:
delegate
- aorg.opennms.netmgt.rrd.tcp.SimpleTcpOutputStrategy
object.
-
-
Method Detail
-
updateData
public void updateData(java.lang.String path, java.lang.String owner, java.lang.Long timestamp, java.util.List<java.lang.Double> dblValues, java.util.List<java.lang.String> strValues) throws java.lang.Exception
Updates the TCP output stream with the supplied values- Specified by:
updateData
in interfaceTcpOutputStrategy
- Parameters:
path
- the hierarchy path for the dataowner
- the owner of the datadblValues
- a list of Double valuesstrValues
- a list of String values- Throws:
java.lang.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()
-
-