diff --git a/constant.go b/constant.go index 6787e5d..6c6ded1 100644 --- a/constant.go +++ b/constant.go @@ -1,9 +1,19 @@ package natsio var Stream = struct { - Selly string + Selly string + User string + HelpCenter string + Order string + Withdrawal string + Jobs string }{ - Selly: "selly", + Selly: "selly", + User: "user", + HelpCenter: "help_center", + Order: "order", + Withdrawal: "withdrawal", + Jobs: "jobs", } var SellyServer = struct { @@ -17,17 +27,3 @@ var SellyServer = struct { SMS: "sms", Chat: "chat", } - -var SellyService = struct { - User string - HelpCenter string - Order string - Withdrawal string - Jobs string -}{ - User: "user", - HelpCenter: "help_center", - Order: "order", - Withdrawal: "withdrawal", - Jobs: "jobs", -} diff --git a/utils.go b/utils.go index f04c363..e6930bf 100644 --- a/utils.go +++ b/utils.go @@ -21,13 +21,13 @@ func combineStreamAndSubjectName(stream, subject string) string { } // GenerateJetStreamSubject ... -func GenerateJetStreamSubject(stream, server, service, subject string) string { - return fmt.Sprintf("%s.jetstream.%s.%s.%s", stream, server, service, subject) +func GenerateJetStreamSubject(stream, server, subject string) string { + return fmt.Sprintf("%s.jetstream.%s.%s", stream, server, subject) } // GenerateReqrepSubject ... -func GenerateReqrepSubject(stream, server, service, subject string) string { - return fmt.Sprintf("%s.reqrep.%s.%s.%s", stream, server, service, subject) +func GenerateReqrepSubject(stream, server, subject string) string { + return fmt.Sprintf("%s.reqrep.%s.%s", stream, server, subject) } // InterfaceToBytes ...