Camel.terminators.base

class BaseTerminator(ABC):

def __init__(self, *args, **kwargs):

def is_terminated(self, *args, **kwargs):

def reset(self):

class ResponseTerminator(BaseTerminator):

def is_terminated(self, messages: List[BaseMessage]):

def reset(self):