object Transport
- Annotations
- @deprecated
- Deprecated
(Since version Akka 2.6.0) Classic remoting is deprecated, use Artery
- Source
- Transport.scala
- Alphabetic
- By Inheritance
- Transport
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class ActorAssociationEventListener(actor: ActorRef) extends AssociationEventListener with Product with Serializable
Class to convert ordinary pekko.actor.ActorRef instances to an AssociationEventListener.
Class to convert ordinary pekko.actor.ActorRef instances to an AssociationEventListener. The adapter will forward event objects as messages to the provided ActorRef.
- trait AssociationEvent extends NoSerializationVerificationNeeded
- trait AssociationEventListener extends AnyRef
An interface that needs to be implemented by the user of a transport to listen to association events
- final case class InboundAssociation(association: AssociationHandle) extends AssociationEvent with Product with Serializable
Message sent to a pekko.remote.transport.Transport.AssociationEventListener registered to a transport (via the Promise returned by pekko.remote.transport.Transport#listen) when an inbound association request arrives.
Message sent to a pekko.remote.transport.Transport.AssociationEventListener registered to a transport (via the Promise returned by pekko.remote.transport.Transport#listen) when an inbound association request arrives.
- association
The handle for the inbound association.
- final case class InvalidAssociationException(msg: String, cause: Throwable = null) extends PekkoException with NoStackTrace with Product with Serializable
Indicates that the association setup request is invalid, and it is impossible to recover (malformed IP address, hostname, etc.).
Indicates that the association setup request is invalid, and it is impossible to recover (malformed IP address, hostname, etc.).
- Annotations
- @SerialVersionUID()
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])