Method enqueue

src/crates/execution/agent-runtime/src/event_queue.rs:76–120

Enqueue event

(
        &self,
        event: AgenticEvent,
        priority: Option<EventPriority>,
    )

    /// Enqueue event
    pub async fn enqueue(
        &self,
        event: AgenticEvent,
        priority: Option<EventPriority>,
    ) -> EventBusResult<String> {
        let priority = priority.unwrap_or_else(|| event.default_priority());
        let envelope = EventEnvelope::new(event, priority);
        let event_id = envelope.id.clone();

        // Check queue size
        {
            let queue = self.queue.lock().await;
            if queue.len() >= self.config.max_queue_size {
                warn!("Event queue full, dropping event: event_id={}", event_id);
                return Ok(event_id);
            }
        }

        // Add to queue
        {
            let mut queue = self.queue.lock().await;
            queue.push(std::cmp::Reverse(envelope.clone()));
        }

        let _ = self.broadcast_tx.send(envelope);

        // Update statistics: get queue size first, then update statistics (avoid getting queue lock while holding stats lock)
        let queue_len = self.queue.lock().await.len();
        {
            let mut stats = self.stats.lock().await;
            stats.total_enqueued += 1;
            stats.pending_events = queue_len;
        }

        // Notify waiting consumers
        self.notify.notify_one();

        trace!(
            "Event enqueued: event_id={}, priority={:?}",
            event_id,
            priority
        );

        Ok(event_id)
    }

    /// Dequeue batch of events
    pub async fn dequeue_batch(&self, max_size: usize) -> Vec<EventEnvelope> {