Package org.apache.activemq.artemis.core.remoting.impl.invm

Class InVMAcceptor

java.lang.Object

org.apache.activemq.artemis.core.remoting.impl.AbstractAcceptor

org.apache.activemq.artemis.core.remoting.impl.invm.InVMAcceptor

All Implemented Interfaces:

ActiveMQComponent, Acceptor

public final class InVMAcceptor
extends AbstractAcceptor

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.remoting.impl.AbstractAcceptor

protocolMap

Constructor Summary

Constructors

Constructor	Description
InVMAcceptor(String name, ClusterConnection clusterConnection, Map<String,Object> configuration, BufferHandler handler, ServerConnectionLifeCycleListener listener, Map<String,ProtocolManager> protocolMap, Executor threadPool)

Method Summary

Modifier and Type	Method	Description
void	connect(String connectionID, BufferHandler remoteHandler, InVMConnector connector, ArtemisExecutor clientExecutor)
void	disconnect(String connectionID)
ClusterConnection	getClusterConnection()
Map<String,Object>	getConfiguration()
int	getConnectionCount()
long	getConnectionsAllowed()
ExecutorFactory	getExecutorFactory()
BufferHandler	getHandler()
String	getName()	The name of the acceptor used on the configuration. for logging and debug purposes.
boolean	isStarted()
boolean	isUnsecurable()	we are InVM so allow unsecure connections
void	notifyStop()
void	pause()	Stop accepting new connections
void	reload()	Re-create the acceptor with the existing configuration values.
void	setDefaultActiveMQPrincipal(ActiveMQPrincipal defaultActiveMQPrincipal)	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 org.apache.activemq.artemis.core.remoting.impl.AbstractAcceptor

getProtocolMap, updateInterceptors

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.spi.core.remoting.Acceptor

getActualPort, getProtocolHandler

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Constructor Details

InVMAcceptor

public InVMAcceptor(String name,
 ClusterConnection clusterConnection,
 Map<String,Object> configuration,
 BufferHandler handler,
 ServerConnectionLifeCycleListener listener,
 Map<String,ProtocolManager> protocolMap,
 Executor threadPool)

Method Details

getName

public String getName()

Description copied from interface: Acceptor

The name of the acceptor used on the configuration. for logging and debug purposes.

getConfiguration

public Map<String,Object> getConfiguration()

getClusterConnection

public ClusterConnection getClusterConnection()

Returns:

the cluster connection associated with this Acceptor

getConnectionsAllowed

public long getConnectionsAllowed()

getConnectionCount

public int getConnectionCount()

start

public void start()
           throws Exception

Throws:

Exception

stop

public void stop()

notifyStop

public void notifyStop()

isStarted

public boolean isStarted()

pause

public void pause()

Stop accepting new connections

setNotificationService

public void setNotificationService(NotificationService notificationService)

Description copied from interface: Acceptor

Set the notification service for this acceptor to use.

Parameters:

notificationService - the notification service

getHandler

public BufferHandler getHandler()

getExecutorFactory

public ExecutorFactory getExecutorFactory()

connect

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

disconnect

public void disconnect(String connectionID)

isUnsecurable

public boolean isUnsecurable()

we are InVM so allow unsecure connections

Returns:

true

reload

public void reload()

Description copied from interface: Acceptor

Re-create the acceptor with the existing configuration values. Useful, for example, for reloading key/trust stores on acceptors which support SSL.

setDefaultActiveMQPrincipal

public void setDefaultActiveMQPrincipal(ActiveMQPrincipal defaultActiveMQPrincipal)

Description copied from interface: Acceptor

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