c

org.scalatra.atmosphere

DefaultScalatraBroadcaster

final class DefaultScalatraBroadcaster extends DefaultBroadcaster with ScalatraBroadcaster

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

Instance Constructors

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

Inherited from ScalatraBroadcaster

Inherited from DefaultBroadcaster

Inherited from Broadcaster

Inherited from AnyRef

Inherited from Any

Ungrouped