Return-Path: Delivered-To: apmail-directory-commits-archive@www.apache.org Received: (qmail 20143 invoked from network); 31 Oct 2006 09:28:12 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 31 Oct 2006 09:28:12 -0000 Received: (qmail 78976 invoked by uid 500); 31 Oct 2006 09:28:17 -0000 Delivered-To: apmail-directory-commits-archive@directory.apache.org Received: (qmail 78913 invoked by uid 500); 31 Oct 2006 09:28:17 -0000 Mailing-List: contact commits-help@directory.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@directory.apache.org Delivered-To: mailing list commits@directory.apache.org Received: (qmail 78888 invoked by uid 500); 31 Oct 2006 09:28:17 -0000 Delivered-To: apmail-incubator-directory-cvs@incubator.apache.org Received: (qmail 78880 invoked by uid 99); 31 Oct 2006 09:28:17 -0000 Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 31 Oct 2006 01:28:17 -0800 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_HELO_PASS X-Spam-Check-By: apache.org Received: from [192.87.106.226] (HELO ajax.apache.org) (192.87.106.226) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 31 Oct 2006 01:28:04 -0800 Received: from ajax.apache.org (localhost [127.0.0.1]) by ajax.apache.org (Postfix) with ESMTP id 379ECD49C1 for ; Tue, 31 Oct 2006 09:27:43 +0000 (GMT) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: Apache Wiki To: directory-cvs@incubator.apache.org Date: Tue, 31 Oct 2006 09:27:42 -0000 Message-ID: <20061031092742.32320.85470@ajax.apache.org> Subject: [Directory Wiki] Update of "MinaTutorial" by sishen X-Virus-Checked: Checked by ClamAV on apache.org Dear Wiki user, You have subscribed to a wiki page or wiki category on "Directory Wiki" for change notification. The following page has been changed by sishen: http://wiki.apache.org/directory/MinaTutorial ------------------------------------------------------------------------------ {{{ package org.apache.mina.examples.echoserver; + import org.apache.mina.common.ByteBuffer; + import org.apache.mina.common.IoHandlerAdapter; - import org.apache.mina.common.*; + import org.apache.mina.common.IoSession; - import org.apache.mina.io.*; - import org.apache.mina.io.socket.*; + import org.apache.mina.common.TransportType; + import org.apache.mina.transport.socket.nio.SocketSessionConfig; public class EchoProtocolHandler extends IoHandlerAdapter { public void sessionCreated( IoSession session ) { + if (session.getTransportType() == TransportType.SOCKET) { + ((SocketSessionConfig)session.getConfig()).setReceiveBufferSize(2048); - SessionConfig cfg = session.getConfig(); - if( cfg instanceof SocketSessionConfig ) - { - SocketSessionConfig scfg = ( SocketSessionConfig ) cfg ) ; - scfg.setSessionReceiveBufferSize( 2048 ); } } @@ -83, +82 @@ session.close(); } - public void dataRead( IoSession session, ByteBuffer rb ) + public void dataRead( IoSession session, Object message ) + { + if (!(message instanceof ByteBuffer)) + return; - { + + ByteBuffer rb = (ByteBuffer)message; // Write the received data back to remote peer ByteBuffer wb = ByteBuffer.allocate( rb.remaining() ); wb.put( rb ); wb.flip(); - session.write( wb, null ); + session.write( wb ); } } }}}