Class CfnPipe.PipeSourceParametersProperty.Builder
java.lang.Object
software.amazon.awscdk.services.pipes.CfnPipe.PipeSourceParametersProperty.Builder
- All Implemented Interfaces:
software.amazon.jsii.Builder<CfnPipe.PipeSourceParametersProperty>
- Enclosing interface:
CfnPipe.PipeSourceParametersProperty
@Stability(Stable)
public static final class CfnPipe.PipeSourceParametersProperty.Builder
extends Object
implements software.amazon.jsii.Builder<CfnPipe.PipeSourceParametersProperty>
A builder for
CfnPipe.PipeSourceParametersProperty-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionactiveMqBrokerParameters(IResolvable activeMqBrokerParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getActiveMqBrokerParameters()activeMqBrokerParameters(CfnPipe.PipeSourceActiveMQBrokerParametersProperty activeMqBrokerParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getActiveMqBrokerParameters()build()Builds the configured instance.dynamoDbStreamParameters(IResolvable dynamoDbStreamParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getDynamoDbStreamParameters()dynamoDbStreamParameters(CfnPipe.PipeSourceDynamoDBStreamParametersProperty dynamoDbStreamParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getDynamoDbStreamParameters()filterCriteria(IResolvable filterCriteria) Sets the value ofCfnPipe.PipeSourceParametersProperty.getFilterCriteria()filterCriteria(CfnPipe.FilterCriteriaProperty filterCriteria) Sets the value ofCfnPipe.PipeSourceParametersProperty.getFilterCriteria()kinesisStreamParameters(IResolvable kinesisStreamParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getKinesisStreamParameters()kinesisStreamParameters(CfnPipe.PipeSourceKinesisStreamParametersProperty kinesisStreamParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getKinesisStreamParameters()managedStreamingKafkaParameters(IResolvable managedStreamingKafkaParameters) managedStreamingKafkaParameters(CfnPipe.PipeSourceManagedStreamingKafkaParametersProperty managedStreamingKafkaParameters) rabbitMqBrokerParameters(IResolvable rabbitMqBrokerParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getRabbitMqBrokerParameters()rabbitMqBrokerParameters(CfnPipe.PipeSourceRabbitMQBrokerParametersProperty rabbitMqBrokerParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getRabbitMqBrokerParameters()selfManagedKafkaParameters(IResolvable selfManagedKafkaParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getSelfManagedKafkaParameters()selfManagedKafkaParameters(CfnPipe.PipeSourceSelfManagedKafkaParametersProperty selfManagedKafkaParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getSelfManagedKafkaParameters()sqsQueueParameters(IResolvable sqsQueueParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getSqsQueueParameters()sqsQueueParameters(CfnPipe.PipeSourceSqsQueueParametersProperty sqsQueueParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getSqsQueueParameters()
-
Constructor Details
-
Builder
public Builder()
-
-
Method Details
-
activeMqBrokerParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder activeMqBrokerParameters(IResolvable activeMqBrokerParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getActiveMqBrokerParameters()- Parameters:
activeMqBrokerParameters- The parameters for using an Active MQ broker as a source.- Returns:
this
-
activeMqBrokerParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder activeMqBrokerParameters(CfnPipe.PipeSourceActiveMQBrokerParametersProperty activeMqBrokerParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getActiveMqBrokerParameters()- Parameters:
activeMqBrokerParameters- The parameters for using an Active MQ broker as a source.- Returns:
this
-
dynamoDbStreamParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder dynamoDbStreamParameters(IResolvable dynamoDbStreamParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getDynamoDbStreamParameters()- Parameters:
dynamoDbStreamParameters- The parameters for using a DynamoDB stream as a source.- Returns:
this
-
dynamoDbStreamParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder dynamoDbStreamParameters(CfnPipe.PipeSourceDynamoDBStreamParametersProperty dynamoDbStreamParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getDynamoDbStreamParameters()- Parameters:
dynamoDbStreamParameters- The parameters for using a DynamoDB stream as a source.- Returns:
this
-
filterCriteria
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder filterCriteria(IResolvable filterCriteria) Sets the value ofCfnPipe.PipeSourceParametersProperty.getFilterCriteria()- Parameters:
filterCriteria- The collection of event patterns used to filter events. To remove a filter, specify aFilterCriteriaobject with an empty array ofFilterobjects.For more information, see Events and Event Patterns in the Amazon EventBridge User Guide .
- Returns:
this
-
filterCriteria
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder filterCriteria(CfnPipe.FilterCriteriaProperty filterCriteria) Sets the value ofCfnPipe.PipeSourceParametersProperty.getFilterCriteria()- Parameters:
filterCriteria- The collection of event patterns used to filter events. To remove a filter, specify aFilterCriteriaobject with an empty array ofFilterobjects.For more information, see Events and Event Patterns in the Amazon EventBridge User Guide .
- Returns:
this
-
kinesisStreamParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder kinesisStreamParameters(IResolvable kinesisStreamParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getKinesisStreamParameters()- Parameters:
kinesisStreamParameters- The parameters for using a Kinesis stream as a source.- Returns:
this
-
kinesisStreamParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder kinesisStreamParameters(CfnPipe.PipeSourceKinesisStreamParametersProperty kinesisStreamParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getKinesisStreamParameters()- Parameters:
kinesisStreamParameters- The parameters for using a Kinesis stream as a source.- Returns:
this
-
managedStreamingKafkaParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder managedStreamingKafkaParameters(IResolvable managedStreamingKafkaParameters) - Parameters:
managedStreamingKafkaParameters- The parameters for using an MSK stream as a source.- Returns:
this
-
managedStreamingKafkaParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder managedStreamingKafkaParameters(CfnPipe.PipeSourceManagedStreamingKafkaParametersProperty managedStreamingKafkaParameters) - Parameters:
managedStreamingKafkaParameters- The parameters for using an MSK stream as a source.- Returns:
this
-
rabbitMqBrokerParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder rabbitMqBrokerParameters(IResolvable rabbitMqBrokerParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getRabbitMqBrokerParameters()- Parameters:
rabbitMqBrokerParameters- The parameters for using a Rabbit MQ broker as a source.- Returns:
this
-
rabbitMqBrokerParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder rabbitMqBrokerParameters(CfnPipe.PipeSourceRabbitMQBrokerParametersProperty rabbitMqBrokerParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getRabbitMqBrokerParameters()- Parameters:
rabbitMqBrokerParameters- The parameters for using a Rabbit MQ broker as a source.- Returns:
this
-
selfManagedKafkaParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder selfManagedKafkaParameters(IResolvable selfManagedKafkaParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getSelfManagedKafkaParameters()- Parameters:
selfManagedKafkaParameters- The parameters for using a self-managed Apache Kafka stream as a source. A self managed cluster refers to any Apache Kafka cluster not hosted by AWS . This includes both clusters you manage yourself, as well as those hosted by a third-party provider, such as Confluent Cloud , CloudKarafka , or Redpanda . For more information, see Apache Kafka streams as a source in the Amazon EventBridge User Guide .- Returns:
this
-
selfManagedKafkaParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder selfManagedKafkaParameters(CfnPipe.PipeSourceSelfManagedKafkaParametersProperty selfManagedKafkaParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getSelfManagedKafkaParameters()- Parameters:
selfManagedKafkaParameters- The parameters for using a self-managed Apache Kafka stream as a source. A self managed cluster refers to any Apache Kafka cluster not hosted by AWS . This includes both clusters you manage yourself, as well as those hosted by a third-party provider, such as Confluent Cloud , CloudKarafka , or Redpanda . For more information, see Apache Kafka streams as a source in the Amazon EventBridge User Guide .- Returns:
this
-
sqsQueueParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder sqsQueueParameters(IResolvable sqsQueueParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getSqsQueueParameters()- Parameters:
sqsQueueParameters- The parameters for using a Amazon SQS stream as a source.- Returns:
this
-
sqsQueueParameters
@Stability(Stable) public CfnPipe.PipeSourceParametersProperty.Builder sqsQueueParameters(CfnPipe.PipeSourceSqsQueueParametersProperty sqsQueueParameters) Sets the value ofCfnPipe.PipeSourceParametersProperty.getSqsQueueParameters()- Parameters:
sqsQueueParameters- The parameters for using a Amazon SQS stream as a source.- Returns:
this
-
build
Builds the configured instance.- Specified by:
buildin interfacesoftware.amazon.jsii.Builder<CfnPipe.PipeSourceParametersProperty>- Returns:
- a new instance of
CfnPipe.PipeSourceParametersProperty - Throws:
NullPointerException- if any required attribute was not provided
-