diff --git a/node.go b/node.go new file mode 100644 index 0000000..4c6ec8b --- /dev/null +++ b/node.go @@ -0,0 +1,19 @@ +package natsio + +import "github.com/nats-io/nats.go" + +// Node include all necessary things of a client +type Node struct { + Sv Server + Js JetStream +} + +func (n Node) ServerQueueSubscribe(subjectName string, h nats.MsgHandler) { + queueName := GenerateQueueNameFromSubject(subjectName) + _, _ = n.Sv.QueueSubscribe(subjectName, queueName, h) +} + +func (n Node) JetStreamQueueSubscribe(subjectName string, h nats.MsgHandler) { + queueName := GenerateQueueNameFromSubject(subjectName) + _ = n.Js.QueueSubscribe(subjectName, queueName, h) +}