org.hornetq.core.remoting.impl.invm

Class InVMAcceptor

java.lang.Object

org.hornetq.core.remoting.impl.invm.InVMAcceptor

All Implemented Interfaces:

HornetQComponent, Acceptor

public final class InVMAcceptor
extends Object
implements Acceptor

A InVMAcceptor

Author:

Tim Fox

Constructor Summary

Constructors

Constructor and Description
InVMAcceptor(ClusterConnection clusterConnection, Map<String,Object> configuration, BufferHandler handler, ConnectionLifeCycleListener listener, Executor threadPool)

Method Summary

Methods

Modifier and Type	Method and Description
void	connect(String connectionID, BufferHandler remoteHandler, InVMConnector connector, Executor clientExecutor)
void	disconnect(String connectionID)
ClusterConnection	getClusterConnection()
Map<String,Object>	getConfiguration()
ExecutorFactory	getExecutorFactory()
BufferHandler	getHandler()
boolean	isStarted()
boolean	isUnsecurable() we are InVM so allow unsecure connections
void	pause() Pause the acceptor and stop it from receiving client requests.
void	setDefaultHornetQPrincipal(HornetQPrincipal defaultHornetQPrincipal) Set the default security Principal to be used when no user/pass are defined, only for InVM
void	setNotificationService(NotificationService notificationService) Set the notification service for this acceptor to use.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

InVMAcceptor

public InVMAcceptor(ClusterConnection clusterConnection,
            Map<String,Object> configuration,
            BufferHandler handler,
            ConnectionLifeCycleListener listener,
            Executor threadPool)

Method Detail

getConfiguration

public Map<String,Object> getConfiguration()

Specified by:

getConfiguration in interface Acceptor

getClusterConnection

public ClusterConnection getClusterConnection()

Specified by:

getClusterConnection in interface Acceptor

Returns:

the cluster connection associated with this Acceptor

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface HornetQComponent

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

pause

public void pause()

Description copied from interface: Acceptor

Pause the acceptor and stop it from receiving client requests.

Specified by:

pause in interface Acceptor

setNotificationService

public void setNotificationService(NotificationService notificationService)

Description copied from interface: Acceptor

Set the notification service for this acceptor to use.

Specified by:

setNotificationService in interface Acceptor

Parameters:

notificationService - the notification service

getHandler

public BufferHandler getHandler()

getExecutorFactory

public ExecutorFactory getExecutorFactory()

connect

public void connect(String connectionID,
           BufferHandler remoteHandler,
           InVMConnector connector,
           Executor clientExecutor)

disconnect

public void disconnect(String connectionID)

isUnsecurable

public boolean isUnsecurable()

we are InVM so allow unsecure connections

Specified by:

isUnsecurable in interface Acceptor

Returns:

true

setDefaultHornetQPrincipal

public void setDefaultHornetQPrincipal(HornetQPrincipal defaultHornetQPrincipal)

Description copied from interface: Acceptor

Set the default security Principal to be used when no user/pass are defined, only for InVM

Specified by:

setDefaultHornetQPrincipal in interface Acceptor