Package berlin.yuna.natsserver.junit.logic

Class 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 Detail

      • NatsServer

        public NatsServer()

    • Method Detail

      • 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

      • 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()

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object