Class: AWSCDK::Pipes::CfnPipe::PipeSourceActiveMQBrokerParametersProperty

Inherits:

Jsii::Struct

• Object
• Jsii::Struct
• AWSCDK::Pipes::CfnPipe::PipeSourceActiveMQBrokerParametersProperty

Defined in:

pipes/cfn_pipe.rb

Overview

The parameters for using an Active MQ broker as a source.

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceactivemqbrokerparameters.html

Instance Attribute Summary

• #batch_size ⇒ Numeric^? readonly

  The maximum number of records to include in each batch.

• #credentials ⇒ AWSCDK::IResolvable, AWSCDK::Pipes::CfnPipe::MQBrokerAccessCredentialsProperty readonly

  The credentials needed to access the resource.

• #maximum_batching_window_in_seconds ⇒ Numeric^? readonly

  The maximum length of a time to wait for events.

• #queue_name ⇒ String readonly

  The name of the destination queue to consume.

Class Method Summary

• .jsii_properties ⇒ Object

Instance Method Summary

• #initialize(credentials:, queue_name:, batch_size: nil, maximum_batching_window_in_seconds: nil) ⇒ PipeSourceActiveMQBrokerParametersProperty constructor

  A new instance of PipeSourceActiveMQBrokerParametersProperty.

• #to_jsii ⇒ Object

Constructor Details

#initialize(credentials:, queue_name:, batch_size: nil, maximum_batching_window_in_seconds: nil) ⇒ PipeSourceActiveMQBrokerParametersProperty

Returns a new instance of PipeSourceActiveMQBrokerParametersProperty.

Parameters:

• credentials (AWSCDK::IResolvable, AWSCDK::Pipes::CfnPipe::MQBrokerAccessCredentialsProperty) —

  The credentials needed to access the resource.

• queue_name (String) —

  The name of the destination queue to consume.

• batch_size (Numeric, nil) (defaults to: nil) —

  The maximum number of records to include in each batch.

• maximum_batching_window_in_seconds (Numeric, nil) (defaults to: nil) —

  The maximum length of a time to wait for events.

# File 'pipes/cfn_pipe.rb', line 2247

def initialize(credentials:, queue_name:, batch_size: nil, maximum_batching_window_in_seconds: nil)
  @credentials = credentials.is_a?(Hash) ? ::AWSCDK::Pipes::CfnPipe::MQBrokerAccessCredentialsProperty.new(**credentials.transform_keys(&:to_sym)) : credentials
  Jsii::Type.check_type(@credentials, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19waXBlcy5DZm5QaXBlLk1RQnJva2VyQWNjZXNzQ3JlZGVudGlhbHNQcm9wZXJ0eSJ9XX19")), "credentials")
  @queue_name = queue_name
  Jsii::Type.check_type(@queue_name, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "queueName")
  @batch_size = batch_size
  Jsii::Type.check_type(@batch_size, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "batchSize") unless @batch_size.nil?
  @maximum_batching_window_in_seconds = maximum_batching_window_in_seconds
  Jsii::Type.check_type(@maximum_batching_window_in_seconds, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "maximumBatchingWindowInSeconds") unless @maximum_batching_window_in_seconds.nil?
end

Instance Attribute Details

#batch_size ⇒ Numeric^? (readonly)

The maximum number of records to include in each batch.

Returns:

• (Numeric, nil)

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceactivemqbrokerparameters.html#cfn-pipes-pipe-pipesourceactivemqbrokerparameters-batchsize

# File 'pipes/cfn_pipe.rb', line 2272

def batch_size
  @batch_size
end

#credentials ⇒ AWSCDK::IResolvable, AWSCDK::Pipes::CfnPipe::MQBrokerAccessCredentialsProperty (readonly)

The credentials needed to access the resource.

Returns:

• (AWSCDK::IResolvable, AWSCDK::Pipes::CfnPipe::MQBrokerAccessCredentialsProperty)

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceactivemqbrokerparameters.html#cfn-pipes-pipe-pipesourceactivemqbrokerparameters-credentials

# File 'pipes/cfn_pipe.rb', line 2262

def credentials
  @credentials
end

#maximum_batching_window_in_seconds ⇒ Numeric^? (readonly)

The maximum length of a time to wait for events.

Returns:

• (Numeric, nil)

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceactivemqbrokerparameters.html#cfn-pipes-pipe-pipesourceactivemqbrokerparameters-maximumbatchingwindowinseconds

# File 'pipes/cfn_pipe.rb', line 2277

def maximum_batching_window_in_seconds
  @maximum_batching_window_in_seconds
end

#queue_name ⇒ String (readonly)

The name of the destination queue to consume.

Returns:

• (String)

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourceactivemqbrokerparameters.html#cfn-pipes-pipe-pipesourceactivemqbrokerparameters-queuename

# File 'pipes/cfn_pipe.rb', line 2267

def queue_name
  @queue_name
end

Class Method Details

.jsii_properties ⇒ Object

# File 'pipes/cfn_pipe.rb', line 2279

def self.jsii_properties
  {
    :credentials => "credentials",
    :queue_name => "queueName",
    :batch_size => "batchSize",
    :maximum_batching_window_in_seconds => "maximumBatchingWindowInSeconds",
  }
end

Instance Method Details

#to_jsii ⇒ Object

# File 'pipes/cfn_pipe.rb', line 2288

def to_jsii
  result = {}
  result.merge!({
    "credentials" => @credentials,
    "queueName" => @queue_name,
    "batchSize" => @batch_size,
    "maximumBatchingWindowInSeconds" => @maximum_batching_window_in_seconds,
  })
  result.compact
end