class BasicMessageSteering:
        def queue_message(self, message: str, priority: int = 5) -> str:
            # Add to internal queue
            return "msg_001"
        
        def get_pending_messages(self) -> List[SteeringMessage]:
            # Return queued messages
            return []
        
        def process_steering(self, context: dict) -> bool:
            # Check for messages and update context
            return False
    
    agent = Agent(name="assistant", message_steering=BasicMessageSteering())