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

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

All Implemented Interfaces:

CleanUpNotifier, RemotingService, MessagingComponent

public class MinaService
extends java.lang.Object
implements RemotingService, CleanUpNotifier

Version:

$Revision$

Author:

Jeff Mesnil

Constructor Summary

MinaService(Configuration config)

MinaService(Configuration config, ServerKeepAliveFactory factory)

Method Summary

void	addInterceptor(Interceptor filter)
void	addRemotingSessionListener(RemotingSessionListener listener)
void	fireCleanup(long sessionID, MessagingException me)
Configuration	getConfiguration()
PacketDispatcher	getDispatcher()
org.apache.mina.common.DefaultIoFilterChainBuilder	getFilterChain() This method must only be called by tests which requires to insert Filters (e.g.
ServerKeepAliveFactory	getKeepAliveFactory()
void	removeInterceptor(Interceptor filter)
void	removeRemotingSessionListener(RemotingSessionListener listener)
void	setKeepAliveFactory(ServerKeepAliveFactory factory)
void	setRemotingConfiguration(Configuration remotingConfig)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

MinaService

public MinaService(Configuration config)

MinaService

public MinaService(Configuration config,
                   ServerKeepAliveFactory factory)

Method Detail

addInterceptor

public void addInterceptor(Interceptor filter)

Specified by:

addInterceptor in interface RemotingService

removeInterceptor

public void removeInterceptor(Interceptor filter)

Specified by:

removeInterceptor in interface RemotingService

addRemotingSessionListener

public void addRemotingSessionListener(RemotingSessionListener listener)

Specified by:

addRemotingSessionListener in interface RemotingService

removeRemotingSessionListener

public void removeRemotingSessionListener(RemotingSessionListener listener)

Specified by:

removeRemotingSessionListener in interface RemotingService

start

public void start()
           throws java.lang.Exception

Specified by:

start in interface MessagingComponent

Throws:

java.lang.Exception

stop

public void stop()

Specified by:

stop in interface MessagingComponent

getDispatcher

public PacketDispatcher getDispatcher()

Specified by:

getDispatcher in interface RemotingService

getConfiguration

public Configuration getConfiguration()

Specified by:

getConfiguration in interface RemotingService

getKeepAliveFactory

public ServerKeepAliveFactory getKeepAliveFactory()

Specified by:

getKeepAliveFactory in interface RemotingService

getFilterChain

public org.apache.mina.common.DefaultIoFilterChainBuilder getFilterChain()

This method must only be called by tests which requires to insert Filters (e.g. to simulate network failures)

fireCleanup

public void fireCleanup(long sessionID,
                        MessagingException me)

Specified by:

fireCleanup in interface CleanUpNotifier

setKeepAliveFactory

public void setKeepAliveFactory(ServerKeepAliveFactory factory)

setRemotingConfiguration

public void setRemotingConfiguration(Configuration remotingConfig)