nats

var NewJetStreamMsg = func(subject string, data []byte) *jetStreamMsg {
	return &jetStreamMsg{
		msg: &nats.Msg{
			Subject: subject,
			Data:    data,
		},
	}
}