Packages

  • package root
    Definition Classes
    root
  • package akka
    Definition Classes
    root
  • package wamp

    Contains classes, traits, types and functions to be used to write applications based on WAMP - Web Application Messaging Protocol

    Contains classes, traits, types and functions to be used to write applications based on WAMP - Web Application Messaging Protocol

    Client

    Akka Wamp provides you with three distinct Client APIs in the wamp.client package

    • Actor based
    • Future based
    • Stream based

    Router

    Akka Wamp provides you with a basic router implementation in the wamp.router package

    Definition Classes
    akka
  • package client

    Contains classes, traits, types and functions to be used to implement WAMP clients in Scala.

    Contains classes, traits, types and functions to be used to implement WAMP clients in Scala.

    Please refer to the official Akka Wamp User's Guide for further details.

    Actors

    Is the low level Client API.

    Futures

    Is the high level Client API we encourage you to use.

    import akka.actor._
    import akka.wamp.client._
    import com.typesafe.config._
    
    val config = ConfigFactory.load("my.conf")
    val system = ActorSystem("myapp", config)
    val client = Client(system)
    
    client.connect("myrouter").foreach { conn =>
      conn.open("myrealm").foreach { implicit s =>
    
        publish("mytopic", List("paolo", 99))
    
        subscribe("mytopic", (name: String, age: Int) = {
          println(s"$name is $age years old")
        }
    
        call("myprocedure", List("paolo", 99))
    
        register("myprocedure", (name: String, age: Int) => {
          name.length + age
        })
      }
    }

    Streams

    Working in progress.

    See also

    akka.wamp.client.japi for Java API

  • package messages
  • package router
  • package serialization
  • Connection
  • Dict
  • Peer
  • RichConfig
  • RichDict
  • Roles
  • Session
  • SessionScopedIdGenerator
  • Wamp
p

akka

wamp

package wamp

Contains classes, traits, types and functions to be used to write applications based on WAMP - Web Application Messaging Protocol

Client

Akka Wamp provides you with three distinct Client APIs in the wamp.client package

  • Actor based
  • Future based
  • Stream based

Router

Akka Wamp provides you with a basic router implementation in the wamp.router package

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. wamp
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. trait Connection extends AnyRef

    Represents a transport connection between two Peers

    Represents a transport connection between two Peers

    See also

    akka.wamp.client.Connection TODO @see akka.wamp.client.Connection

  2. type Dict = Map[String, Any]

    Represents a dictionary.

    Represents a dictionary.

    Instances can be created using its companion object.

  3. type Id = Long

    Represents a unique identifier

  4. trait Peer extends AnyRef

    Represents a peer (either client or router)

  5. implicit class RichConfig extends AnyRef

    Implicitly wraps a TypeSafe Config to provide additional utility methods

  6. implicit class RichDict extends AnyRef

    Implicitly wraps a Dict to provide additional utility methods

  7. type Role = String

    Represents a role played by a Peer

  8. trait Session extends AnyRef

    Represents a transient conversation between two Peers attached to a realm and running over a Connection.

    Represents a transient conversation between two Peers attached to a realm and running over a Connection.

    See also

    akka.wamp.router.Session

    akka.wamp.client.Session

  9. class SessionScopedIdGenerator extends IdGenerator

    Generate identifiers in session scope.

    Generate identifiers in session scope.

    Identifiers are incremented by 1 beginning with 1 and they are used for

    • Dealer.invocations
    • Client.*
  10. type Uri = String

    Represents an uniform resource identifier

Value Members

  1. object Dict

    Factory for Dict instances

    Factory for Dict instances

    See also

    RichDict

  2. object Roles

    Are the roles sets

  3. object Wamp extends ExtensionId[WampExt] with ExtensionIdProvider

    Is the extension driver for Akka IO layer

    Is the extension driver for Akka IO layer

    For a full description of the design and philosophy behind this implementation please refer to the Akka online documentation.

    Connect

    (For clients) In order to open an outbound connection send a messages.Connect to the IO manager.

    import akka.io._
    import akka.wamp._
    import akka.wamp.messages._
    
    val manager = IO(Wamp)
    manager ! Connect("wss://host:9999/router", "json")
    
    def receive = {
      case Connected(handler) =>
    }

    Bind

    (For routers) In order to start listening for inbound connections send a messages.Bind to the IO manager.

    import akka.io._
    import akka.wamp._
    import akka.wamp.router._
    import akka.wamp.messages._
    
    val router = Router.props()
    
    val manager = IO(Wamp)
    manager ! Bind(router)
    
    def receive = {
      case Bound(listener, port) =>
    }

Inherited from AnyRef

Inherited from Any

Ungrouped