public PubSubSubscriberFactoryForEmulator()

in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/emulator/PubSubSubscriberFactoryForEmulator.java [46:58]

• 13 lines of code
• 1 McCabe index (conditional complexity)

    public PubSubSubscriberFactoryForEmulator(
            String hostAndPort,
            String project,
            String subscription,
            int retries,
            Duration timeout,
            int maxMessagesPerPull) {
        this.hostAndPort = hostAndPort;
        this.retries = retries;
        this.timeout = timeout;
        this.maxMessagesPerPull = maxMessagesPerPull;
        this.projectSubscriptionName = ProjectSubscriptionName.format(project, subscription);
    }