Class WordsSocketStreamerServer


  • public class WordsSocketStreamerServer
    extends java.lang.Object
    Example demonstrates streaming of data from external components into Ignite cache.

    WordsSocketStreamerServer is simple socket streaming server implementation that receives words from socket using SocketStreamer and message delimiter based protocol and streams them into Ignite cache. Example illustrates usage of TCP socket streamer in case of non-Java clients. In this example words are zero-terminated strings.

    To start the example, you should:

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static void main​(java.lang.String[] args)
      Starts socket streaming server.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • WordsSocketStreamerServer

        public WordsSocketStreamerServer()
    • Method Detail

      • main

        public static void main​(java.lang.String[] args)
                         throws java.lang.Exception
        Starts socket streaming server.
        Parameters:
        args - Command line arguments (none required).
        Throws:
        java.lang.Exception - If failed.