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

Class 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.

    • 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

      • 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​(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 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:
        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()