/** * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. * SPDX-License-Identifier: Apache-2.0. */ #pragma once #include #include #include namespace Aws { namespace Utils { namespace Json { class JsonValue; class JsonView; } // namespace Json } // namespace Utils namespace Pipes { namespace Model { /** *

The parameters for using a Rabbit MQ broker as a source.

See * Also:

AWS * API Reference

*/ class UpdatePipeSourceRabbitMQBrokerParameters { public: AWS_PIPES_API UpdatePipeSourceRabbitMQBrokerParameters(); AWS_PIPES_API UpdatePipeSourceRabbitMQBrokerParameters(Aws::Utils::Json::JsonView jsonValue); AWS_PIPES_API UpdatePipeSourceRabbitMQBrokerParameters& operator=(Aws::Utils::Json::JsonView jsonValue); AWS_PIPES_API Aws::Utils::Json::JsonValue Jsonize() const; /** *

The maximum number of records to include in each batch.

*/ inline int GetBatchSize() const{ return m_batchSize; } /** *

The maximum number of records to include in each batch.

*/ inline bool BatchSizeHasBeenSet() const { return m_batchSizeHasBeenSet; } /** *

The maximum number of records to include in each batch.

*/ inline void SetBatchSize(int value) { m_batchSizeHasBeenSet = true; m_batchSize = value; } /** *

The maximum number of records to include in each batch.

*/ inline UpdatePipeSourceRabbitMQBrokerParameters& WithBatchSize(int value) { SetBatchSize(value); return *this;} /** *

The credentials needed to access the resource.

*/ inline const MQBrokerAccessCredentials& GetCredentials() const{ return m_credentials; } /** *

The credentials needed to access the resource.

*/ inline bool CredentialsHasBeenSet() const { return m_credentialsHasBeenSet; } /** *

The credentials needed to access the resource.

*/ inline void SetCredentials(const MQBrokerAccessCredentials& value) { m_credentialsHasBeenSet = true; m_credentials = value; } /** *

The credentials needed to access the resource.

*/ inline void SetCredentials(MQBrokerAccessCredentials&& value) { m_credentialsHasBeenSet = true; m_credentials = std::move(value); } /** *

The credentials needed to access the resource.

*/ inline UpdatePipeSourceRabbitMQBrokerParameters& WithCredentials(const MQBrokerAccessCredentials& value) { SetCredentials(value); return *this;} /** *

The credentials needed to access the resource.

*/ inline UpdatePipeSourceRabbitMQBrokerParameters& WithCredentials(MQBrokerAccessCredentials&& value) { SetCredentials(std::move(value)); return *this;} /** *

The maximum length of a time to wait for events.

*/ inline int GetMaximumBatchingWindowInSeconds() const{ return m_maximumBatchingWindowInSeconds; } /** *

The maximum length of a time to wait for events.

*/ inline bool MaximumBatchingWindowInSecondsHasBeenSet() const { return m_maximumBatchingWindowInSecondsHasBeenSet; } /** *

The maximum length of a time to wait for events.

*/ inline void SetMaximumBatchingWindowInSeconds(int value) { m_maximumBatchingWindowInSecondsHasBeenSet = true; m_maximumBatchingWindowInSeconds = value; } /** *

The maximum length of a time to wait for events.

*/ inline UpdatePipeSourceRabbitMQBrokerParameters& WithMaximumBatchingWindowInSeconds(int value) { SetMaximumBatchingWindowInSeconds(value); return *this;} private: int m_batchSize; bool m_batchSizeHasBeenSet = false; MQBrokerAccessCredentials m_credentials; bool m_credentialsHasBeenSet = false; int m_maximumBatchingWindowInSeconds; bool m_maximumBatchingWindowInSecondsHasBeenSet = false; }; } // namespace Model } // namespace Pipes } // namespace Aws