unable to create a scheduled message in azure service bus

When creating a scheduled message in azure service bus, it always return connlost error.

I am using golang library:

github.com/Azure/azure-sdk-for-go/sdk/messaging/azservicebus v1.10.0

the code

sequenceNumbers, err := sender.ScheduleMessages(ctx, []*azservicebus.Message{sbMessage}, scheduledTimeUTC, nil)

always return connlost error. I can confirm that the scheduledTimeUTC is valid and, sending a normal message to the same queue works fine, and creating a scheduled message in Azure portal works fine as well.

Here is the full function code.

func (serviceBus *ServiceBus) sendToQueueScheduled(queueName string, message ServiceBusMessage, scheduledTime time.Time) (int64, *exception.Exception) {
	// Validate scheduled time - must be in the future
	now := time.Now().UTC()
	scheduledTimeUTC := scheduledTime.UTC()
	if scheduledTimeUTC.Before(now) {
		err := fmt.Errorf("scheduled time must be in the future: scheduled=%s, now=%s", scheduledTimeUTC.Format(time.RFC3339), now.Format(time.RFC3339))
		serviceBus.logger.ErrorFunction(err, queueName, message)
		return 0, exception.NewException(types.ExceptionTypeInternalServer)
	}
	// Get or create a long-lived sender for the queue
	sender, err := serviceBus.getSender(queueName)
	if err != nil {
		serviceBus.logger.ErrorFunction(err, queueName, message)
		return 0, exception.NewException(types.ExceptionTypeInternalServer)
	}
	// Convert data to JSON
	dataBytes, err := json.Marshal(message.Data)
	if err != nil {
		serviceBus.logger.ErrorFunction(err, queueName, message)
		return 0, exception.NewException(types.ExceptionTypeInternalServer)
	}
	// Create the Service Bus message
	sbMessage := &azservicebus.Message{
		Body: dataBytes,
	}
	if message.ID != "" {
		sbMessage.MessageID = &message.ID
	}
	if message.Subject != "" {
		sbMessage.Subject = &message.Subject
	}
	if message.ContentType != "" {
		sbMessage.ContentType = &message.ContentType
	}
	if len(message.Properties) > 0 {
		sbMessage.ApplicationProperties = make(map[string]any)
		maps.Copy(sbMessage.ApplicationProperties, message.Properties)
	}
	if message.TimeToLive != nil {
		sbMessage.TimeToLive = message.TimeToLive
	}
	// Schedule message with extended timeout (2 minutes for scheduling operations)
	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Minute)
	defer cancel()
	// get sequence number
	sequenceNumbers, err := sender.ScheduleMessages(ctx, []*azservicebus.Message{sbMessage}, scheduledTimeUTC, nil)
	if err != nil {
		serviceBus.logger.ErrorFunction(err, queueName, message, scheduledTimeUTC)
		return 0, exception.NewException(types.ExceptionTypeInternalServer)
	}
	if len(sequenceNumbers) == 0 {
		serviceBus.logger.ErrorFunction(fmt.Errorf("no sequence number returned"), queueName, message)
		return 0, exception.NewException(types.ExceptionTypeInternalServer)
	}
	serviceBus.logger.Infof("successfully scheduled message to queue: %s, messageID: %s, scheduledTime: %s, sequenceNumber: %d",
		queueName, message.ID, scheduledTimeUTC.Format(time.RFC3339), sequenceNumbers[0])
	return sequenceNumbers[0], nil
}

any urgent help is appreciated, thank you community!