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
}