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, persistences: Map[String, PersistenceWriter], subscriptions: Map[String, ArrayBuffer[ConsumerWriter]])

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. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any

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

    Definition Classes
    Logger

  9. var broadcaster : Thread

    A thread to publish data.

    A thread to publish data.

    Attributes
    protected

  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 (arg0: ChannelHandlerContext, arg1: ChannelStateEvent): Unit

    Definition Classes
    SimpleChannelUpstreamHandler
    Annotations
    @throws()

  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 getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any

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

    Definition Classes
    SimpleChannelUpstreamHandler → ChannelUpstreamHandler
    Annotations
    @throws()

  36. def hashCode (): Int

    Definition Classes
    AnyRef → Any

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

  42. val interval : Long

  43. def isDebugEnabled : Boolean

    Definition Classes
    Logger

  44. def isErrorEnabled : Boolean

    Definition Classes
    Logger

  45. def isInfoEnabled : Boolean

    Definition Classes
    Logger

  46. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any

  47. def isTraceEnabled : Boolean

    Definition Classes
    Logger

  48. def isWarnEnabled : Boolean

    Definition Classes
    Logger

  49. val lock : Lock

    Attributes
    protected

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

    Definition Classes
    PublishingHandler → SimpleChannelUpstreamHandler

  51. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  52. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  53. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  54. val path : String

    Path to rollback database.

    Path to rollback database.

    Definition Classes
    PublishingHandler → PersistenceHandler

  55. val pending : LinkedBlockingQueue[PublishMessage]

    Holds pending messages.

    Holds pending messages.

    Attributes
    protected

  56. val persistences : Map[String, PersistenceWriter]

    Holds persistence writers.

    Holds persistence writers.

    Attributes
    protected
    Definition Classes
    PublishingHandler → PersistenceHandler

  57. val subscriptions : Map[String, ArrayBuffer[ConsumerWriter]]

    Holds subscription writers.

    Holds subscription writers.

    Attributes
    protected
    Definition Classes
    PublishingHandler → PersistenceHandler

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

    Attributes
    final
    Definition Classes
    AnyRef

  59. def toString (): String

    Definition Classes
    AnyRef → Any

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

  66. 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

  67. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  69. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

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

    Definition Classes
    Logger

  75. 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