Class NoBundler

  • All Implemented Interfaces:
    Bundler
    Direct Known Subclasses:
    AsyncNoBundler

    public class NoBundler
    extends java.lang.Object
    implements Bundler
    Bundler which doesn't bundle :-) Can be used to measure the diff between bundling and non-bundling (e.g. at runtime) This bundler doesn't use a pool of buffers, but creates a new buffer every time a message is sent.
    Since:
    4.0
    Author:
    Bela Ban
    • Field Detail

      • transport

        protected TP transport
      • log

        protected Log log
    • Constructor Detail

      • NoBundler

        public NoBundler()
    • Method Detail

      • size

        public int size()
        Description copied from interface: Bundler
        The number of unsent messages in the bundler
        Specified by:
        size in interface Bundler
      • init

        public void init​(TP transport)
        Description copied from interface: Bundler
        Called after creation of the bundler
        Specified by:
        init in interface Bundler
        Parameters:
        transport - the transport, for further reference
      • stop

        public void stop()
        Specified by:
        stop in interface Bundler
      • send

        public void send​(Message msg)
                  throws java.lang.Exception
        Specified by:
        send in interface Bundler
        Throws:
        java.lang.Exception
      • sendSingleMessage

        protected void sendSingleMessage​(Message msg,
                                         ByteArrayDataOutputStream output)
                                  throws java.lang.Exception
        Throws:
        java.lang.Exception