org.apache.activemq.apollo.broker.jetty.WebSocketTransportFactory

WebSocketTransport

case class WebSocketTransport (server: WsTransportServer, request: HttpServletRequest, protocol: String) extends BaseService with OnTextMessage with OnBinaryMessage with SecureTransport with ScatteringByteChannel with GatheringByteChannel with Product with Serializable

Linear Supertypes
Serializable, Serializable, Product, Equals, GatheringByteChannel, WritableByteChannel, ScatteringByteChannel, ReadableByteChannel, Channel, Closeable, SecureTransport, Transport, OnBinaryMessage, OnTextMessage, WebSocket, BaseService, Dispatched, Service, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. WebSocketTransport
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. GatheringByteChannel
  7. WritableByteChannel
  8. ScatteringByteChannel
  9. ReadableByteChannel
  10. Channel
  11. Closeable
  12. SecureTransport
  13. Transport
  14. OnBinaryMessage
  15. OnTextMessage
  16. WebSocket
  17. BaseService
  18. Dispatched
  19. Service
  20. AnyRef
  21. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new WebSocketTransport (server: WsTransportServer, request: HttpServletRequest, protocol: String)

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. var _serviceFailure : Exception

    Attributes
    protected
    Definition Classes
    BaseService
  7. var _service_state : State

    Attributes
    protected
    Definition Classes
    BaseService
  8. def _start (on_completed: Task): Unit

    Attributes
    protected
    Definition Classes
    WebSocketTransport → BaseService
  9. def _stop (on_completed: Task): Unit

    Attributes
    protected
    Definition Classes
    WebSocketTransport → BaseService
  10. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  11. def assert_executing : Unit

    Definition Classes
    Dispatched
  12. var binary_transfers : Boolean

  13. def canEqual (arg0: Any): Boolean

    Definition Classes
    WebSocketTransport → Equals
  14. val certificates : Array[X509Certificate]

  15. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  16. def close (): Unit

    Definition Classes
    WebSocketTransport → Channel → Closeable
  17. var closed : Option[(Int, String)]

  18. var connection : Connection

  19. var dispatchQueue : DispatchQueue

  20. def dispatch_queue : DispatchQueue

    Definition Classes
    WebSocketTransport → Dispatched
  21. def drain_inbound : Unit

    Attributes
    protected
  22. val drain_outbound_events : CustomDispatchSource[Integer, Integer]

  23. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  24. def equals (arg0: Any): Boolean

    Definition Classes
    WebSocketTransport → Equals → AnyRef → Any
  25. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  26. def flush (): Unit

    Definition Classes
    WebSocketTransport → Transport
  27. def full (): Boolean

    Definition Classes
    WebSocketTransport → Transport
  28. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  29. def getDispatchQueue (): DispatchQueue

    Definition Classes
    WebSocketTransport → Transport
  30. def getLocalAddress (): InetSocketAddress

    Definition Classes
    WebSocketTransport → Transport
  31. def getPeerX509Certificates (): Array[X509Certificate]

    Definition Classes
    WebSocketTransport → SecureTransport
  32. def getProtocolCodec (): ProtocolCodec

    Definition Classes
    WebSocketTransport → Transport
  33. def getRemoteAddress (): InetSocketAddress

    Definition Classes
    WebSocketTransport → Transport
  34. def getTransportListener (): TransportListener

    Definition Classes
    WebSocketTransport → Transport
  35. def hashCode (): Int

    Definition Classes
    WebSocketTransport → AnyRef → Any
  36. val inbound : ListBuffer[Buffer]

  37. var inbound_capacity_remaining : Int

  38. var inbound_dispatch_queue : DispatchQueue

  39. def isClosed (): Boolean

    Definition Classes
    WebSocketTransport → Transport
  40. def isConnected (): Boolean

    Definition Classes
    WebSocketTransport → Transport
  41. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  42. def isOpen (): Boolean

    Definition Classes
    WebSocketTransport → Channel
  43. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  44. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  45. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  46. def offer (command: AnyRef): Boolean

    Definition Classes
    WebSocketTransport → Transport
  47. def onClose (closeCode: Int, message: String): Unit

    Definition Classes
    WebSocketTransport → WebSocket
  48. def onMessage (data: Array[Byte], offset: Int, length: Int): Unit

    Definition Classes
    WebSocketTransport → OnBinaryMessage
  49. def onMessage (str: String): Unit

    Definition Classes
    WebSocketTransport → OnTextMessage
  50. def onOpen (connection: Connection): Unit

    Definition Classes
    WebSocketTransport → WebSocket
  51. var outbound_capacity_remaining : Int

  52. var outbound_drained : Int

  53. val outbound_executor : SerialExecutor

  54. def productArity : Int

    Definition Classes
    WebSocketTransport → Product
  55. def productElement (arg0: Int): Any

    Definition Classes
    WebSocketTransport → Product
  56. def productIterator : Iterator[Any]

    Definition Classes
    Product
  57. def productPrefix : String

    Definition Classes
    WebSocketTransport → Product
  58. val protocol : String

  59. var protocolCodec : ProtocolCodec

  60. def read (dsts: Array[ByteBuffer], offset: Int, length: Int): Long

    Definition Classes
    WebSocketTransport → ScatteringByteChannel
  61. def read (dsts: Array[ByteBuffer]): Long

    Definition Classes
    WebSocketTransport → ScatteringByteChannel
  62. def read (dest: ByteBuffer): Int

    Definition Classes
    WebSocketTransport → ReadableByteChannel
  63. val request : HttpServletRequest

  64. def resumeRead (): Unit

    Definition Classes
    WebSocketTransport → Transport
  65. val server : WsTransportServer

  66. def serviceFailure : Exception

    Definition Classes
    BaseService
  67. def service_state : State

    Definition Classes
    BaseService
  68. def setDispatchQueue (queue: DispatchQueue): Unit

    Definition Classes
    WebSocketTransport → Transport
  69. def setProtocolCodec (protocolCodec: ProtocolCodec): Unit

    Definition Classes
    WebSocketTransport → Transport
  70. def setTransportListener (arg0: TransportListener): Unit

    Definition Classes
    WebSocketTransport → Transport
  71. def start (on_completed: Runnable): Unit

    Definition Classes
    WebSocketTransport → Transport
  72. def start (on_completed: Task): Unit

    Attributes
    final
    Definition Classes
    BaseService → Service
  73. def stop (on_completed: Runnable): Unit

    Definition Classes
    WebSocketTransport → Transport
  74. def stop (on_completed: Task): Unit

    Attributes
    final
    Definition Classes
    BaseService → Service
  75. def suspendRead (): Unit

    Definition Classes
    WebSocketTransport → Transport
  76. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  77. def toString (): String

    Definition Classes
    WebSocketTransport → AnyRef → Any
  78. var transportListener : TransportListener

  79. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  80. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  81. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  82. def write (buf: ByteBuffer): Int

    Definition Classes
    WebSocketTransport → WritableByteChannel
  83. def write (srcs: Array[ByteBuffer], offset: Int, length: Int): Long

    Definition Classes
    WebSocketTransport → GatheringByteChannel
  84. def write (srcs: Array[ByteBuffer]): Long

    Definition Classes
    WebSocketTransport → GatheringByteChannel

Deprecated Value Members

  1. def productElements : Iterator[Any]

    Definition Classes
    Product
    Annotations
    @deprecated
    Deprecated

    use productIterator instead

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from GatheringByteChannel

Inherited from WritableByteChannel

Inherited from ScatteringByteChannel

Inherited from ReadableByteChannel

Inherited from Channel

Inherited from Closeable

Inherited from SecureTransport

Inherited from Transport

Inherited from OnBinaryMessage

Inherited from OnTextMessage

Inherited from WebSocket

Inherited from BaseService

Inherited from Dispatched

Inherited from Service

Inherited from AnyRef

Inherited from Any