diff --git a/solutions/aws-message-queue-elasticache/__tests__/route.test.ts b/solutions/aws-message-queue-elasticache/__tests__/route.test.ts
index e342c2da37..516ea3964f 100644
--- a/solutions/aws-message-queue-elasticache/__tests__/route.test.ts
+++ b/solutions/aws-message-queue-elasticache/__tests__/route.test.ts
@@ -28,6 +28,19 @@ beforeEach(() => {
   mockClient.ping.mockResolvedValue('PONG')
 })
 
+describe('Valkey client config', () => {
+  it('connects with a named client for observability', async () => {
+    mockClient.xautoclaim.mockResolvedValue(['0-0', {}, []])
+    mockClient.xreadgroup.mockResolvedValue([])
+    await GET()
+
+    const { GlideClient } = await import('@valkey/valkey-glide')
+    expect(GlideClient.createClient).toHaveBeenCalledWith(
+      expect.objectContaining({ clientName: 'vercel_message_queue_client' }),
+    )
+  })
+})
+
 describe('POST /api/messages', () => {
   it('returns 201 with streamMessageId on valid input', async () => {
     mockClient.xadd.mockResolvedValue('1234567890-0')
diff --git a/solutions/aws-message-queue-elasticache/app/api/messages/route.ts b/solutions/aws-message-queue-elasticache/app/api/messages/route.ts
index 7a2050d695..625da75c44 100644
--- a/solutions/aws-message-queue-elasticache/app/api/messages/route.ts
+++ b/solutions/aws-message-queue-elasticache/app/api/messages/route.ts
@@ -41,6 +41,7 @@ async function getClient(): Promise<GlideClient> {
   const config: GlideClientConfiguration = {
     addresses: [{ host, port }],
     requestTimeout: 5000,
+    clientName: 'vercel_message_queue_client',
   }
 
   client = await GlideClient.createClient(config)