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

Constructor Summary

Constructors

Constructor and Description
NettyAcceptor(ClusterConnection clusterConnection, Map<String,Object> configuration, BufferHandler handler, BufferDecoder decoder, ConnectionLifeCycleListener listener, Executor threadPool, ScheduledExecutorService scheduledThreadPool)
NettyAcceptor(Map<String,Object> configuration, BufferHandler handler, BufferDecoder decoder, ConnectionLifeCycleListener listener, Executor threadPool, ScheduledExecutorService scheduledThreadPool)

Method Summary

Methods

Modifier and Type	Method and Description
ClusterConnection	getClusterConnection()
Map<String,Object>	getConfiguration()
boolean	isStarted()
boolean	isUnsecurable()
void	pause() Pause the acceptor and stop it from receiving client requests.
void	setDefaultHornetQPrincipal(HornetQPrincipal defaultHornetQPrincipal)
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

NettyAcceptor

public NettyAcceptor(Map<String,Object> configuration,
             BufferHandler handler,
             BufferDecoder decoder,
             ConnectionLifeCycleListener listener,
             Executor threadPool,
             ScheduledExecutorService scheduledThreadPool)

NettyAcceptor

public NettyAcceptor(ClusterConnection clusterConnection,
             Map<String,Object> configuration,
             BufferHandler handler,
             BufferDecoder decoder,
             ConnectionLifeCycleListener listener,
             Executor threadPool,
             ScheduledExecutorService scheduledThreadPool)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

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)

Specified by:

setDefaultHornetQPrincipal in interface Acceptor

isUnsecurable

public boolean isUnsecurable()

Specified by:

isUnsecurable in interface Acceptor

getClusterConnection

public ClusterConnection getClusterConnection()

Specified by:

getClusterConnection in interface Acceptor

Returns:

the cluster connection associated with this Acceptor