def METHOD_NAME(self):
    if not self.socket:
        self.create_socket()
    self.log('info', f'Connecting to {self.address}')
    try:
        self.socket.connect(self.address)
        self.log('info', f'Connected to {self.address}')
    except zmq.error.ZMQError as err:
        if (str(err) == 'Address already in use'):
            self.log('error', f'Address {self.address} already in use.')
        else:
            self.log('error', err)