org.jboss.messaging.core.remoting.impl.mina
Class MinaConnector

java.lang.Object
  org.jboss.messaging.core.remoting.impl.mina.MinaConnector

All Implemented Interfaces:

CleanUpNotifier, NIOConnector

public class MinaConnector
extends java.lang.Object
implements NIOConnector, CleanUpNotifier

Version:

$Revision$

Author:

Jeff Mesnil

Constructor Summary

MinaConnector(Location location, ConnectionParams connectionParams, PacketDispatcher dispatcher)

MinaConnector(Location location, ConnectionParams connectionParams, PacketDispatcher dispatcher, ClientKeepAliveFactory keepAliveFactory)

MinaConnector(Location location, PacketDispatcher dispatcher)

MinaConnector(Location location, PacketDispatcher dispatcher, ClientKeepAliveFactory keepAliveFactory)

Method Summary

void	addSessionListener(RemotingSessionListener listener)
NIOSession	connect()
boolean	disconnect()
void	fireCleanup(long sessionID)
void	fireCleanup(long sessionID, MessagingException me)
PacketDispatcher	getDispatcher()
java.lang.String	getServerURI()
void	removeSessionListener(RemotingSessionListener listener)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MinaConnector

public MinaConnector(Location location,
                     PacketDispatcher dispatcher)

MinaConnector

public MinaConnector(Location location,
                     ConnectionParams connectionParams,
                     PacketDispatcher dispatcher)

MinaConnector

public MinaConnector(Location location,
                     PacketDispatcher dispatcher,
                     ClientKeepAliveFactory keepAliveFactory)

MinaConnector

public MinaConnector(Location location,
                     ConnectionParams connectionParams,
                     PacketDispatcher dispatcher,
                     ClientKeepAliveFactory keepAliveFactory)

Method Detail

connect

public NIOSession connect()
                   throws java.io.IOException

Specified by:

connect in interface NIOConnector

Throws:

java.io.IOException

disconnect

public boolean disconnect()

Specified by:

disconnect in interface NIOConnector

addSessionListener

public void addSessionListener(RemotingSessionListener listener)

Specified by:

addSessionListener in interface NIOConnector

removeSessionListener

public void removeSessionListener(RemotingSessionListener listener)

Specified by:

removeSessionListener in interface NIOConnector

getServerURI

public java.lang.String getServerURI()

Specified by:

getServerURI in interface NIOConnector

getDispatcher

public PacketDispatcher getDispatcher()

Specified by:

getDispatcher in interface NIOConnector

fireCleanup

public void fireCleanup(long sessionID,
                        MessagingException me)

Specified by:

fireCleanup in interface CleanUpNotifier

fireCleanup

public void fireCleanup(long sessionID)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object