[Phase 7] Implement advanced queue features (scheduling, rate limiting, routing)

.github/workflows/js.yml

@@ -107,6 +107,7 @@ jobs:
   lint:
     name: Lint and Format Check
     runs-on: ubuntu-latest
+    timeout-minutes: 10
     needs: [detect-changes]
     if: |
       github.event_name == 'push' ||
@@ -140,6 +141,7 @@ jobs:
   test:
     name: Test (${{ matrix.runtime }} on ${{ matrix.os }})
     runs-on: ${{ matrix.os }}
+    timeout-minutes: 30
     needs: [detect-changes, changeset-check]
     if: always() && (github.event_name == 'push' || github.event_name == 'workflow_dispatch' || needs.changeset-check.result == 'success' || needs.changeset-check.result == 'skipped')
     strategy:
@@ -192,6 +194,7 @@ jobs:
   coverage:
     name: Test Coverage
     runs-on: ubuntu-latest
+    timeout-minutes: 15
     needs: [detect-changes, changeset-check]
     if: always() && (github.event_name == 'push' || github.event_name == 'workflow_dispatch' || needs.changeset-check.result == 'success' || needs.changeset-check.result == 'skipped')
     steps:

js/.changeset/phase7-advanced-features.md

@@ -0,0 +1,10 @@
+---
+'links-queue-js': minor
+---
+
+Add Phase 7 advanced queue features
+
+- **Scheduling**: Implement `CronParser`, `Scheduler`, and `ScheduledQueue` for delayed messages, cron jobs, TTL, and message expiration
+- **Rate Limiting**: Implement `SlidingWindowCounter`, `TokenBucket`, `RateLimiter`, and `RateLimitedQueue` with sliding window algorithm
+- **Routing**: Implement `TopicMatcher`, `DirectExchange`, `TopicExchange`, `FanoutExchange`, `HeadersExchange`, `Router`, and `RoutedQueueManager` for topic-based routing with AMQP-style wildcards
+- **Pub/Sub**: Implement `MessageFilter`, `PubSubBroker`, `ObservableQueue`, and `QueueBackedPubSub` for publish/subscribe patterns with message filtering

js/src/features/index.js

@@ -0,0 +1,37 @@
+/**
+ * Advanced queue features module exports.
+ *
+ * @module features
+ */
+
+// Scheduler exports
+export { CronParser, Scheduler, ScheduledQueue } from './scheduler.js';
+
+// Rate limiter exports
+export {
+  SlidingWindowCounter,
+  TokenBucket,
+  RateLimiter,
+  RateLimitedQueue,
+  RateLimitError,
+} from './rate-limiter.js';
+
+// Router exports
+export {
+  ExchangeType,
+  TopicMatcher,
+  DirectExchange,
+  TopicExchange,
+  FanoutExchange,
+  HeadersExchange,
+  Router,
+  RoutedQueueManager,
+} from './router.js';
+
+// Pub/Sub exports
+export {
+  MessageFilter,
+  PubSubBroker,
+  ObservableQueue,
+  QueueBackedPubSub,
+} from './pubsub.js';