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

Class NettyAcceptor

java.lang.Object

org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptor

All Implemented Interfaces:

ActiveMQComponent, Acceptor

public class NettyAcceptor
extends Object
implements Acceptor

A Netty TCP Acceptor that supports SSL

Constructor Summary

Constructors

Constructor and Description
NettyAcceptor(String name, ClusterConnection clusterConnection, Map<String,Object> configuration, BufferHandler handler, ConnectionLifeCycleListener listener, ScheduledExecutorService scheduledThreadPool, Map<String,ProtocolManager> protocolMap)

Method Summary

Modifier and Type	Method and Description
ConnectionCreator	createConnectionCreator()
ClusterConnection	getClusterConnection()
Map<String,Object>	getConfiguration()
String	getName() The name of the acceptor used on the configuration.
boolean	isStarted()
boolean	isUnsecurable() only InVM acceptors should allow this
void	pause() Pause the acceptor and stop it from receiving client requests.
void	setDefaultActiveMQPrincipal(ActiveMQPrincipal defaultActiveMQPrincipal) not allowed
void	setNotificationService(NotificationService notificationService) Set the notification service for this acceptor to use.
void	start()
void	stop()
void	transfer(io.netty.channel.Channel channel) Transfers the Netty channel that has been created outside of this NettyAcceptor to control it and configure it according to this NettyAcceptor setting.

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyAcceptor

public NettyAcceptor(String name,
                     ClusterConnection clusterConnection,
                     Map<String,Object> configuration,
                     BufferHandler handler,
                     ConnectionLifeCycleListener listener,
                     ScheduledExecutorService scheduledThreadPool,
                     Map<String,ProtocolManager> protocolMap)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

getName

public String getName()

Description copied from interface: Acceptor

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

Specified by:

getName in interface Acceptor

transfer

public void transfer(io.netty.channel.Channel channel)

Transfers the Netty channel that has been created outside of this NettyAcceptor to control it and configure it according to this NettyAcceptor setting.

Parameters:

channel - A Netty channel created outside this NettyAcceptor.

getConfiguration

public Map<String,Object> getConfiguration()

Specified by:

getConfiguration in interface Acceptor

stop

public void stop()

Specified by:

stop in interface ActiveMQComponent

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

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

setDefaultActiveMQPrincipal

public void setDefaultActiveMQPrincipal(ActiveMQPrincipal defaultActiveMQPrincipal)

not allowed

Specified by:

setDefaultActiveMQPrincipal in interface Acceptor

Parameters:

defaultActiveMQPrincipal -

isUnsecurable

public boolean isUnsecurable()

only InVM acceptors should allow this

Specified by:

isUnsecurable in interface Acceptor

Returns:

getClusterConnection

public ClusterConnection getClusterConnection()

Specified by:

getClusterConnection in interface Acceptor

Returns:

the cluster connection associated with this Acceptor

createConnectionCreator

public ConnectionCreator createConnectionCreator()