org.apache.qpid.transport.network.mina
Class MinaHandler<E>

java.lang.Object
  extended by org.apache.qpid.transport.network.mina.MinaHandler<E>
All Implemented Interfaces:
org.apache.mina.common.IoHandler

public class MinaHandler<E>
extends Object
implements org.apache.mina.common.IoHandler

MinaHandler


Method Summary
static
<E> void
accept(SocketAddress address, Binding<E,ByteBuffer> binding)
           
static void accept(String host, int port, Binding<?,ByteBuffer> binding)
           
static void accept(String host, int port, ConnectionDelegate delegate)
           
static
<E> E
connect(SocketAddress address, Binding<E,ByteBuffer> binding)
           
static
<E> E
connect(String host, int port, Binding<E,ByteBuffer> binding)
           
static Connection connect(String host, int port, ConnectionDelegate delegate)
           
 void exceptionCaught(org.apache.mina.common.IoSession ssn, Throwable e)
           
 void messageReceived(org.apache.mina.common.IoSession ssn, Object obj)
           
 void messageSent(org.apache.mina.common.IoSession ssn, Object obj)
           
 void sessionClosed(org.apache.mina.common.IoSession ssn)
           
 void sessionCreated(org.apache.mina.common.IoSession session)
          Invoked by MINA when a MINA session for a new connection is created.
 void sessionIdle(org.apache.mina.common.IoSession ssn, org.apache.mina.common.IdleStatus status)
           
 void sessionOpened(org.apache.mina.common.IoSession ssn)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

messageReceived

public void messageReceived(org.apache.mina.common.IoSession ssn,
                            Object obj)
Specified by:
messageReceived in interface org.apache.mina.common.IoHandler

messageSent

public void messageSent(org.apache.mina.common.IoSession ssn,
                        Object obj)
Specified by:
messageSent in interface org.apache.mina.common.IoHandler

exceptionCaught

public void exceptionCaught(org.apache.mina.common.IoSession ssn,
                            Throwable e)
Specified by:
exceptionCaught in interface org.apache.mina.common.IoHandler

sessionCreated

public void sessionCreated(org.apache.mina.common.IoSession session)
                    throws Exception
Invoked by MINA when a MINA session for a new connection is created. This method sets up the filter chain on the session, which filters the events handled by this handler. The filter chain consists of, handing off events to an optional protectio

Specified by:
sessionCreated in interface org.apache.mina.common.IoHandler
Parameters:
session - The MINA session.
Throws:
Exception - Any underlying exceptions are allowed to fall through to MINA.

sessionOpened

public void sessionOpened(org.apache.mina.common.IoSession ssn)
Specified by:
sessionOpened in interface org.apache.mina.common.IoHandler

sessionClosed

public void sessionClosed(org.apache.mina.common.IoSession ssn)
Specified by:
sessionClosed in interface org.apache.mina.common.IoHandler

sessionIdle

public void sessionIdle(org.apache.mina.common.IoSession ssn,
                        org.apache.mina.common.IdleStatus status)
Specified by:
sessionIdle in interface org.apache.mina.common.IoHandler

accept

public static final void accept(String host,
                                int port,
                                Binding<?,ByteBuffer> binding)
                         throws IOException
Throws:
IOException

accept

public static final <E> void accept(SocketAddress address,
                                    Binding<E,ByteBuffer> binding)
                         throws IOException
Throws:
IOException

connect

public static final <E> E connect(String host,
                                  int port,
                                  Binding<E,ByteBuffer> binding)

connect

public static final <E> E connect(SocketAddress address,
                                  Binding<E,ByteBuffer> binding)

accept

public static final void accept(String host,
                                int port,
                                ConnectionDelegate delegate)
                         throws IOException
Throws:
IOException

connect

public static final Connection connect(String host,
                                       int port,
                                       ConnectionDelegate delegate)


Licensed to the Apache Software Foundation