diff --git a/.env b/.env index a029ae7..8923e13 100644 --- a/.env +++ b/.env @@ -5,7 +5,7 @@ # Core Application Settings NODE_ENV=development LOG_LEVEL=trace -LOG_HIDE_OBJECT=true +LOG_HIDE_OBJECT=false # Data Service Configuration DATA_SERVICE_PORT=2001 diff --git a/.serena/cache/typescript/document_symbols_cache_v20-05-25.pkl b/.serena/cache/typescript/document_symbols_cache_v20-05-25.pkl index 8a3db7e..11457a0 100644 Binary files a/.serena/cache/typescript/document_symbols_cache_v20-05-25.pkl and b/.serena/cache/typescript/document_symbols_cache_v20-05-25.pkl differ diff --git a/libs/services/queue/src/service-registry.ts b/libs/services/queue/src/service-registry.ts index 4c693c6..5d14a3c 100644 --- a/libs/services/queue/src/service-registry.ts +++ b/libs/services/queue/src/service-registry.ts @@ -89,14 +89,14 @@ export function findServiceForHandler(handlerName: string): string | undefined { * Get full queue name with service namespace */ export function getFullQueueName(serviceName: string, handlerName: string): string { - return `${serviceName}:${handlerName}`; + return `${serviceName}_${handlerName}`; } /** * Parse a full queue name into service and handler */ export function parseQueueName(fullQueueName: string): { service: string; handler: string } | null { - const parts = fullQueueName.split(':'); + const parts = fullQueueName.split('_'); if (parts.length !== 2 || !parts[0] || !parts[1]) { return null; } diff --git a/libs/services/queue/src/smart-queue-manager.ts b/libs/services/queue/src/smart-queue-manager.ts index e4efeb5..cb80a78 100644 --- a/libs/services/queue/src/smart-queue-manager.ts +++ b/libs/services/queue/src/smart-queue-manager.ts @@ -212,7 +212,7 @@ export class SmartQueueManager extends QueueManager { * Resolve a queue name to a route */ private resolveQueueRoute(queueName: string): QueueRoute | null { - // Check if it's a full name (service:handler) + // Check if it's a full name (service_handler) const parsed = parseQueueName(queueName); if (parsed) { const config = getServiceConfig(parsed.service); diff --git a/libs/services/queue/src/types.ts b/libs/services/queue/src/types.ts index a2b6f15..ae600c7 100644 --- a/libs/services/queue/src/types.ts +++ b/libs/services/queue/src/types.ts @@ -175,7 +175,7 @@ export interface SmartQueueConfig extends QueueManagerConfig { } export interface QueueRoute { - /** Full queue name (e.g., 'data-ingestion:ceo') */ + /** Full queue name (e.g., 'data-ingestion_ceo') */ fullName: string; /** Service that owns this queue */ service: string;