widebase.stream.handler.rq

PublishingHandler

class PublishingHandler extends SimpleChannelUpstreamHandler with Logger with PersistenceHandler

Handles publishers.

Linear Supertypes
PersistenceHandler, Logger, SimpleChannelUpstreamHandler, ChannelUpstreamHandler, ChannelHandler, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. PublishingHandler
  2. PersistenceHandler
  3. Logger
  4. SimpleChannelUpstreamHandler
  5. ChannelUpstreamHandler
  6. ChannelHandler
  7. AnyRef
  8. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new PublishingHandler (path: String, interval: Long, lock: Lock, actors: ActorSystem, persistences: Map[String, PersistenceWriter], subscriptions: Map[String, ArrayBuffer[ActorRef]])

Type Members

  1. class Broadcaster extends Actor

    Attributes
    protected

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any

  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  6. def _logger : Logger

    Attributes
    protected
    Definition Classes
    Logger

  7. val actors : ActorSystem

    Attributes
    protected

  8. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any

  9. def assertLog (assertion: Boolean, msg: ⇒ String): Unit

    Definition Classes
    Logger

  10. def channelBound (arg0: ChannelHandlerContext, arg1: ChannelStateEvent): Unit

    Definition Classes
    SimpleChannelUpstreamHandler
    Annotations
    @throws()

  11. def channelClosed (ctx: ChannelHandlerContext, evt: ChannelStateEvent): Unit

    Definition Classes
    PublishingHandler → SimpleChannelUpstreamHandler

  12. def channelConnected (arg0: ChannelHandlerContext, arg1: ChannelStateEvent): Unit

    Definition Classes
    SimpleChannelUpstreamHandler
    Annotations
    @throws()

  13. def channelDisconnected (arg0: ChannelHandlerContext, arg1: ChannelStateEvent): Unit

    Definition Classes
    SimpleChannelUpstreamHandler
    Annotations
    @throws()

  14. def channelInterestChanged (arg0: ChannelHandlerContext, arg1: ChannelStateEvent): Unit

    Definition Classes
    SimpleChannelUpstreamHandler
    Annotations
    @throws()

  15. def channelOpen (ctx: ChannelHandlerContext, evt: ChannelStateEvent): Unit

    Definition Classes
    PublishingHandler → SimpleChannelUpstreamHandler

  16. def channelUnbound (arg0: ChannelHandlerContext, arg1: ChannelStateEvent): Unit

    Definition Classes
    SimpleChannelUpstreamHandler
    Annotations
    @throws()

  17. def childChannelClosed (arg0: ChannelHandlerContext, arg1: ChildChannelStateEvent): Unit

    Definition Classes
    SimpleChannelUpstreamHandler
    Annotations
    @throws()

  18. def childChannelOpen (arg0: ChannelHandlerContext, arg1: ChildChannelStateEvent): Unit

    Definition Classes
    SimpleChannelUpstreamHandler
    Annotations
    @throws()

  19. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  20. def debug (msg: ⇒ AnyRef, t: Throwable, marker: Marker): Unit

    Definition Classes
    Logger

  21. def debug (msg: ⇒ AnyRef, marker: Marker): Unit

    Definition Classes
    Logger

  22. def debug (msg: ⇒ AnyRef, t: Throwable): Unit

    Definition Classes
    Logger

  23. def debug (msg: ⇒ AnyRef): Unit

    Definition Classes
    Logger

  24. def debug (msg: ⇒ AnyRef, box: net.liftweb.common.Box[_]): Unit

    Definition Classes
    Logger

  25. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  26. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  27. def error (msg: ⇒ AnyRef, t: Throwable, marker: Marker): Unit

    Definition Classes
    Logger

  28. def error (msg: ⇒ AnyRef, marker: Marker): Unit

    Definition Classes
    Logger

  29. def error (msg: ⇒ AnyRef, t: Throwable): Unit

    Definition Classes
    Logger

  30. def error (msg: ⇒ AnyRef): Unit

    Definition Classes
    Logger

  31. def error (msg: ⇒ AnyRef, box: net.liftweb.common.Box[_]): Unit

    Definition Classes
    Logger

  32. def exceptionCaught (ctx: ChannelHandlerContext, evt: ExceptionEvent): Unit

    Definition Classes
    PublishingHandler → SimpleChannelUpstreamHandler

  33. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  34. def flush (name: String): Unit

    Flush records into rollback table.

    Flush records into rollback table.

    name

    of rollback table

    Definition Classes
    PersistenceHandler

  35. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any

  36. def handleUpstream (arg0: ChannelHandlerContext, arg1: ChannelEvent): Unit

    Definition Classes
    SimpleChannelUpstreamHandler → ChannelUpstreamHandler
    Annotations
    @throws()

  37. def hashCode (): Int

    Definition Classes
    AnyRef → Any

  38. def info (msg: ⇒ AnyRef, t: Throwable, marker: Marker): Unit

    Definition Classes
    Logger

  39. def info (msg: ⇒ AnyRef, marker: Marker): Unit

    Definition Classes
    Logger

  40. def info (msg: ⇒ AnyRef, t: ⇒ Throwable): Unit

    Definition Classes
    Logger

  41. def info (msg: ⇒ AnyRef): Unit

    Definition Classes
    Logger

  42. def info (msg: ⇒ AnyRef, box: net.liftweb.common.Box[_]): Unit

    Definition Classes
    Logger

  43. val interval : Long

  44. def isDebugEnabled : Boolean

    Definition Classes
    Logger

  45. def isErrorEnabled : Boolean

    Definition Classes
    Logger

  46. def isInfoEnabled : Boolean

    Definition Classes
    Logger

  47. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any

  48. def isPersistence : Boolean

    Attributes
    protected

  49. def isTraceEnabled : Boolean

    Definition Classes
    Logger

  50. def isWarnEnabled : Boolean

    Definition Classes
    Logger

  51. val lock : Lock

    Attributes
    protected

  52. def messageReceived (ctx: ChannelHandlerContext, evt: MessageEvent): Unit

    Definition Classes
    PublishingHandler → SimpleChannelUpstreamHandler

  53. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  54. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  55. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  56. val path : String

    Path to rollback database.

    Path to rollback database.

    Definition Classes
    PublishingHandler → PersistenceHandler

  57. val persistences : Map[String, PersistenceWriter]

    Holds persistence writers.

    Holds persistence writers.

    Attributes
    protected
    Definition Classes
    PublishingHandler → PersistenceHandler

  58. val subscriptions : Map[String, ArrayBuffer[ActorRef]]

    Attributes
    protected

  59. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef

  60. def toString (): String

    Definition Classes
    AnyRef → Any

  61. def trace (msg: ⇒ AnyRef, t: Throwable, marker: ⇒ Marker): Unit

    Definition Classes
    Logger

  62. def trace (msg: ⇒ AnyRef, marker: Marker): Unit

    Definition Classes
    Logger

  63. def trace (msg: ⇒ AnyRef, t: Throwable): Unit

    Definition Classes
    Logger

  64. def trace (msg: ⇒ AnyRef): Unit

    Definition Classes
    Logger

  65. def trace (msg: ⇒ AnyRef, box: net.liftweb.common.Box[_]): Unit

    Definition Classes
    Logger

  66. def trace [T] (msg: String, v: T): T

    Definition Classes
    Logger

  67. def upsert (name: String, table: Table): Unit

    Upsert records into rollback table.

    Upsert records into rollback table.

    name

    of rollback table

    table

    self-explenatory

    Definition Classes
    PersistenceHandler

  68. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  69. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  70. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  71. def warn (msg: ⇒ AnyRef, t: Throwable, marker: Marker): Unit

    Definition Classes
    Logger

  72. def warn (msg: ⇒ AnyRef, marker: Marker): Unit

    Definition Classes
    Logger

  73. def warn (msg: ⇒ AnyRef, t: Throwable): Unit

    Definition Classes
    Logger

  74. def warn (msg: ⇒ AnyRef): Unit

    Definition Classes
    Logger

  75. def warn (msg: ⇒ AnyRef, box: net.liftweb.common.Box[_]): Unit

    Definition Classes
    Logger

  76. def writeComplete (arg0: ChannelHandlerContext, arg1: WriteCompletionEvent): Unit

    Definition Classes
    SimpleChannelUpstreamHandler
    Annotations
    @throws()

Inherited from PersistenceHandler

Inherited from Logger

Inherited from SimpleChannelUpstreamHandler

Inherited from ChannelUpstreamHandler

Inherited from ChannelHandler

Inherited from AnyRef

Inherited from Any