SubscriberAkkaConnection

Instance Constructors

new SubscriberAkkaConnection(system: ActorSystem, host: String, port: Int, passwordOpt: Option[String], nameOpt: Option[String], decodersCount: Int, receiveTimeoutOpt: Option[FiniteDuration], connectTimeout: FiniteDuration, maxWriteBatchSize: Int, tcpSendBufferSizeHint: Int, tcpReceiveBufferSizeHint: Int, akkaListenerDispatcherPath: String, akkaIODispatcherPath: String, akkaDecoderDispatcherPath: String)

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
val akkaDecoderDispatcherPath: String

Attributes
protected
Definition Classes
AbstractAkkaConnection
val akkaIODispatcherPath: String

Attributes
protected
Definition Classes
AbstractAkkaConnection
val akkaListenerDispatcherPath: String

Attributes
protected
Definition Classes
AbstractAkkaConnection
final def asInstanceOf[T0]: T0

Definition Classes
Any
def authenticate(password: String): Future[Unit]

Attributes
protected
def awaitTermination(timeout: Duration = Duration.Inf): Unit

Waits for all the internal actors to be shutdown.
Waits for all the internal actors to be shutdown.
timeout
amount of time to wait

Definition Classes
AbstractAkkaConnection
Note
This method is usually called after issuing a QUIT command
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
val connectTimeout: FiniteDuration

Attributes
protected
Definition Classes
AbstractAkkaConnection
var database: Int

Attributes
protected
Definition Classes
AbstractAkkaConnection
val decodersCount: Int

Attributes
protected
Definition Classes
AbstractAkkaConnection
implicit val dispatcher: ExecutionContextExecutor

Definition Classes
AbstractAkkaConnection → Connection
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def getDatabase: Int

Attributes
protected
Definition Classes
AbstractAkkaConnection
def getNameOpt: Option[String]

Attributes
protected
Definition Classes
AbstractAkkaConnection
def getPasswordOpt: Option[String]

Attributes
protected
Definition Classes
AbstractAkkaConnection
def hashCode(): Int

Definition Classes
AnyRef → Any
val host: String

Definition Classes
AbstractAkkaConnection
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
var isShuttingDown: Boolean

Attributes
protected
Definition Classes
AbstractAkkaConnection
val listenerActor: ActorRef

Attributes
protected
Definition Classes
SubscriberAkkaConnection → AbstractAkkaConnection
lazy val logger: Logger

Attributes
protected
Definition Classes
LazyLogging → Logging
val maxWriteBatchSize: Int

Attributes
protected
Definition Classes
AbstractAkkaConnection
var nameOpt: Option[String]

Attributes
protected
Definition Classes
AbstractAkkaConnection
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
var passwordOpt: Option[String]

Attributes
protected
Definition Classes
AbstractAkkaConnection
val port: Int

Definition Classes
AbstractAkkaConnection
val receiveTimeoutOpt: Option[FiniteDuration]

Attributes
protected
Definition Classes
AbstractAkkaConnection
def sendAsSubscriber(request: Request[_]): Future[Int]

Attributes
protected
Definition Classes
SubscriberAkkaConnection → SubscriberConnection
def setName(name: String): Future[Unit]

Attributes
protected
def setSubscription(subscription: Subscription): Unit

Attributes
protected
Definition Classes
SubscriberAkkaConnection → SubscriberConnection
def shutdown(): Future[Unit]

Attributes
protected
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
val system: ActorSystem

Attributes
protected
Definition Classes
AbstractAkkaConnection
val tcpReceiveBufferSizeHint: Int

Attributes
protected
Definition Classes
AbstractAkkaConnection
val tcpSendBufferSizeHint: Int

Attributes
protected
Definition Classes
AbstractAkkaConnection
def toString(): String

Definition Classes
AnyRef → Any
def updateState(request: Request[_]): Unit

Attributes
protected
Definition Classes
AbstractAkkaConnection
final def wait(): Unit

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

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

Definition Classes
AnyRef
Annotations
@throws( ... )
def watchTermination(): Unit

Attributes
protected
Definition Classes
AbstractAkkaConnection

abstract class SubscriberAkkaConnection extends AbstractAkkaConnection with SubscriberConnection

Instance Constructors

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

val akkaDecoderDispatcherPath: String

val akkaIODispatcherPath: String

val akkaListenerDispatcherPath: String

final def asInstanceOf[T0]: T0

def authenticate(password: String): Future[Unit]

def awaitTermination(timeout: Duration = Duration.Inf): Unit

def clone(): AnyRef

val connectTimeout: FiniteDuration

var database: Int

val decodersCount: Int

implicit val dispatcher: ExecutionContextExecutor

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def getDatabase: Int

def getNameOpt: Option[String]

def getPasswordOpt: Option[String]

def hashCode(): Int

val host: String

final def isInstanceOf[T0]: Boolean

var isShuttingDown: Boolean

val listenerActor: ActorRef

lazy val logger: Logger

val maxWriteBatchSize: Int

var nameOpt: Option[String]

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

var passwordOpt: Option[String]

val port: Int

val receiveTimeoutOpt: Option[FiniteDuration]

def sendAsSubscriber(request: Request[_]): Future[Int]

def setName(name: String): Future[Unit]

def setSubscription(subscription: Subscription): Unit

def shutdown(): Future[Unit]

final def synchronized[T0](arg0: ⇒ T0): T0

val system: ActorSystem

val tcpReceiveBufferSizeHint: Int

val tcpSendBufferSizeHint: Int

def toString(): String

def updateState(request: Request[_]): Unit

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def watchTermination(): Unit

Inherited from SubscriberConnection

Inherited from AbstractAkkaConnection

Inherited from LazyLogging

Inherited from Logging

Inherited from Connection

Inherited from AnyRef

Inherited from Any

Ungrouped