org.hornetq.core.remoting.impl.netty

Class NettyAcceptor

java.lang.Object

org.hornetq.core.remoting.impl.netty.NettyAcceptor

All Implemented Interfaces:

HornetQComponent, Acceptor

public class NettyAcceptor
extends Object
implements Acceptor

A Netty TCP Acceptor that supports SSL

Version:

$Rev$, $Date$

Author:

Andy Taylor, Tim Fox, Trustin Lee, Jeff Mesnil, Norman Maurer

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()
boolean	isStarted()
boolean	isUnsecurable() only InVM acceptors should allow this
void	pause() Pause the acceptor and stop it from receiving client requests.
void	setDefaultHornetQPrincipal(HornetQPrincipal defaultHornetQPrincipal) 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 HornetQComponent

Throws:

Exception

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

setDefaultHornetQPrincipal

public void setDefaultHornetQPrincipal(HornetQPrincipal defaultHornetQPrincipal)

not allowed

Specified by:

setDefaultHornetQPrincipal in interface Acceptor

Parameters:

defaultHornetQPrincipal -

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