c

org.scalatra.atmosphere

RedisScalatraBroadcaster

final class RedisScalatraBroadcaster extends RedisBroadcaster with ScalatraBroadcaster

Linear Supertypes
ScalatraBroadcaster, RedisBroadcaster, AbstractBroadcasterProxy, DefaultBroadcaster, Broadcaster, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RedisScalatraBroadcaster
  2. ScalatraBroadcaster
  3. RedisBroadcaster
  4. AbstractBroadcasterProxy
  5. DefaultBroadcaster
  6. Broadcaster
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new RedisScalatraBroadcaster()(implicit wireFormat: WireFormat, _actorSystem: ActorSystem)

Type Members

  1. final class WriteOperation extends Callable[AnyRef]
    Attributes
    private[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. implicit var _actorSystem: ActorSystem
    Attributes
    protected
    Definition Classes
    RedisScalatraBroadcaster → ScalatraBroadcaster
  5. var _resources: ConcurrentLinkedQueue[AtmosphereResource]
    Attributes
    protected
    Definition Classes
    RedisScalatraBroadcaster → ScalatraBroadcaster
  6. var _wireFormat: WireFormat
    Attributes
    protected
    Definition Classes
    RedisScalatraBroadcaster → ScalatraBroadcaster
  7. def addAtmosphereResource(arg0: AtmosphereResource): Broadcaster
    Definition Classes
    DefaultBroadcaster → Broadcaster
  8. def addBroadcasterLifeCyclePolicyListener(arg0: BroadcasterLifeCyclePolicyListener): Unit
    Definition Classes
    DefaultBroadcaster → Broadcaster
  9. def addBroadcasterListener(arg0: BroadcasterListener): Broadcaster
    Definition Classes
    DefaultBroadcaster → Broadcaster
  10. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  11. def awaitAndBroadcast(arg0: Any, arg1: Long, arg2: TimeUnit): Future[AnyRef]
    Definition Classes
    DefaultBroadcaster → Broadcaster
  12. def b(arg0: Any): Future[AnyRef]
    Attributes
    protected[org.atmosphere.util]
    Definition Classes
    AbstractBroadcasterProxy
  13. def broadcast[T <: OutboundMessage](msg: T, clientFilter: ClientFilter)(implicit executionContext: ExecutionContext): Future[T]
    Definition Classes
    RedisScalatraBroadcaster → ScalatraBroadcaster
  14. def broadcast(arg0: Any, arg1: Set[AtmosphereResource]): Future[AnyRef]
    Definition Classes
    AbstractBroadcasterProxy → DefaultBroadcaster → Broadcaster
  15. def broadcast(arg0: Any, arg1: AtmosphereResource): Future[AnyRef]
    Definition Classes
    AbstractBroadcasterProxy → DefaultBroadcaster → Broadcaster
  16. def broadcast(arg0: Any): Future[AnyRef]
    Definition Classes
    AbstractBroadcasterProxy → DefaultBroadcaster → Broadcaster
  17. def broadcastOnResume(arg0: AtmosphereResource): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  18. def broadcastOnResume(arg0: Any): Future[AnyRef]
    Definition Classes
    DefaultBroadcaster → Broadcaster
  19. def broadcastReceivedMessage(message: AnyRef): Unit
    Attributes
    protected
    Definition Classes
    RedisScalatraBroadcaster → AbstractBroadcasterProxy
  20. def broadcasterListeners(): Collection[BroadcasterListener]
    Definition Classes
    DefaultBroadcaster
  21. def cacheAndSuspend(arg0: AtmosphereResource): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  22. def cacheLostMessage(arg0: AtmosphereResource, arg1: AsyncWriteToken, arg2: Boolean): Unit
    Definition Classes
    DefaultBroadcaster
  23. def cacheLostMessage(arg0: AtmosphereResource, arg1: AsyncWriteToken): Unit
    Definition Classes
    DefaultBroadcaster
  24. def cacheLostMessage(arg0: AtmosphereResource, arg1: Boolean): Unit
    Definition Classes
    DefaultBroadcaster
  25. def cacheMessageOnIOException(arg0: Throwable): Boolean
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  26. def checkCachedAndPush(arg0: AtmosphereResource, arg1: AtmosphereResourceEvent): Boolean
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  27. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  28. def createBroadcasterConfig(arg0: AtmosphereConfig): BroadcasterConfig
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  29. def currentLifecycleTask(arg0: Future[_]): DefaultBroadcaster
    Definition Classes
    DefaultBroadcaster
  30. def currentLifecycleTask(): Future[_]
    Definition Classes
    DefaultBroadcaster
  31. def delayBroadcast(arg0: Any, arg1: Long, arg2: TimeUnit): Future[AnyRef]
    Definition Classes
    DefaultBroadcaster → Broadcaster
  32. def delayBroadcast(arg0: Any): Future[AnyRef]
    Definition Classes
    DefaultBroadcaster → Broadcaster
  33. def deliverPush(arg0: Deliver, arg1: Boolean): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  34. def destroy(): Unit
    Definition Classes
    RedisBroadcaster → DefaultBroadcaster → Broadcaster
  35. def dispatchMessages(arg0: Deliver): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  36. def endBroadcast(arg0: Deliver, arg1: AtmosphereResource, arg2: CacheMessage, arg3: Boolean): Boolean
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  37. def entryDone(arg0: BroadcasterFuture[_]): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  38. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  39. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  40. def executeAsyncWrite(arg0: AsyncWriteToken): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  41. def executeBlockingWrite(arg0: AtmosphereResource, arg1: Deliver, arg2: AtomicInteger): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
    Annotations
    @throws( ... )
  42. def filter(arg0: Any): AnyRef
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  43. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  44. implicit val formats: Formats { ... /* 2 definitions in type refinement */ }
  45. def futureDone(arg0: Any): BroadcasterFuture[AnyRef]
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  46. def getAsyncWriteHandler(arg0: WriteQueue): Runnable
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  47. def getAtmosphereResources(): Collection[AtmosphereResource]
    Definition Classes
    DefaultBroadcaster → Broadcaster
  48. def getAuth(): String
    Definition Classes
    RedisBroadcaster
  49. def getBroadcastHandler(): Runnable
    Attributes
    protected[org.atmosphere.util]
    Definition Classes
    AbstractBroadcasterProxy → DefaultBroadcaster
  50. def getBroadcasterConfig(): BroadcasterConfig
    Definition Classes
    DefaultBroadcaster → Broadcaster
  51. def getBroadcasterLifeCyclePolicy(): BroadcasterLifeCyclePolicy
    Definition Classes
    DefaultBroadcaster → Broadcaster
  52. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  53. def getID(): String
    Definition Classes
    DefaultBroadcaster → Broadcaster
  54. def getScope(): SCOPE
    Definition Classes
    DefaultBroadcaster → Broadcaster
  55. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  56. def incomingBroadcast(): Unit
    Definition Classes
    RedisBroadcaster → AbstractBroadcasterProxy
  57. def initialize(arg0: String, arg1: URI, arg2: AtmosphereConfig): Broadcaster
    Definition Classes
    RedisBroadcaster → AbstractBroadcasterProxy → DefaultBroadcaster → Broadcaster
  58. def initialize(arg0: String, arg1: AtmosphereConfig): Broadcaster
    Definition Classes
    RedisBroadcaster → DefaultBroadcaster
  59. def invokeOnStateChange(arg0: AtmosphereResource, arg1: AtmosphereResourceEvent): Unit
    Attributes
    protected[org.atmosphere.util]
    Definition Classes
    AbstractBroadcasterProxy → DefaultBroadcaster
  60. def isDestroyed(): Boolean
    Definition Classes
    DefaultBroadcaster → Broadcaster
  61. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  62. def killReactiveThreads(): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  63. def lifeCycleListeners(): ConcurrentLinkedQueue[BroadcasterLifeCyclePolicyListener]
    Definition Classes
    DefaultBroadcaster
  64. def lifeCyclePolicy(): BroadcasterLifeCyclePolicy
    Definition Classes
    DefaultBroadcaster
  65. def lifecycleHandler(arg0: LifecycleHandler): DefaultBroadcaster
    Definition Classes
    DefaultBroadcaster
  66. def lifecycleHandler(): LifecycleHandler
    Definition Classes
    DefaultBroadcaster
  67. def messages(): BlockingQueue[Deliver]
    Definition Classes
    DefaultBroadcaster
  68. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  69. final def notify(): Unit
    Definition Classes
    AnyRef
  70. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  71. def notifyAndAdd(arg0: AtmosphereResource): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  72. def notifyBroadcastListener(): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  73. def notifyOnAddAtmosphereResourceListener(arg0: AtmosphereResource): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  74. def notifyOnMessage(arg0: Deliver): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  75. def notifyOnRemoveAtmosphereResourceListener(arg0: AtmosphereResource): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  76. def onException(arg0: Throwable, arg1: AtmosphereResource, arg2: Boolean): Unit
    Definition Classes
    DefaultBroadcaster
  77. def onException(arg0: Throwable, arg1: AtmosphereResource): Unit
    Definition Classes
    DefaultBroadcaster
  78. def outOfOrderBroadcastSupported(): Boolean
    Definition Classes
    DefaultBroadcaster
  79. def outgoingBroadcast(arg0: Any): Unit
    Definition Classes
    RedisBroadcaster → AbstractBroadcasterProxy
  80. def perRequestFilter(arg0: AtmosphereResource, arg1: Deliver): Boolean
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  81. def policy(): POLICY
    Definition Classes
    DefaultBroadcaster
  82. def prepareInvokeOnStateChange(arg0: AtmosphereResource, arg1: AtmosphereResourceEvent): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  83. def push(arg0: Deliver): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  84. def queueWriteIO(arg0: AtmosphereResource, arg1: Deliver, arg2: AtomicInteger): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
    Annotations
    @throws( ... )
  85. def reactiveThreadsCount(): Int
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  86. def recentActivity(): AtomicBoolean
    Definition Classes
    DefaultBroadcaster
  87. def reconfigure(): Unit
    Attributes
    protected[org.atmosphere.util]
    Definition Classes
    AbstractBroadcasterProxy
  88. def releaseExternalResources(): Unit
    Definition Classes
    DefaultBroadcaster → Broadcaster
  89. def removeAtmosphereResource(arg0: AtmosphereResource, arg1: Boolean): Broadcaster
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  90. def removeAtmosphereResource(arg0: AtmosphereResource): Broadcaster
    Definition Classes
    DefaultBroadcaster → Broadcaster
  91. def removeBroadcasterLifeCyclePolicyListener(arg0: BroadcasterLifeCyclePolicyListener): Unit
    Definition Classes
    DefaultBroadcaster → Broadcaster
  92. def removeBroadcasterListener(arg0: BroadcasterListener): Broadcaster
    Definition Classes
    DefaultBroadcaster → Broadcaster
  93. def rename(arg0: String): Broadcaster
    Definition Classes
    DefaultBroadcaster
  94. def resumeAll(): Unit
    Definition Classes
    DefaultBroadcaster → Broadcaster
  95. def retrieveTrackedBroadcast(arg0: AtmosphereResource, arg1: AtmosphereResourceEvent): Boolean
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  96. def scheduleFixedBroadcast(arg0: Any, arg1: Long, arg2: Long, arg3: TimeUnit): Future[AnyRef]
    Definition Classes
    DefaultBroadcaster → Broadcaster
  97. def scheduleFixedBroadcast(arg0: Any, arg1: Long, arg2: TimeUnit): Future[AnyRef]
    Definition Classes
    DefaultBroadcaster → Broadcaster
  98. def setAuth(arg0: String): Unit
    Definition Classes
    RedisBroadcaster
  99. def setBroadcasterConfig(arg0: BroadcasterConfig): Unit
    Definition Classes
    DefaultBroadcaster → Broadcaster
  100. def setBroadcasterLifeCyclePolicy(arg0: BroadcasterLifeCyclePolicy): Unit
    Definition Classes
    DefaultBroadcaster → Broadcaster
  101. def setID(arg0: String): Unit
    Definition Classes
    RedisBroadcaster → DefaultBroadcaster → Broadcaster
  102. def setScope(arg0: SCOPE): Unit
    Definition Classes
    DefaultBroadcaster → Broadcaster
  103. def setSuspendPolicy(arg0: Long, arg1: POLICY): Unit
    Definition Classes
    DefaultBroadcaster → Broadcaster
  104. def setUp(): Unit
    Definition Classes
    RedisBroadcaster
  105. def spawnReactor(): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  106. def start(): Unit
    Attributes
    protected[org.atmosphere.cpr]
    Definition Classes
    DefaultBroadcaster
  107. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  108. def toString(): String
    Definition Classes
    DefaultBroadcaster → AnyRef → Any
  109. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  110. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  111. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  112. def writeQueues(): ConcurrentHashMap[String, WriteQueue]
    Definition Classes
    DefaultBroadcaster

Inherited from ScalatraBroadcaster

Inherited from RedisBroadcaster

Inherited from AbstractBroadcasterProxy

Inherited from DefaultBroadcaster

Inherited from Broadcaster

Inherited from AnyRef

Inherited from Any

Ungrouped