public class NettyAcceptor extends Object implements Acceptor
Constructor and Description |
---|
NettyAcceptor(String name,
ClusterConnection clusterConnection,
Map<String,Object> configuration,
BufferHandler handler,
ConnectionLifeCycleListener listener,
ScheduledExecutorService scheduledThreadPool,
Map<String,ProtocolManager> protocolMap) |
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.
|
public NettyAcceptor(String name, ClusterConnection clusterConnection, Map<String,Object> configuration, BufferHandler handler, ConnectionLifeCycleListener listener, ScheduledExecutorService scheduledThreadPool, Map<String,ProtocolManager> protocolMap)
public void start() throws Exception
start
in interface HornetQComponent
Exception
public void transfer(io.netty.channel.Channel channel)
channel
- A Netty channel created outside this NettyAcceptor.public Map<String,Object> getConfiguration()
getConfiguration
in interface Acceptor
public void stop()
stop
in interface HornetQComponent
public boolean isStarted()
isStarted
in interface HornetQComponent
public void pause()
Acceptor
public void setNotificationService(NotificationService notificationService)
Acceptor
setNotificationService
in interface Acceptor
notificationService
- the notification servicepublic void setDefaultHornetQPrincipal(HornetQPrincipal defaultHornetQPrincipal)
setDefaultHornetQPrincipal
in interface Acceptor
defaultHornetQPrincipal
- public boolean isUnsecurable()
isUnsecurable
in interface Acceptor
public ClusterConnection getClusterConnection()
getClusterConnection
in interface Acceptor
public ConnectionCreator createConnectionCreator()
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.