Interface Bundler

    • Method Detail

      • init

        default void init​(TP transport)
        Called after creation of the bundler
        Parameters:
        transport - the transport, for further reference
      • start

        void start()
        Called after init(TP)
      • stop

        void stop()
      • send

        void send​(Message msg)
           throws java.lang.Exception
        Throws:
        java.lang.Exception
      • viewChange

        default void viewChange​(View view)
      • size

        int size()
        The number of unsent messages in the bundler
      • getQueueSize

        int getQueueSize()
        If the bundler has a queue and it should be managed by a queuing discipline (like Random Early Detection), then return the number of elements in the queue, else -1. In the latter case, the queue won't be managed.
        This method needs to be fast as it might get called on every message to be sent.
      • getCapacity

        default int getCapacity()
        If the bundler implementation supports a capacity (e.g. RingBufferBundler, then return it, else return -1
      • getMaxSize

        int getMaxSize()
        Maximum number of bytes for messages to be queued until they are sent
      • setMaxSize

        default Bundler setMaxSize​(int s)
      • renameThread

        default void renameThread()
      • resetStats

        default void resetStats()