def METHOD_NAME(self, log_type: str, message: str) -> None:
    if self.local_ip:
        named_message = f'[SUBSCRIBER] {message}'
        logger = get_logger(f'[{self.current_thread.name}][{self.local_ip}]')
    else:
        named_message = message
        logger = get_logger(f'SUBSCRIBER')
    if log_type == 'info':
        logger.info(named_message)
    if log_type == 'error':
        logger.error(named_message)
    if log_type == 'warning':
        logger.warning(named_message)