berlin.yuna.natsserver.junit.logic

Class NatsServer

java.lang.Object

berlin.yuna.natsserver.junit.logic.NatsServer

All Implemented Interfaces:

org.junit.jupiter.api.extension.AfterAllCallback, org.junit.jupiter.api.extension.BeforeAllCallback, org.junit.jupiter.api.extension.Extension, org.junit.jupiter.api.extension.ExtensionContext.Store.CloseableResource, org.junit.jupiter.params.provider.ArgumentsProvider

public class NatsServer
extends Object
implements org.junit.jupiter.api.extension.BeforeAllCallback, org.junit.jupiter.api.extension.AfterAllCallback, org.junit.jupiter.params.provider.ArgumentsProvider, org.junit.jupiter.api.extension.ExtensionContext.Store.CloseableResource

Constructor Summary

Constructors

Constructor and Description
NatsServer()

Method Summary

Modifier and Type	Method and Description
void	afterAll(org.junit.jupiter.api.extension.ExtensionContext context)
void	beforeAll(org.junit.jupiter.api.extension.ExtensionContext context)
void	close()
boolean	equals(Object o)
String	getConfig(berlin.yuna.natsserver.config.NatsConfig key)
String	getConfig(berlin.yuna.natsserver.config.NatsConfig key, Supplier<String> or)
String	getHost()
String	getName()
berlin.yuna.natsserver.logic.Nats	getNats()
static NatsServer	getNatsServer() Returns last running NatsServer
static NatsServer	getNatsServerBy(Predicate<NatsServer> filter) Returns first running NatsServer with filter
static NatsServer	getNatsServerByHost(String host) Returns first running NatsServer with host
static NatsServer	getNatsServerByName(String name) Returns first running NatsServer with name
static NatsServer	getNatsServerByPid(int pid) Returns first running NatsServer with pid (processId)
static NatsServer	getNatsServerByPort(int port) Returns first running NatsServer with port (For random port please identify by name)
int	getPid()
int	getPort()
long	getTimeoutMs()
int	hashCode()
Stream<? extends org.junit.jupiter.params.provider.Arguments>	provideArguments(org.junit.jupiter.api.extension.ExtensionContext extensionContext)
berlin.yuna.natsserver.logic.Nats	stop()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

NatsServer

public NatsServer()

Method Detail

getNatsServer

public static NatsServer getNatsServer()

Returns last running NatsServer

Returns:

NatsServer or null if no no server is running

getNatsServerByName

public static NatsServer getNatsServerByName(String name)

Returns first running NatsServer with name

Returns:

NatsServer or null on no match

getNatsServerByPid

public static NatsServer getNatsServerByPid(int pid)

Returns first running NatsServer with pid (processId)

Returns:

NatsServer or null on no match

getNatsServerByPort

public static NatsServer getNatsServerByPort(int port)

Returns first running NatsServer with port (For random port please identify by name)

Returns:

NatsServer or null on no match

getNatsServerByHost

public static NatsServer getNatsServerByHost(String host)

Returns first running NatsServer with host

Returns:

NatsServer or null on no match

getNatsServerBy

public static NatsServer getNatsServerBy(Predicate<NatsServer> filter)

Returns first running NatsServer with filter

Returns:

NatsServer or null on no match

beforeAll

public void beforeAll(org.junit.jupiter.api.extension.ExtensionContext context)

Specified by:

beforeAll in interface org.junit.jupiter.api.extension.BeforeAllCallback

afterAll

public void afterAll(org.junit.jupiter.api.extension.ExtensionContext context)

Specified by:

afterAll in interface org.junit.jupiter.api.extension.AfterAllCallback

close

public void close()

Specified by:

close in interface org.junit.jupiter.api.extension.ExtensionContext.Store.CloseableResource

provideArguments

public Stream<? extends org.junit.jupiter.params.provider.Arguments> provideArguments(org.junit.jupiter.api.extension.ExtensionContext extensionContext)

Specified by:

provideArguments in interface org.junit.jupiter.params.provider.ArgumentsProvider

getConfig

public String getConfig(berlin.yuna.natsserver.config.NatsConfig key)

getConfig

public String getConfig(berlin.yuna.natsserver.config.NatsConfig key,
                        Supplier<String> or)

getTimeoutMs

public long getTimeoutMs()

getPid

public int getPid()

getPort

public int getPort()

getHost

public String getHost()

getName

public String getName()

stop

public berlin.yuna.natsserver.logic.Nats stop()

getNats

public berlin.yuna.natsserver.logic.Nats getNats()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object