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

java.lang.Object
  extended by 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)


Copyright © 2006 JBoss Inc. All Rights Reserved.