(t *testing.T, s *server.Server)
| 54 | } |
| 55 | |
| 56 | func restartBasicJSServer(t *testing.T, s *server.Server) *server.Server { |
| 57 | opts := natsserver.DefaultTestOptions |
| 58 | clientURL, err := url.Parse(s.ClientURL()) |
| 59 | if err != nil { |
| 60 | t.Fatalf("Unexpected error: %v", err) |
| 61 | } |
| 62 | port, err := strconv.Atoi(clientURL.Port()) |
| 63 | if err != nil { |
| 64 | t.Fatalf("Unexpected error: %v", err) |
| 65 | } |
| 66 | opts.Port = port |
| 67 | opts.JetStream = true |
| 68 | opts.StoreDir = s.JetStreamConfig().StoreDir |
| 69 | s.Shutdown() |
| 70 | s.WaitForShutdown() |
| 71 | return RunServerWithOptions(&opts) |
| 72 | } |
| 73 | |
| 74 | func TestJetStreamNotEnabled(t *testing.T) { |
| 75 | s := RunServerOnPort(-1) |
no test coverage detected