Class RadiusListener<N extends ru.bitel.bgbilling.kernel.network.radius.nas.Nas<?,​?,​?>>

java.lang.Object
ru.bitel.common.io.DatagramChannelListener
ru.bitel.bgbilling.kernel.network.radius.RadiusListener<N>
Type Parameters:
N -
All Implemented Interfaces:
java.lang.Runnable, ru.bitel.bgbilling.kernel.network.processor.ProcessorListener, ru.bitel.common.worker.ThreadContextFactory<ru.bitel.common.worker.ThreadContext>

public class RadiusListener<N extends ru.bitel.bgbilling.kernel.network.radius.nas.Nas<?,​?,​?>>
extends ru.bitel.common.io.DatagramChannelListener
implements ru.bitel.bgbilling.kernel.network.processor.ProcessorListener
Слушатель радиус пакетов.
  • Field Details

    • accountingStartCounter

      @Deprecated public static bitel.billing.server.util.RequestCounter accountingStartCounter
      Deprecated.
    • accountingStopCounter

      @Deprecated public static bitel.billing.server.util.RequestCounter accountingStopCounter
      Deprecated.
    • accountingUpdateCounter

      @Deprecated public static bitel.billing.server.util.RequestCounter accountingUpdateCounter
      Deprecated.
    • authenticationAcceptCounter

      @Deprecated public static bitel.billing.server.util.RequestCounter authenticationAcceptCounter
      Deprecated.
    • authenticationRejectCounter

      @Deprecated public static bitel.billing.server.util.RequestCounter authenticationRejectCounter
      Deprecated.
    • authenticationIgnoreCount

      @Deprecated public static bitel.billing.server.util.RequestCounter authenticationIgnoreCount
      Deprecated.
    • accountingUpdateIgnoreCount

      @Deprecated public static bitel.billing.server.util.RequestCounter accountingUpdateIgnoreCount
      Deprecated.
    • antispamIgnoreCount

      @Deprecated public static bitel.billing.server.util.RequestCounter antispamIgnoreCount
      Deprecated.
    • mode

      protected final RadiusListener.Mode mode
    • setup

      protected final Setup setup
    • processor

      protected final RadiusProcessor<?,​N extends ru.bitel.bgbilling.kernel.network.radius.nas.Nas<?,​?,​?>,​?> processor
    • dataLogger

      protected final ru.bitel.bgbilling.kernel.network.radius.datalog.hourly.RadiusHourlyDataLogger dataLogger
    • threadCountParamName

      protected java.lang.String threadCountParamName
    • threadQueueParamName

      protected java.lang.String threadQueueParamName
  • Constructor Details

    • RadiusListener

      @ConstructorProperties({"host","port","recvBufferSize","soRCVBUF","processor","mode","setup","dataLogger","threadCount","maxQueueSize","defaultAutoCommit"}) public RadiusListener​(java.lang.String host, int port, int byteBufferCapacity, int socketRcvBuf, RadiusProcessor<?,​N,​?> processor, RadiusListener.Mode mode, Setup setup, ru.bitel.bgbilling.kernel.network.radius.datalog.hourly.RadiusHourlyDataLogger dataLogger, int threadCount, int maxQueueSize, java.lang.Boolean defaultAutoCommit)
      Parameters:
      host -
      port -
      byteBufferCapacity - буфер на поток
      socketRcvBuf - рекомендуемый буфер сокета
      processor -
      mode -
      setup -
      dataLogger - RadiusHourlyDataLogger, если нужно сохранять логи
      threadCount - количество потоков или 0, если брать из setup
      maxQueueSize - размер очереди или 0, если брать из setup
  • Method Details

    • newThreadContext

      public ru.bitel.common.worker.ThreadContext newThreadContext()
      Specified by:
      newThreadContext in interface ru.bitel.common.worker.ThreadContextFactory<N extends ru.bitel.bgbilling.kernel.network.radius.nas.Nas<?,​?,​?>>
    • newRequest

      public ru.bitel.bgbilling.kernel.network.processor.ProcessorRequest<?> newRequest​(java.net.SocketAddress clientAddress, long millis, java.nio.ByteBuffer data, int overloadLevel)
      Specified by:
      newRequest in interface ru.bitel.bgbilling.kernel.network.processor.ProcessorListener
    • onPacket

      public void onPacket​(java.net.SocketAddress clientAddress, java.nio.ByteBuffer data)
      Overrides:
      onPacket in class ru.bitel.common.io.DatagramChannelListener
    • startListener

      public java.lang.Thread startListener()
    • toString

      public java.lang.String toString()
      Overrides:
      toString in class java.lang.Object
    • toString

      protected void toString​(java.lang.StringBuilder result)
    • getThreadCount

      public int getThreadCount()
    • setThreadCount

      public void setThreadCount​(int count)
    • getMaxQueueSize

      public int getMaxQueueSize()
    • setMaxQueueSize

      public void setMaxQueueSize​(int maxQueueSize)
    • getSlow1QueueSize

      public int getSlow1QueueSize()
    • getSlow2QueueSize

      public int getSlow2QueueSize()
    • getCurrentThreadCount

      public int getCurrentThreadCount()
    • getActiveThreadCount

      public int getActiveThreadCount()
    • getTaskCount

      public long getTaskCount()
    • getQueueSize

      public long getQueueSize()
    • isSkipAccountingRequestsOnSlow

      public boolean isSkipAccountingRequestsOnSlow()
    • setSkipAccountingRequestsOnSlow

      public void setSkipAccountingRequestsOnSlow​(boolean skipAccountingRequestsOnSlow)