Package org.jgroups.tests

Class ParseMessages

  • Direct Known Subclasses:
    ParseMessagesFields
    public class ParseMessages
extends java.lang.Object
    Parses messages out of a captured file and writes them to stdout

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected static short GMS_ID  
      protected static boolean show_views  

    • Constructor Summary

      Constructors 
      Constructor Description
      ParseMessages()  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected java.io.InputStream createInputStream​(java.io.InputStream in)  
      protected static View getView​(Message msg)  
      protected static void help()  
      static void main​(java.lang.String[] args)  
      static void parse​(byte[] buf, int offset, int length, java.util.function.BiConsumer<java.lang.Short,​Message> msg_consumer, java.util.function.BiConsumer<java.lang.Short,​MessageBatch> batch_consumer, boolean tcp)  
      void parse​(java.io.InputStream in, java.util.function.BiConsumer<java.lang.Short,​Message> msg_consumer, java.util.function.BiConsumer<java.lang.Short,​MessageBatch> batch_consumer, boolean tcp)  
      protected static void parseDiscoveryResponse​(Message msg)  
      protected static void readMappings​(java.lang.String filename)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • GMS_ID

        protected static final short GMS_ID

      • show_views

        protected static boolean show_views

    • Constructor Detail

      • ParseMessages

        public ParseMessages()

    • Method Detail

      • parse

        public static void parse​(byte[] buf,
                         int offset,
                         int length,
                         java.util.function.BiConsumer<java.lang.Short,​Message> msg_consumer,
                         java.util.function.BiConsumer<java.lang.Short,​MessageBatch> batch_consumer,
                         boolean tcp)

      • parse

        public void parse​(java.io.InputStream in,
                  java.util.function.BiConsumer<java.lang.Short,​Message> msg_consumer,
                  java.util.function.BiConsumer<java.lang.Short,​MessageBatch> batch_consumer,
                  boolean tcp)
           throws java.io.FileNotFoundException
        Throws:
        java.io.FileNotFoundException

      • main

        public static void main​(java.lang.String[] args)
                 throws java.lang.Exception
        Throws:
        java.lang.Exception

      • createInputStream

        protected java.io.InputStream createInputStream​(java.io.InputStream in)

      • parseDiscoveryResponse

        protected static void parseDiscoveryResponse​(Message msg)
                                      throws java.io.IOException,
                                             java.lang.ClassNotFoundException
        Throws:
        java.io.IOException
        java.lang.ClassNotFoundException

      • getView

        protected static View getView​(Message msg)

      • help

        protected static void help()

      • readMappings

        protected static void readMappings​(java.lang.String filename)
                            throws java.io.IOException
        Throws:
        java.io.IOException