drain abstract method

Future<List<AgentMessage>> drain(String agentId)

The unread messages for agentId, oldest first, consumed (marked read). A drained message never appears again.

Implementation

Future<List<AgentMessage>> drain(String agentId);