List of fillMessage() Examples

Examples of fillMessage()

kilim.nio.EndPoint.fillMessage()

Reads a length-prefixed message in its entirety. @param bb The bytebuffer to fill, assuming there is sufficient space (including the bytes for the length). Otherwise, thecontents are copied into a sufficiently big buffer, and the new buffer is returned. @param lengthLength The number of bytes occupied by the length. Must be 1, 2 or 4, assumed to be in big-endian order. @param lengthIncludesItself true if the packet length includes lengthLength @return the buffer bb passed in if the message fits or a new buffer. Either way, the buffer returned has the entiremessage including the initial length prefix. @throws IOException @throws Pausable

        public void execute() throws Pausable, Exception {
            ByteBuffer buf = ByteBuffer.allocate(100);
            EndPoint ep = getEndPoint();
            while (true) {
                buf.clear();
                buf = ep.fillMessage(buf, 4, /*lengthIncludesItself*/ false);
                buf.flip();
                int strlen = buf.getInt();
                String s= new String(buf.array(), 4, strlen);
                //System.out.println ("Rcvd: " + s);
                if (!s.startsWith("Iteration #")) {

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.

Examples of fillMessage()

Examples of kilim.nio.EndPoint.fillMessage()