if opts['source_publish_port']:
        ret['source_publish_port'] = int(opts['source_publish_port'])
        log.debug('Using %d as source port for the master pub', ret['source_publish_port'])