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:

org.apache.activemq.artemis.core.server.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 and Description
InVMAcceptor(String name, ClusterConnection clusterConnection, Map<String,Object> configuration, org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler, ServerConnectionLifeCycleListener listener, Map<String,ProtocolManager> protocolMap, Executor threadPool)

Method Summary

Modifier and Type	Method and Description
void	connect(String connectionID, org.apache.activemq.artemis.spi.core.remoting.BufferHandler remoteHandler, InVMConnector connector, Executor clientExecutor)
void	disconnect(String connectionID)
ClusterConnection	getClusterConnection()
Map<String,Object>	getConfiguration()
int	getConnectionCount()
long	getConnectionsAllowed()
org.apache.activemq.artemis.utils.ExecutorFactory	getExecutorFactory()
org.apache.activemq.artemis.spi.core.remoting.BufferHandler	getHandler()
String	getName() The name of the acceptor used on the configuration.
boolean	isStarted()
boolean	isUnsecurable() we are InVM so allow unsecure connections
void	pause() Pause the acceptor and stop it from receiving client requests.
void	reload() Re-create the acceptor with the existing configuration values.
void	setDefaultActiveMQPrincipal(org.apache.activemq.artemis.core.security.ActiveMQPrincipal defaultActiveMQPrincipal) Set the default security Principal to be used when no user/pass are defined, only for InVM
void	setNotificationService(org.apache.activemq.artemis.core.server.management.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

updateInterceptors

Methods inherited from class java.lang.Object

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

Constructor Detail

InVMAcceptor

public InVMAcceptor(String name,
                    ClusterConnection clusterConnection,
                    Map<String,Object> configuration,
                    org.apache.activemq.artemis.spi.core.remoting.BufferHandler handler,
                    ServerConnectionLifeCycleListener listener,
                    Map<String,ProtocolManager> protocolMap,
                    Executor threadPool)

Method Detail

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()

isStarted

public boolean isStarted()

pause

public void pause()

Description copied from interface: Acceptor

Pause the acceptor and stop it from receiving client requests.

setNotificationService

public void setNotificationService(org.apache.activemq.artemis.core.server.management.NotificationService notificationService)

Description copied from interface: Acceptor

Set the notification service for this acceptor to use.

Parameters:

notificationService - the notification service

getHandler

public org.apache.activemq.artemis.spi.core.remoting.BufferHandler getHandler()

getExecutorFactory

public org.apache.activemq.artemis.utils.ExecutorFactory getExecutorFactory()

connect

public void connect(String connectionID,
                    org.apache.activemq.artemis.spi.core.remoting.BufferHandler remoteHandler,
                    InVMConnector connector,
                    Executor 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(org.apache.activemq.artemis.core.security.ActiveMQPrincipal defaultActiveMQPrincipal)

Description copied from interface: Acceptor

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