csw.testkit

Class EventTestKit

java.lang.Object

csw.testkit.EventTestKit

All Implemented Interfaces:

EmbeddedRedis, RedisStore

public final class EventTestKit
extends java.lang.Object
implements 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()

 

Method Summary

Modifier and Type	Method and Description
static EventTestKit	apply(akka.actor.ActorSystem actorSystem, TestKitSettings testKitSettings) Create a EventTestKit
protected Connection.TcpConnection	connection()
static EventTestKit	create(akka.actor.ActorSystem actorSystem) Java API to create a EventTestKit
static EventTestKit	create(TestKitSettings testKitSettings) Java API to create a EventTestKit
static csw.location.api.scaladsl.LocationService	csw$testkit$redis$RedisStore$$locationService()
static void	csw$testkit$redis$RedisStore$$redisSentinel_$eq(scala.Option<redis.embedded.RedisSentinel> x$1)
static scala.Option<redis.embedded.RedisSentinel>	csw$testkit$redis$RedisStore$$redisSentinel()
static void	csw$testkit$redis$RedisStore$$redisServer_$eq(scala.Option<redis.embedded.RedisServer> x$1)
static scala.Option<redis.embedded.RedisServer>	csw$testkit$redis$RedisStore$$redisServer()
scala.concurrent.ExecutionContext	ec()
protected java.lang.String	masterId()
akka.stream.Materializer	mat()
static void	shutdown()
void	shutdownEventService() Shutdown Event service
static RegistrationResult	start(int sentinelPort, int serverPort)
static void	start(java.util.Optional<java.lang.Object> sentinelPort, java.util.Optional<java.lang.Object> serverPort)
static int	start$default$1()
static int	start$default$2()
RegistrationResult	startEventService(int sentinelPort, int serverPort) Scala API to Start Event service
void	startEventService(java.util.Optional<java.lang.Object> sentinelPort, java.util.Optional<java.lang.Object> serverPort) Java API to Start Event service
static scala.Tuple2<redis.embedded.RedisSentinel,redis.embedded.RedisServer>	startSentinel(int sentinelPort, int serverPort, java.lang.String masterId)
static int	startSentinel$default$1()
static int	startSentinel$default$2()
static void	stopRedis()
static void	stopSentinel(redis.embedded.RedisSentinel redisSentinel, redis.embedded.RedisServer redisServer)
akka.actor.ActorSystem	system()
akka.util.Timeout	timeout()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface csw.testkit.redis.RedisStore

shutdown, start, start, stopRedis

Methods inherited from interface csw.testkit.redis.EmbeddedRedis

addJvmShutdownHook, startSentinel, stopSentinel

Method Detail

apply

public static EventTestKit apply(akka.actor.ActorSystem actorSystem,
                                 TestKitSettings testKitSettings)

Create a EventTestKit

When the test has completed you should shutdown the event service with shutdownEventService().

Parameters:

actorSystem - (undocumented)

testKitSettings - (undocumented)

Returns:

handle to EventTestKit which can be used to start and stop event service

create

public static EventTestKit create(akka.actor.ActorSystem actorSystem)

Java API to create a EventTestKit

Parameters:

actorSystem -

Returns:

handle to EventTestKit which can be used to start and stop event service

create

public static EventTestKit create(TestKitSettings testKitSettings)

Java API to create a EventTestKit

Parameters:

testKitSettings - custom testKitSettings

Returns:

handle to EventTestKit which can be used to start and stop event service

startSentinel

public static scala.Tuple2<redis.embedded.RedisSentinel,redis.embedded.RedisServer> startSentinel(int sentinelPort,
                                                                                                  int serverPort,
                                                                                                  java.lang.String masterId)

stopSentinel

public static void stopSentinel(redis.embedded.RedisSentinel redisSentinel,
                                redis.embedded.RedisServer redisServer)

startSentinel$default$1

public static int startSentinel$default$1()

startSentinel$default$2

public static int startSentinel$default$2()

csw$testkit$redis$RedisStore$$redisSentinel

public static scala.Option<redis.embedded.RedisSentinel> csw$testkit$redis$RedisStore$$redisSentinel()

csw$testkit$redis$RedisStore$$redisSentinel_$eq

public static void csw$testkit$redis$RedisStore$$redisSentinel_$eq(scala.Option<redis.embedded.RedisSentinel> x$1)

csw$testkit$redis$RedisStore$$redisServer

public static scala.Option<redis.embedded.RedisServer> csw$testkit$redis$RedisStore$$redisServer()

csw$testkit$redis$RedisStore$$redisServer_$eq

public static void csw$testkit$redis$RedisStore$$redisServer_$eq(scala.Option<redis.embedded.RedisServer> x$1)

csw$testkit$redis$RedisStore$$locationService

public static csw.location.api.scaladsl.LocationService csw$testkit$redis$RedisStore$$locationService()

start

public static RegistrationResult start(int sentinelPort,
                                       int serverPort)

start

public static void start(java.util.Optional<java.lang.Object> sentinelPort,
                         java.util.Optional<java.lang.Object> serverPort)

stopRedis

public static void stopRedis()

shutdown

public static void shutdown()

start$default$1

public static int start$default$1()

start$default$2

public static int start$default$2()

mat

public akka.stream.Materializer mat()

Specified by:

mat in interface RedisStore

ec

public scala.concurrent.ExecutionContext ec()

Specified by:

ec in interface RedisStore

system

public akka.actor.ActorSystem system()

Specified by:

system in interface RedisStore

timeout

public akka.util.Timeout timeout()

Specified by:

timeout in interface RedisStore

masterId

protected java.lang.String masterId()

Specified by:

masterId in interface RedisStore

connection

protected Connection.TcpConnection connection()

Specified by:

connection in interface RedisStore

startEventService

public RegistrationResult startEventService(int sentinelPort,
                                            int serverPort)

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

Parameters:

sentinelPort - (undocumented)

serverPort - (undocumented)

Returns:

(undocumented)

startEventService

public void startEventService(java.util.Optional<java.lang.Object> sentinelPort,
                              java.util.Optional<java.lang.Object> serverPort)

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

Parameters:

sentinelPort - (undocumented)

serverPort - (undocumented)

shutdownEventService

public void shutdownEventService()

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.