public class InetRadiusListener extends RadiusListener<InetNas> implements ru.bitel.bgbilling.kernel.application.server.ExtendedLifecycle
RadiusListener.Mode
accountingStartCounter, accountingStopCounter, accountingUpdateCounter, accountingUpdateIgnoreCount, antispamIgnoreCount, authenticationAcceptCounter, authenticationIgnoreCount, authenticationRejectCounter, dataLogger, mode, processor, setup, threadCountParamName, threadQueueParamName
Constructor and Description |
---|
InetRadiusListener(java.lang.String host,
int port,
int recvBufferSize,
int _recvBufferSize,
int socketRcvBufSize,
RadiusProcessor<?,InetNas,?> processor,
RadiusListener.Mode mode,
Setup setup,
ru.bitel.bgbilling.kernel.network.radius.datalog.hourly.RadiusHourlyDataLogger dataLogger,
int threadCount,
int maxQueueSize) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
void |
init() |
ru.bitel.bgbilling.kernel.network.processor.ProcessorRequest<?> |
newRequest(java.net.SocketAddress clientAddress,
long millis,
java.nio.ByteBuffer data,
int overloadLevel) |
void |
onPacket(java.net.SocketAddress clientAddress,
java.nio.ByteBuffer data) |
void |
start() |
void |
stop() |
getActiveThreadCount, getCurrentThreadCount, getMaxQueueSize, getQueueSize, getSlow1QueueSize, getSlow2QueueSize, getTaskCount, getThreadCount, isSkipAccountingRequestsOnSlow, newThreadContext, setMaxQueueSize, setSkipAccountingRequestsOnSlow, setThreadCount, startListener, toString, toString
run, select, send, sendResponse, setReuseAddress, shutdown
@ConstructorProperties(value={"host","port","recvBufferSize","byteBufferCapacity","soRCVBUF","processor","mode","setup","dataLogger","threadCount","maxQueueSize"}) public InetRadiusListener(java.lang.String host, int port, int recvBufferSize, int _recvBufferSize, int socketRcvBufSize, RadiusProcessor<?,InetNas,?> processor, RadiusListener.Mode mode, Setup setup, ru.bitel.bgbilling.kernel.network.radius.datalog.hourly.RadiusHourlyDataLogger dataLogger, int threadCount, int maxQueueSize)
public ru.bitel.bgbilling.kernel.network.processor.ProcessorRequest<?> newRequest(java.net.SocketAddress clientAddress, long millis, java.nio.ByteBuffer data, int overloadLevel)
newRequest
in interface ru.bitel.bgbilling.kernel.network.processor.ProcessorListener
newRequest
in class RadiusListener<InetNas>
public void init()
init
in interface ru.bitel.bgbilling.kernel.application.server.ExtendedLifecycle
init
in class ru.bitel.common.io.DatagramChannelListener
public void start()
start
in interface ru.bitel.bgbilling.kernel.application.server.Lifecycle
public void stop() throws java.lang.Exception
stop
in interface ru.bitel.bgbilling.kernel.application.server.Lifecycle
java.lang.Exception
public void destroy() throws java.lang.Exception
destroy
in interface ru.bitel.bgbilling.kernel.application.server.ExtendedLifecycle
java.lang.Exception
public void onPacket(java.net.SocketAddress clientAddress, java.nio.ByteBuffer data)
onPacket
in class RadiusListener<InetNas>