func()

in servicebus/servicebus_fake.go [39:46]


func (s *FakeSender) SendMessage(_ context.Context, message []byte) error {
	s.client.mu.Lock()
	defer s.client.mu.Unlock()

	// Append message to the slice (acting as a queue).
	s.client.messages = append(s.client.messages, message)
	return nil
}