32 lines
743 B
Go
32 lines
743 B
Go
package tenant
|
|
|
|
import "testing"
|
|
|
|
func TestCommandRoutingPreservesTenantKey(t *testing.T) {
|
|
got, err := CommandRoutingKey("租户-A")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
want := "agent-call.tenant.租户-A.call.execute"
|
|
if got != want {
|
|
t.Fatalf("routing key = %q, want %q", got, want)
|
|
}
|
|
if err := VerifyCommandRouting("租户-A", got); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
queue, err := CommandQueue("租户-A")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if queue != "agent-call.executor.租户-A.v1" {
|
|
t.Fatalf("queue = %q", queue)
|
|
}
|
|
deadLetterQueue, err := DeadLetterQueue("租户-A")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if deadLetterQueue != "agent-call.executor.租户-A.dlq.v1" {
|
|
t.Fatalf("dead-letter queue = %q", deadLetterQueue)
|
|
}
|
|
}
|