Package com.etsy.net

Examples of com.etsy.net.UnixDomainSocketClient


            System.err.println("Failed to create datagram because its size " +
                    "would exceed the maximum");
            System.exit(1);
        }

        UnixDomainSocketClient unixSocket = null;

        /* Here we use a third party library that uses JNI to write to Bruce's
           UNIX domain datagram socket.  See the following links:

               https://github.com/caprica/juds
               http://mvnrepository.com/artifact/uk.co.caprica/juds/0.94.1

           Alternatively, you can write your own JNI code that uses Bruce's
           client C library. */
        try {
            // create socket for sending to Bruce
            unixSocket = new UnixDomainSocketClient(brucePath,
                    JUDS.SOCK_DGRAM);

            // send AnyPartition message to Bruce
            unixSocket.getOutputStream().write(datagram1);

            // send PartitionKey message to Bruce
            unixSocket.getOutputStream().write(datagram2);
        } catch (IOException x) {
            System.err.println("IOException on attempt to send to Bruce: " +
                x.getMessage());
            System.exit(1);
        } finally {
            if (unixSocket != null) {
                unixSocket.close();
            }
        }
    }
View Full Code Here

TOP

Related Classes of com.etsy.net.UnixDomainSocketClient

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.