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

WebSocketTransport

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

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

Instance Constructors

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

Type Members

  1. class CREATED extends State

    Attributes
    protected
    Definition Classes
    BaseService
  2. class FAILED extends State

    Attributes
    protected
    Definition Classes
    BaseService
  3. class STARTED extends State

    Attributes
    protected
    Definition Classes
    BaseService
  4. class STARTING extends State

    Attributes
    protected
    Definition Classes
    BaseService
  5. class STOPPED extends State

    Attributes
    protected
    Definition Classes
    BaseService
  6. class STOPPING extends State

    Attributes
    protected
    Definition Classes
    BaseService
  7. sealed class State extends AnyRef

    Definition Classes
    BaseService

Value Members

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

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. var _service_failure: Throwable

    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. var _start_transition_counter: Int

    Definition Classes
    BaseService
  10. def _stop(on_completed: Task): Unit

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

    Definition Classes
    Any
  12. def assert_executing: Unit

    Definition Classes
    Dispatched
  13. var binary_transfers: Boolean

  14. def blockingExecutor: Executor

  15. val certificates: Array[X509Certificate]

  16. def clone(): AnyRef

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

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

  19. var connection: eclipse.jetty.websocket.WebSocket.Connection

  20. var dispatchQueue: DispatchQueue

  21. def dispatch_queue: DispatchQueue

    Definition Classes
    WebSocketTransport → Dispatched
  22. def drainInbound(): Unit

    Definition Classes
    WebSocketTransport → Transport
  23. def drain_inbound: Unit

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

  25. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  26. def finalize(): Unit

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

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

    Definition Classes
    WebSocketTransport → Transport
  29. def getBlockingExecutor(): Executor

    Definition Classes
    WebSocketTransport → Transport
  30. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  31. def getDispatchQueue(): DispatchQueue

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

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

    Definition Classes
    WebSocketTransport → SecuredSession
  34. def getProtocolCodec(): ProtocolCodec

    Definition Classes
    WebSocketTransport → Transport
  35. def getReadChannel(): ReadableByteChannel

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

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

    Definition Classes
    WebSocketTransport → Transport
  38. def getWriteChannel(): WritableByteChannel

    Definition Classes
    WebSocketTransport → Transport
  39. val inbound: ListBuffer[Buffer]

  40. var inbound_capacity_remaining: Int

  41. var inbound_dispatch_queue: DispatchQueue

  42. def isClosed(): Boolean

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

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

    Definition Classes
    Any
  45. def isOpen(): Boolean

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

    Definition Classes
    AnyRef
  47. final def notify(): Unit

    Definition Classes
    AnyRef
  48. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  49. def offer(command: AnyRef): Boolean

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

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

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

    Definition Classes
    WebSocketTransport → OnTextMessage
  53. def onOpen(connection: eclipse.jetty.websocket.WebSocket.Connection): Unit

    Definition Classes
    WebSocketTransport → WebSocket
  54. var outbound_capacity_remaining: Int

  55. object outbound_executor extends SerialExecutor

  56. val protocol: String

  57. var protocolCodec: ProtocolCodec

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

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

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

    Definition Classes
    WebSocketTransport → ReadableByteChannel
  61. val request: HttpServletRequest

  62. def resumeRead(): Unit

    Definition Classes
    WebSocketTransport → Transport
  63. def schedule_reoccurring(time: Long, unit: TimeUnit)(func: ⇒ Unit): Unit

    Definition Classes
    BaseService
  64. val server: WsTransportServer

  65. def service_failure(): Throwable

    Definition Classes
    BaseService → Service
  66. def service_state: State

    Definition Classes
    BaseService
  67. def setBlockingExecutor(value: Executor): Unit

    Definition Classes
    WebSocketTransport → Transport
  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

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

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

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

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

    Definition Classes
    AnyRef
  77. var transportListener: TransportListener

  78. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws()
  81. def write(buf: ByteBuffer): Int

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

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

    Definition Classes
    WebSocketTransport → GatheringByteChannel
  84. var write_failed: Boolean

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 AutoCloseable

Inherited from SecuredSession

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

Ungrouped