private RMQSink()

in flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java [70:81]

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

    private RMQSink(
            RMQConnectionConfig rmqConnectionConfig,
            @Nullable String queueName,
            SerializationSchema<IN> schema,
            @Nullable RMQSinkPublishOptions<IN> publishOptions,
            @Nullable SerializableReturnListener returnListener) {
        this.rmqConnectionConfig = rmqConnectionConfig;
        this.queueName = queueName;
        this.schema = schema;
        this.publishOptions = publishOptions;
        this.returnListener = returnListener;
    }