Package 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 Details

    • NatsServer

      public NatsServer()

  • Method Details

    • 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