Examples of org.apache.catalina.tribes.io.ObjectReader.execute()

Class org.apache.catalina.tribes.io.ObjectReader

Examples of org.apache.catalina.tribes.io.ObjectReader.execute()

org.apache.catalina.tribes.io.ObjectReader.execute()
Send buffer to cluster listener (callback). Is message complete receiver send message to callback? @see org.apache.catalina.tribes.tcp.ClusterReceiverBase#messageDataReceived(ChannelMessage) @see XByteBuffer#doesPackageExist() @see XByteBuffer#extractPackage(boolean) @return number of received packages/messages @throws java.io.IOException

                pkgcnt--;
            }
        }


        //check to see if any data is available
        pkgcnt = reader.execute();


        if (log.isTraceEnabled()) {
            log.trace("sending " + pkgcnt + " ack packages to " + channel.socket().getLocalPort() );
        }

View Full Code Here

        }
        
        int pkgcnt = reader.count();


        if ( pkgcnt > 0 ) {
            ChannelMessage[] msgs = reader.execute();
            for ( int i=0; i<msgs.length; i++ ) {
                /**
                 * Use send ack here if you want to ack the request to the remote 
                 * server before completing the request
                 * This is considered an asynchronized request

View Full Code Here

TOP

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.