feat: expose ScheduleAt (#84)

common/options/publisheropts/options.go

@@ -78,14 +78,25 @@ func SetDefaultHeader(headerName, msgKey string) ManagementOption {
 	}
 }
 
-// SetDefaultHeader adds a header to every message published using the value specified from the message body
+// SetMessageMarshaller sets the message marshaller for this publisher. defaults to json.
 func SetMessageMarshaller(marshaller marshal.Marshaller) ManagementOption {
 	return func(p common.Publisher) error {
 		p.SetMarshaller(marshaller)
 		return nil
 	}
 }
 
+// SetScheduleAt schedules a message in the future
+func SetScheduleAt(t time.Time) Option {
+	return func(msg *servicebus.Message) error {
+		if msg == nil {
+			return errors.New("message is nil. cannot set schedule at")
+		}
+		msg.ScheduleAt(t)
+		return nil
+	}
+}
+
 // SetMessageDelay schedules a message in the future
 func SetMessageDelay(delay time.Duration) Option {
 	return func(msg *servicebus.Message) error {