(t *testing.T)
| 193 | } |
| 194 | |
| 195 | func TestNoHeaderSupport(t *testing.T) { |
| 196 | opts := natsserver.DefaultTestOptions |
| 197 | opts.Port = -1 |
| 198 | opts.NoHeaderSupport = true |
| 199 | s := RunServerWithOptions(&opts) |
| 200 | defer s.Shutdown() |
| 201 | |
| 202 | nc, err := nats.Connect(s.ClientURL()) |
| 203 | if err != nil { |
| 204 | t.Fatalf("Error connecting to server: %v", err) |
| 205 | } |
| 206 | defer nc.Close() |
| 207 | |
| 208 | m := nats.NewMsg("foo") |
| 209 | m.Header.Add("Authorization", "s3cr3t") |
| 210 | m.Data = []byte("Hello Headers!") |
| 211 | |
| 212 | if err := nc.PublishMsg(m); err != nats.ErrHeadersNotSupported { |
| 213 | t.Fatalf("Expected an error, got %v", err) |
| 214 | } |
| 215 | |
| 216 | if _, err := nc.RequestMsg(m, time.Second); err != nats.ErrHeadersNotSupported { |
| 217 | t.Fatalf("Expected an error, got %v", err) |
| 218 | } |
| 219 | } |
| 220 | |
| 221 | func TestMsgHeadersCasePreserving(t *testing.T) { |
| 222 | s := RunServerOnPort(-1) |
nothing calls this directly
no test coverage detected