final class EventTestKit extends RedisStore
EventTestKit supports starting Alarm server using embedded redis internally (sentinel + master) and registering it with location service
Example:
private val testKit = EventTestKit() // starting event server (start sentinel on port 6379 and master on port 6378) // it will also register EventService with location service testKit.startEventService(sentinelPort = 6379, serverPort = 6378) // stopping event server testKit.shutdownEventService()
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- EventTestKit
- RedisStore
- EmbeddedRedis
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
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]) @native() @IntrinsicCandidate()
- lazy val connection: TcpConnection
- Attributes
- protected
- Definition Classes
- EventTestKit → RedisStore
- implicit lazy val ec: ExecutionContext
- Definition Classes
- RedisStore
- 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
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- lazy val masterId: String
- Attributes
- protected
- Definition Classes
- EventTestKit → RedisStore
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def shutdown(): Unit
- Definition Classes
- RedisStore
- def shutdownEventService(): Unit
Shutdown Event service
Shutdown Event service
When the test has completed, make sure you shutdown event service. This will terminate actor system and stop redis sentinel and redis server.
- def start(sentinelPort: Optional[Int], serverPort: Optional[Int]): Unit
- Definition Classes
- RedisStore
- def start(sentinelPort: Int = getFreePort, serverPort: Int = getFreePort, keyspaceEvent: Boolean = false): RegistrationResult
- Definition Classes
- RedisStore
- def startEventService(sentinelPort: Optional[Int], serverPort: Optional[Int]): Unit
Java API to Start Event service
Java API to Start Event service
It will start redis sentinel and redis server on provided ports and then register's event service with location service
- def startEventService(sentinelPort: Int = getSentinelPort, serverPort: Int = getMasterPort): RegistrationResult
Scala API to Start Event service
Scala API to Start Event service
It will start redis sentinel and redis server on provided ports and then register's event service with location service
- def startSentinel(sentinelPort: Int = getFreePort, serverPort: Int = getFreePort, masterId: String, keyspaceEvent: Boolean): (RedisSentinel, RedisServer)
- Definition Classes
- EmbeddedRedis
- def stopRedis(): Unit
- Definition Classes
- RedisStore
- def stopSentinel(redisSentinel: RedisSentinel, redisServer: RedisServer): Unit
- Definition Classes
- EmbeddedRedis
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- implicit val system: ActorSystem[_]
- Definition Classes
- EventTestKit → RedisStore
- implicit lazy val timeout: Timeout
- Definition Classes
- EventTestKit → RedisStore
- def toString(): String
- Definition Classes
- AnyRef → Any
- implicit lazy val untypedSystem: ActorSystem
- Definition Classes
- RedisStore
- 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])