diff --git a/request.go b/request.go new file mode 100644 index 0000000..99bd1ff --- /dev/null +++ b/request.go @@ -0,0 +1,15 @@ +package natsio + +import ( + "time" + + "github.com/nats-io/nats.go" +) + +// Default timeout 10s +const requestTimeout = 10 * time.Second + +// Request ... +func Request(subject string, payload []byte) (*nats.Msg, error) { + return natsClient.Request(subject, payload, requestTimeout) +}