cloudamqp.RabbitConfiguration

CloudAMQP v3.27.1, Mar 20 26

Viewing docs for CloudAMQP v3.27.1
published on Friday, Mar 20, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-cloudamqp

Viewing docs for CloudAMQP v3.27.1
published on Friday, Mar 20, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-cloudamqp

Example Usage

RabbitMQ configuration and using 0 values

From v1.35.0 and migrating this resource to Terraform plugin Framework. It’s now possible to use 0 values in the configuration.

import * as pulumi from "@pulumi/pulumi";
import * as cloudamqp from "@pulumi/cloudamqp";

const rabbitmqConfig = new cloudamqp.RabbitConfiguration("rabbitmq_config", {
    instanceId: instance.id,
    heartbeat: 0,
});

import pulumi
import pulumi_cloudamqp as cloudamqp

rabbitmq_config = cloudamqp.RabbitConfiguration("rabbitmq_config",
    instance_id=instance["id"],
    heartbeat=0)

package main

import (
	"github.com/pulumi/pulumi-cloudamqp/sdk/v3/go/cloudamqp"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := cloudamqp.NewRabbitConfiguration(ctx, "rabbitmq_config", &cloudamqp.RabbitConfigurationArgs{
			InstanceId: pulumi.Any(instance.Id),
			Heartbeat:  pulumi.Int(0),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using CloudAmqp = Pulumi.CloudAmqp;

return await Deployment.RunAsync(() => 
{
    var rabbitmqConfig = new CloudAmqp.RabbitConfiguration("rabbitmq_config", new()
    {
        InstanceId = instance.Id,
        Heartbeat = 0,
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.cloudamqp.RabbitConfiguration;
import com.pulumi.cloudamqp.RabbitConfigurationArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var rabbitmqConfig = new RabbitConfiguration("rabbitmqConfig", RabbitConfigurationArgs.builder()
            .instanceId(instance.id())
            .heartbeat(0)
            .build());

    }
}

resources:
  rabbitmqConfig:
    type: cloudamqp:RabbitConfiguration
    name: rabbitmq_config
    properties:
      instanceId: ${instance.id}
      heartbeat: 0

RabbitMQ configuration with default values

import * as pulumi from "@pulumi/pulumi";
import * as cloudamqp from "@pulumi/cloudamqp";

const rabbitmqConfig = new cloudamqp.RabbitConfiguration("rabbitmq_config", {
    instanceId: instance.id,
    channelMax: 0,
    connectionMax: -1,
    consumerTimeout: 7200000,
    heartbeat: 120,
    logExchangeLevel: "error",
    maxMessageSize: 134217728,
    queueIndexEmbedMsgsBelow: 4096,
    vmMemoryHighWatermark: 0.81,
    clusterPartitionHandling: "autoheal",
});

import pulumi
import pulumi_cloudamqp as cloudamqp

rabbitmq_config = cloudamqp.RabbitConfiguration("rabbitmq_config",
    instance_id=instance["id"],
    channel_max=0,
    connection_max=-1,
    consumer_timeout=7200000,
    heartbeat=120,
    log_exchange_level="error",
    max_message_size=134217728,
    queue_index_embed_msgs_below=4096,
    vm_memory_high_watermark=0.81,
    cluster_partition_handling="autoheal")

package main

import (
	"github.com/pulumi/pulumi-cloudamqp/sdk/v3/go/cloudamqp"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := cloudamqp.NewRabbitConfiguration(ctx, "rabbitmq_config", &cloudamqp.RabbitConfigurationArgs{
			InstanceId:               pulumi.Any(instance.Id),
			ChannelMax:               pulumi.Int(0),
			ConnectionMax:            pulumi.Int(-1),
			ConsumerTimeout:          pulumi.Int(7200000),
			Heartbeat:                pulumi.Int(120),
			LogExchangeLevel:         pulumi.String("error"),
			MaxMessageSize:           pulumi.Int(134217728),
			QueueIndexEmbedMsgsBelow: pulumi.Int(4096),
			VmMemoryHighWatermark:    pulumi.Float64(0.81),
			ClusterPartitionHandling: pulumi.String("autoheal"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using CloudAmqp = Pulumi.CloudAmqp;

return await Deployment.RunAsync(() => 
{
    var rabbitmqConfig = new CloudAmqp.RabbitConfiguration("rabbitmq_config", new()
    {
        InstanceId = instance.Id,
        ChannelMax = 0,
        ConnectionMax = -1,
        ConsumerTimeout = 7200000,
        Heartbeat = 120,
        LogExchangeLevel = "error",
        MaxMessageSize = 134217728,
        QueueIndexEmbedMsgsBelow = 4096,
        VmMemoryHighWatermark = 0.81,
        ClusterPartitionHandling = "autoheal",
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.cloudamqp.RabbitConfiguration;
import com.pulumi.cloudamqp.RabbitConfigurationArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var rabbitmqConfig = new RabbitConfiguration("rabbitmqConfig", RabbitConfigurationArgs.builder()
            .instanceId(instance.id())
            .channelMax(0)
            .connectionMax(-1)
            .consumerTimeout(7200000)
            .heartbeat(120)
            .logExchangeLevel("error")
            .maxMessageSize(134217728)
            .queueIndexEmbedMsgsBelow(4096)
            .vmMemoryHighWatermark(0.81)
            .clusterPartitionHandling("autoheal")
            .build());

    }
}

resources:
  rabbitmqConfig:
    type: cloudamqp:RabbitConfiguration
    name: rabbitmq_config
    properties:
      instanceId: ${instance.id}
      channelMax: 0
      connectionMax: -1
      consumerTimeout: 7.2e+06
      heartbeat: 120
      logExchangeLevel: error
      maxMessageSize: 1.34217728e+08
      queueIndexEmbedMsgsBelow: 4096
      vmMemoryHighWatermark: 0.81
      clusterPartitionHandling: autoheal

Change log level and combine `cloudamqp.NodeActions` for RabbitMQ restart

import * as pulumi from "@pulumi/pulumi";
import * as cloudamqp from "@pulumi/cloudamqp";

const rabbitmqConfig = new cloudamqp.RabbitConfiguration("rabbitmq_config", {
    instanceId: instance.id,
    channelMax: 0,
    connectionMax: -1,
    consumerTimeout: 7200000,
    heartbeat: 120,
    logExchangeLevel: "info",
    maxMessageSize: 134217728,
    queueIndexEmbedMsgsBelow: 4096,
    vmMemoryHighWatermark: 0.81,
    clusterPartitionHandling: "autoheal",
});
const listNodes = cloudamqp.getNodes({
    instanceId: instance.id,
});
const nodeAction = new cloudamqp.NodeActions("node_action", {
    instanceId: instance.id,
    action: "cluster.restart",
}, {
    dependsOn: [rabbitmqConfig],
});

import pulumi
import pulumi_cloudamqp as cloudamqp

rabbitmq_config = cloudamqp.RabbitConfiguration("rabbitmq_config",
    instance_id=instance["id"],
    channel_max=0,
    connection_max=-1,
    consumer_timeout=7200000,
    heartbeat=120,
    log_exchange_level="info",
    max_message_size=134217728,
    queue_index_embed_msgs_below=4096,
    vm_memory_high_watermark=0.81,
    cluster_partition_handling="autoheal")
list_nodes = cloudamqp.get_nodes(instance_id=instance["id"])
node_action = cloudamqp.NodeActions("node_action",
    instance_id=instance["id"],
    action="cluster.restart",
    opts = pulumi.ResourceOptions(depends_on=[rabbitmq_config]))

package main

import (
	"github.com/pulumi/pulumi-cloudamqp/sdk/v3/go/cloudamqp"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		rabbitmqConfig, err := cloudamqp.NewRabbitConfiguration(ctx, "rabbitmq_config", &cloudamqp.RabbitConfigurationArgs{
			InstanceId:               pulumi.Any(instance.Id),
			ChannelMax:               pulumi.Int(0),
			ConnectionMax:            pulumi.Int(-1),
			ConsumerTimeout:          pulumi.Int(7200000),
			Heartbeat:                pulumi.Int(120),
			LogExchangeLevel:         pulumi.String("info"),
			MaxMessageSize:           pulumi.Int(134217728),
			QueueIndexEmbedMsgsBelow: pulumi.Int(4096),
			VmMemoryHighWatermark:    pulumi.Float64(0.81),
			ClusterPartitionHandling: pulumi.String("autoheal"),
		})
		if err != nil {
			return err
		}
		_, err = cloudamqp.GetNodes(ctx, &cloudamqp.GetNodesArgs{
			InstanceId: instance.Id,
		}, nil)
		if err != nil {
			return err
		}
		_, err = cloudamqp.NewNodeActions(ctx, "node_action", &cloudamqp.NodeActionsArgs{
			InstanceId: pulumi.Any(instance.Id),
			Action:     pulumi.String("cluster.restart"),
		}, pulumi.DependsOn([]pulumi.Resource{
			rabbitmqConfig,
		}))
		if err != nil {
			return err
		}
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using CloudAmqp = Pulumi.CloudAmqp;

return await Deployment.RunAsync(() => 
{
    var rabbitmqConfig = new CloudAmqp.RabbitConfiguration("rabbitmq_config", new()
    {
        InstanceId = instance.Id,
        ChannelMax = 0,
        ConnectionMax = -1,
        ConsumerTimeout = 7200000,
        Heartbeat = 120,
        LogExchangeLevel = "info",
        MaxMessageSize = 134217728,
        QueueIndexEmbedMsgsBelow = 4096,
        VmMemoryHighWatermark = 0.81,
        ClusterPartitionHandling = "autoheal",
    });

    var listNodes = CloudAmqp.GetNodes.Invoke(new()
    {
        InstanceId = instance.Id,
    });

    var nodeAction = new CloudAmqp.NodeActions("node_action", new()
    {
        InstanceId = instance.Id,
        Action = "cluster.restart",
    }, new CustomResourceOptions
    {
        DependsOn =
        {
            rabbitmqConfig,
        },
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.cloudamqp.RabbitConfiguration;
import com.pulumi.cloudamqp.RabbitConfigurationArgs;
import com.pulumi.cloudamqp.CloudamqpFunctions;
import com.pulumi.cloudamqp.inputs.GetNodesArgs;
import com.pulumi.cloudamqp.NodeActions;
import com.pulumi.cloudamqp.NodeActionsArgs;
import com.pulumi.resources.CustomResourceOptions;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var rabbitmqConfig = new RabbitConfiguration("rabbitmqConfig", RabbitConfigurationArgs.builder()
            .instanceId(instance.id())
            .channelMax(0)
            .connectionMax(-1)
            .consumerTimeout(7200000)
            .heartbeat(120)
            .logExchangeLevel("info")
            .maxMessageSize(134217728)
            .queueIndexEmbedMsgsBelow(4096)
            .vmMemoryHighWatermark(0.81)
            .clusterPartitionHandling("autoheal")
            .build());

        final var listNodes = CloudamqpFunctions.getNodes(GetNodesArgs.builder()
            .instanceId(instance.id())
            .build());

        var nodeAction = new NodeActions("nodeAction", NodeActionsArgs.builder()
            .instanceId(instance.id())
            .action("cluster.restart")
            .build(), CustomResourceOptions.builder()
                .dependsOn(rabbitmqConfig)
                .build());

    }
}

resources:
  rabbitmqConfig:
    type: cloudamqp:RabbitConfiguration
    name: rabbitmq_config
    properties:
      instanceId: ${instance.id}
      channelMax: 0
      connectionMax: -1
      consumerTimeout: 7.2e+06
      heartbeat: 120
      logExchangeLevel: info
      maxMessageSize: 1.34217728e+08
      queueIndexEmbedMsgsBelow: 4096
      vmMemoryHighWatermark: 0.81
      clusterPartitionHandling: autoheal
  nodeAction:
    type: cloudamqp:NodeActions
    name: node_action
    properties:
      instanceId: ${instance.id}
      action: cluster.restart
    options:
      dependsOn:
        - ${rabbitmqConfig}
variables:
  listNodes:
    fn::invoke:
      function: cloudamqp:getNodes
      arguments:
        instanceId: ${instance.id}

Only change log level for exchange. All other values will be read from the RabbitMQ configuration.

import * as pulumi from "@pulumi/pulumi";
import * as cloudamqp from "@pulumi/cloudamqp";

const rabbitConfig = new cloudamqp.RabbitConfiguration("rabbit_config", {
    instanceId: instance.id,
    logExchangeLevel: "info",
});

import pulumi
import pulumi_cloudamqp as cloudamqp

rabbit_config = cloudamqp.RabbitConfiguration("rabbit_config",
    instance_id=instance["id"],
    log_exchange_level="info")

package main

import (
	"github.com/pulumi/pulumi-cloudamqp/sdk/v3/go/cloudamqp"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := cloudamqp.NewRabbitConfiguration(ctx, "rabbit_config", &cloudamqp.RabbitConfigurationArgs{
			InstanceId:       pulumi.Any(instance.Id),
			LogExchangeLevel: pulumi.String("info"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using CloudAmqp = Pulumi.CloudAmqp;

return await Deployment.RunAsync(() => 
{
    var rabbitConfig = new CloudAmqp.RabbitConfiguration("rabbit_config", new()
    {
        InstanceId = instance.Id,
        LogExchangeLevel = "info",
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.cloudamqp.RabbitConfiguration;
import com.pulumi.cloudamqp.RabbitConfigurationArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var rabbitConfig = new RabbitConfiguration("rabbitConfig", RabbitConfigurationArgs.builder()
            .instanceId(instance.id())
            .logExchangeLevel("info")
            .build());

    }
}

resources:
  rabbitConfig:
    type: cloudamqp:RabbitConfiguration
    name: rabbit_config
    properties:
      instanceId: ${instance.id}
      logExchangeLevel: info

MQTT and SSL configuration and combine `cloudamqp.NodeActions` for RabbitMQ restart

SSL certificate-based authentication for MQTT connections requires peer certificate verification. Set the following when enabling mqtt_ssl_cert_login:

ssl_options_fail_if_no_peer_cert = true
ssl_options_verify = verify_peer

import * as pulumi from "@pulumi/pulumi";
import * as cloudamqp from "@pulumi/cloudamqp";

const rabbitmqConfig = new cloudamqp.RabbitConfiguration("rabbitmq_config", {
    instanceId: instance.id,
    mqttVhost: instance.vhost,
    mqttExchange: "amq.topic",
    mqttSslCertLogin: true,
    sslOptionsFailIfNoPeerCert: true,
    sslOptionsVerify: "verify_peer",
});
const nodes = cloudamqp.getNodes({
    instanceId: instance.id,
});
const nodeAction = new cloudamqp.NodeActions("node_action", {
    instanceId: instance.id,
    nodeName: nodes.then(nodes => nodes.nodes?.[0]?.name),
    action: "restart",
}, {
    dependsOn: [rabbitmqConfig],
});

import pulumi
import pulumi_cloudamqp as cloudamqp

rabbitmq_config = cloudamqp.RabbitConfiguration("rabbitmq_config",
    instance_id=instance["id"],
    mqtt_vhost=instance["vhost"],
    mqtt_exchange="amq.topic",
    mqtt_ssl_cert_login=True,
    ssl_options_fail_if_no_peer_cert=True,
    ssl_options_verify="verify_peer")
nodes = cloudamqp.get_nodes(instance_id=instance["id"])
node_action = cloudamqp.NodeActions("node_action",
    instance_id=instance["id"],
    node_name=nodes.nodes[0].name,
    action="restart",
    opts = pulumi.ResourceOptions(depends_on=[rabbitmq_config]))

package main

import (
	"github.com/pulumi/pulumi-cloudamqp/sdk/v3/go/cloudamqp"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		rabbitmqConfig, err := cloudamqp.NewRabbitConfiguration(ctx, "rabbitmq_config", &cloudamqp.RabbitConfigurationArgs{
			InstanceId:                 pulumi.Any(instance.Id),
			MqttVhost:                  pulumi.Any(instance.Vhost),
			MqttExchange:               pulumi.String("amq.topic"),
			MqttSslCertLogin:           pulumi.Bool(true),
			SslOptionsFailIfNoPeerCert: pulumi.Bool(true),
			SslOptionsVerify:           pulumi.String("verify_peer"),
		})
		if err != nil {
			return err
		}
		nodes, err := cloudamqp.GetNodes(ctx, &cloudamqp.GetNodesArgs{
			InstanceId: instance.Id,
		}, nil)
		if err != nil {
			return err
		}
		_, err = cloudamqp.NewNodeActions(ctx, "node_action", &cloudamqp.NodeActionsArgs{
			InstanceId: pulumi.Any(instance.Id),
			NodeName:   pulumi.String(nodes.Nodes[0].Name),
			Action:     pulumi.String("restart"),
		}, pulumi.DependsOn([]pulumi.Resource{
			rabbitmqConfig,
		}))
		if err != nil {
			return err
		}
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using CloudAmqp = Pulumi.CloudAmqp;

return await Deployment.RunAsync(() => 
{
    var rabbitmqConfig = new CloudAmqp.RabbitConfiguration("rabbitmq_config", new()
    {
        InstanceId = instance.Id,
        MqttVhost = instance.Vhost,
        MqttExchange = "amq.topic",
        MqttSslCertLogin = true,
        SslOptionsFailIfNoPeerCert = true,
        SslOptionsVerify = "verify_peer",
    });

    var nodes = CloudAmqp.GetNodes.Invoke(new()
    {
        InstanceId = instance.Id,
    });

    var nodeAction = new CloudAmqp.NodeActions("node_action", new()
    {
        InstanceId = instance.Id,
        NodeName = nodes.Apply(getNodesResult => getNodesResult.Nodes[0]?.Name),
        Action = "restart",
    }, new CustomResourceOptions
    {
        DependsOn =
        {
            rabbitmqConfig,
        },
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.cloudamqp.RabbitConfiguration;
import com.pulumi.cloudamqp.RabbitConfigurationArgs;
import com.pulumi.cloudamqp.CloudamqpFunctions;
import com.pulumi.cloudamqp.inputs.GetNodesArgs;
import com.pulumi.cloudamqp.NodeActions;
import com.pulumi.cloudamqp.NodeActionsArgs;
import com.pulumi.resources.CustomResourceOptions;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var rabbitmqConfig = new RabbitConfiguration("rabbitmqConfig", RabbitConfigurationArgs.builder()
            .instanceId(instance.id())
            .mqttVhost(instance.vhost())
            .mqttExchange("amq.topic")
            .mqttSslCertLogin(true)
            .sslOptionsFailIfNoPeerCert(true)
            .sslOptionsVerify("verify_peer")
            .build());

        final var nodes = CloudamqpFunctions.getNodes(GetNodesArgs.builder()
            .instanceId(instance.id())
            .build());

        var nodeAction = new NodeActions("nodeAction", NodeActionsArgs.builder()
            .instanceId(instance.id())
            .nodeName(nodes.nodes()[0].name())
            .action("restart")
            .build(), CustomResourceOptions.builder()
                .dependsOn(rabbitmqConfig)
                .build());

    }
}

resources:
  rabbitmqConfig:
    type: cloudamqp:RabbitConfiguration
    name: rabbitmq_config
    properties:
      instanceId: ${instance.id}
      mqttVhost: ${instance.vhost}
      mqttExchange: amq.topic
      mqttSslCertLogin: true
      sslOptionsFailIfNoPeerCert: true
      sslOptionsVerify: verify_peer
  nodeAction:
    type: cloudamqp:NodeActions
    name: node_action
    properties:
      instanceId: ${instance.id}
      nodeName: ${nodes.nodes[0].name}
      action: restart
    options:
      dependsOn:
        - ${rabbitmqConfig}
variables:
  nodes:
    fn::invoke:
      function: cloudamqp:getNodes
      arguments:
        instanceId: ${instance.id}

Argument threshold values

heartbeat

Type	Default	Min	Affect
int	120	0	Only effects new connection

### connection_max

Type	Default	Min	Affect
int	-1	1	Applied immediately (RabbitMQ restart required before 3.11.13)

Note: -1 in the provider corresponds to INFINITY in the RabbitMQ config

### channel_max

Type	Default	Min	Affect
int	128	0	Only effects new connections

Note: 0 means “no limit”

### consumer_timeout

Type	Default	Min	Max	Unit	Affect
int	7200000	10000	86400000	milliseconds	Only effects new channels

Note: -1 in the provider corresponds to false (disable) in the RabbitMQ config

### vm_memory_high_watermark

Type	Default	Min	Max	Affect
float	0.81	0.4	0.9	Applied immediately

### queue_index_embed_msgs_below

Type	Default	Min	Max	Unit	Affect
int	4096	0	10485760	bytes	Applied immediately for new queues

Note: Existing queues requires restart

### max_message_size

Type	Default	Min	Max	Unit	Affect
int	134217728	1	536870912	bytes	Only effects new channels

### log_exchange_level

Type	Default	Affect	Allowed values
string	error	RabbitMQ restart required	`debug, info, warning, error, critical, none`

### cluster_partition_handling

Type	Affect	Allowed values
string	Applied immediately	`autoheal, pause_minority, ignore`

Recommended setting for cluster_partition_handling: autoheal for cluster with 1-2 nodes, pause_minority for cluster with 3 or more nodes. While ignore setting is not recommended.

### message_interceptors_timestamp_overwrite

Type	Affect	Allowed values
string	RabbitMQ restart required	`enabled_with_overwrite, enabled, disabled`

Note: Corresponds to setting message_interceptors.incoming.set_header_timestamp.overwrite

### mqtt_vhost

Type	Affect
string	Only affects new connections

Note: A vhost is automatically created when cloudamqp.Instance is created. This attribute defaults to that vhost (I.e. cloudamqp_instance.instance.vhost).

### mqtt_exchange

Type	Affect
string	Only affects new connections

### mqtt_ssl_cert_login

Type	Affect
bool	RabbitMQ restart required

Note: When enabled, rabbit.ssl_options.fail_if_no_peer_cert should be set to true and rabbit.ssl_options.verify should be set to verify_peer for it to work properly.

### ssl_cert_login_from

Type	Affect	Allowed values
string	Only affects new connections	`common_name`, `distinguished_name`

### ssl_options_fail_if_no_peer_cert

Type	Affect
string	RabbitMQ restart required

Note: When enabled, rabbit.ssl_options.verify must be set to verify_peer.

### ssl_options_verify

Type	Affect	Allowed values
string	RabbitMQ restart required	`verify_none`, `verify_peer`

Note: verify_peer validates the client’s certificate chain, verify_none disables verification.

Dependency

This resource depends on CloudAMQP instance identifier, cloudamqp_instance.instance.id.

Known issues

Cannot set heartbeat=0 when creating this resource

Note: This is no longer the case from v1.35.0.

The provider is built by older Terraform Plugin SDK which doesn’t support nullable configuration values. Instead the values will be set to it’s default value based on it’s schema primitive type.

schema.TypeString = ""
schema.TypeInt = 0
schema.TypeFloat = 0.0
schema.TypeBool = false

During initial create of this resource, we need to exclude all arguments that can take these default values. Argument such as hearbeat, channel_max, etc. cannot be set to its default value, 0 in these cases. Current workaround is to use the default value in the initial create run, then change to the wanted value in the re-run.

Will be solved once we migrate the current provider to Terraform Plugin Framework.

Create RabbitConfiguration Resource

Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

Constructor syntax

new RabbitConfiguration(name: string, args: RabbitConfigurationArgs, opts?: CustomResourceOptions);

@overload
def RabbitConfiguration(resource_name: str,
                        args: RabbitConfigurationArgs,
                        opts: Optional[ResourceOptions] = None)

@overload
def RabbitConfiguration(resource_name: str,
                        opts: Optional[ResourceOptions] = None,
                        instance_id: Optional[int] = None,
                        message_interceptors_timestamp_overwrite: Optional[str] = None,
                        mqtt_vhost: Optional[str] = None,
                        consumer_timeout: Optional[int] = None,
                        heartbeat: Optional[int] = None,
                        cluster_partition_handling: Optional[str] = None,
                        log_exchange_level: Optional[str] = None,
                        max_message_size: Optional[int] = None,
                        channel_max: Optional[int] = None,
                        connection_max: Optional[int] = None,
                        mqtt_exchange: Optional[str] = None,
                        mqtt_ssl_cert_login: Optional[bool] = None,
                        queue_index_embed_msgs_below: Optional[int] = None,
                        sleep: Optional[int] = None,
                        ssl_cert_login_from: Optional[str] = None,
                        ssl_options_fail_if_no_peer_cert: Optional[bool] = None,
                        ssl_options_verify: Optional[str] = None,
                        timeout: Optional[int] = None,
                        vm_memory_high_watermark: Optional[float] = None)

func NewRabbitConfiguration(ctx *Context, name string, args RabbitConfigurationArgs, opts ...ResourceOption) (*RabbitConfiguration, error)

public RabbitConfiguration(string name, RabbitConfigurationArgs args, CustomResourceOptions? opts = null)

public RabbitConfiguration(String name, RabbitConfigurationArgs args)
public RabbitConfiguration(String name, RabbitConfigurationArgs args, CustomResourceOptions options)

type: cloudamqp:RabbitConfiguration
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

Parameters

name string: The unique name of the resource.
args RabbitConfigurationArgs: The arguments to resource properties.
opts CustomResourceOptions: Bag of options to control resource's behavior.

resource_name str: The unique name of the resource.
args RabbitConfigurationArgs: The arguments to resource properties.
opts ResourceOptions: Bag of options to control resource's behavior.

ctx Context: Context object for the current deployment.
name string: The unique name of the resource.
args RabbitConfigurationArgs: The arguments to resource properties.
opts ResourceOption: Bag of options to control resource's behavior.

name string: The unique name of the resource.
args RabbitConfigurationArgs: The arguments to resource properties.
opts CustomResourceOptions: Bag of options to control resource's behavior.

name String: The unique name of the resource.
args RabbitConfigurationArgs: The arguments to resource properties.
options CustomResourceOptions: Bag of options to control resource's behavior.

Constructor example

The following reference example uses placeholder values for all input properties.

var rabbitConfigurationResource = new CloudAmqp.RabbitConfiguration("rabbitConfigurationResource", new()
{
    InstanceId = 0,
    MessageInterceptorsTimestampOverwrite = "string",
    MqttVhost = "string",
    ConsumerTimeout = 0,
    Heartbeat = 0,
    ClusterPartitionHandling = "string",
    LogExchangeLevel = "string",
    MaxMessageSize = 0,
    ChannelMax = 0,
    ConnectionMax = 0,
    MqttExchange = "string",
    MqttSslCertLogin = false,
    QueueIndexEmbedMsgsBelow = 0,
    Sleep = 0,
    SslCertLoginFrom = "string",
    SslOptionsFailIfNoPeerCert = false,
    SslOptionsVerify = "string",
    Timeout = 0,
    VmMemoryHighWatermark = 0,
});

example, err := cloudamqp.NewRabbitConfiguration(ctx, "rabbitConfigurationResource", &cloudamqp.RabbitConfigurationArgs{
	InstanceId:                            pulumi.Int(0),
	MessageInterceptorsTimestampOverwrite: pulumi.String("string"),
	MqttVhost:                             pulumi.String("string"),
	ConsumerTimeout:                       pulumi.Int(0),
	Heartbeat:                             pulumi.Int(0),
	ClusterPartitionHandling:              pulumi.String("string"),
	LogExchangeLevel:                      pulumi.String("string"),
	MaxMessageSize:                        pulumi.Int(0),
	ChannelMax:                            pulumi.Int(0),
	ConnectionMax:                         pulumi.Int(0),
	MqttExchange:                          pulumi.String("string"),
	MqttSslCertLogin:                      pulumi.Bool(false),
	QueueIndexEmbedMsgsBelow:              pulumi.Int(0),
	Sleep:                                 pulumi.Int(0),
	SslCertLoginFrom:                      pulumi.String("string"),
	SslOptionsFailIfNoPeerCert:            pulumi.Bool(false),
	SslOptionsVerify:                      pulumi.String("string"),
	Timeout:                               pulumi.Int(0),
	VmMemoryHighWatermark:                 pulumi.Float64(0),
})

var rabbitConfigurationResource = new RabbitConfiguration("rabbitConfigurationResource", RabbitConfigurationArgs.builder()
    .instanceId(0)
    .messageInterceptorsTimestampOverwrite("string")
    .mqttVhost("string")
    .consumerTimeout(0)
    .heartbeat(0)
    .clusterPartitionHandling("string")
    .logExchangeLevel("string")
    .maxMessageSize(0)
    .channelMax(0)
    .connectionMax(0)
    .mqttExchange("string")
    .mqttSslCertLogin(false)
    .queueIndexEmbedMsgsBelow(0)
    .sleep(0)
    .sslCertLoginFrom("string")
    .sslOptionsFailIfNoPeerCert(false)
    .sslOptionsVerify("string")
    .timeout(0)
    .vmMemoryHighWatermark(0.0)
    .build());

rabbit_configuration_resource = cloudamqp.RabbitConfiguration("rabbitConfigurationResource",
    instance_id=0,
    message_interceptors_timestamp_overwrite="string",
    mqtt_vhost="string",
    consumer_timeout=0,
    heartbeat=0,
    cluster_partition_handling="string",
    log_exchange_level="string",
    max_message_size=0,
    channel_max=0,
    connection_max=0,
    mqtt_exchange="string",
    mqtt_ssl_cert_login=False,
    queue_index_embed_msgs_below=0,
    sleep=0,
    ssl_cert_login_from="string",
    ssl_options_fail_if_no_peer_cert=False,
    ssl_options_verify="string",
    timeout=0,
    vm_memory_high_watermark=0)

const rabbitConfigurationResource = new cloudamqp.RabbitConfiguration("rabbitConfigurationResource", {
    instanceId: 0,
    messageInterceptorsTimestampOverwrite: "string",
    mqttVhost: "string",
    consumerTimeout: 0,
    heartbeat: 0,
    clusterPartitionHandling: "string",
    logExchangeLevel: "string",
    maxMessageSize: 0,
    channelMax: 0,
    connectionMax: 0,
    mqttExchange: "string",
    mqttSslCertLogin: false,
    queueIndexEmbedMsgsBelow: 0,
    sleep: 0,
    sslCertLoginFrom: "string",
    sslOptionsFailIfNoPeerCert: false,
    sslOptionsVerify: "string",
    timeout: 0,
    vmMemoryHighWatermark: 0,
});

type: cloudamqp:RabbitConfiguration
properties:
    channelMax: 0
    clusterPartitionHandling: string
    connectionMax: 0
    consumerTimeout: 0
    heartbeat: 0
    instanceId: 0
    logExchangeLevel: string
    maxMessageSize: 0
    messageInterceptorsTimestampOverwrite: string
    mqttExchange: string
    mqttSslCertLogin: false
    mqttVhost: string
    queueIndexEmbedMsgsBelow: 0
    sleep: 0
    sslCertLoginFrom: string
    sslOptionsFailIfNoPeerCert: false
    sslOptionsVerify: string
    timeout: 0
    vmMemoryHighWatermark: 0

RabbitConfiguration Resource Properties

To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

Inputs

In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

The RabbitConfiguration resource accepts the following input properties:

InstanceId int

The CloudAMQP instance ID.

ChannelMax int

Set the maximum permissible number of channels per connection.

ClusterPartitionHandling string

Set how the cluster should handle network partition.

ConnectionMax int

Set the maximum permissible number of connection.

ConsumerTimeout int

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

Heartbeat int

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

LogExchangeLevel string

Log level for the logger used for log integrations and the CloudAMQP Console log view.

MaxMessageSize int

The largest allowed message payload size in bytes.

MessageInterceptorsTimestampOverwrite string

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

MqttExchange string

The exchange option determines which exchange messages from MQTT clients are published to.

MqttSslCertLogin bool

Enable SSL certificate-based authentication for MQTT connections.

MqttVhost string

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

QueueIndexEmbedMsgsBelow int

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

Sleep int

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

SslCertLoginFrom string

Determines which certificate field to use as the username for TLS-based authentication.

SslOptionsFailIfNoPeerCert bool

When set to true, TLS connections will fail if the client does not provide a certificate.

SslOptionsVerify string

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

Timeout int

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

VmMemoryHighWatermark double

When the server will enter memory based flow-control as relative to the maximum available memory.

InstanceId int

The CloudAMQP instance ID.

ChannelMax int

Set the maximum permissible number of channels per connection.

ClusterPartitionHandling string

Set how the cluster should handle network partition.

ConnectionMax int

Set the maximum permissible number of connection.

ConsumerTimeout int

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

Heartbeat int

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

LogExchangeLevel string

Log level for the logger used for log integrations and the CloudAMQP Console log view.

MaxMessageSize int

The largest allowed message payload size in bytes.

MessageInterceptorsTimestampOverwrite string

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

MqttExchange string

The exchange option determines which exchange messages from MQTT clients are published to.

MqttSslCertLogin bool

Enable SSL certificate-based authentication for MQTT connections.

MqttVhost string

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

QueueIndexEmbedMsgsBelow int

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

Sleep int

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

SslCertLoginFrom string

Determines which certificate field to use as the username for TLS-based authentication.

SslOptionsFailIfNoPeerCert bool

When set to true, TLS connections will fail if the client does not provide a certificate.

SslOptionsVerify string

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

Timeout int

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

VmMemoryHighWatermark float64

When the server will enter memory based flow-control as relative to the maximum available memory.

instanceId Integer

The CloudAMQP instance ID.

channelMax Integer

Set the maximum permissible number of channels per connection.

clusterPartitionHandling String

Set how the cluster should handle network partition.

connectionMax Integer

Set the maximum permissible number of connection.

consumerTimeout Integer

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

heartbeat Integer

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

logExchangeLevel String

Log level for the logger used for log integrations and the CloudAMQP Console log view.

maxMessageSize Integer

The largest allowed message payload size in bytes.

messageInterceptorsTimestampOverwrite String

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

mqttExchange String

The exchange option determines which exchange messages from MQTT clients are published to.

mqttSslCertLogin Boolean

Enable SSL certificate-based authentication for MQTT connections.

mqttVhost String

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

queueIndexEmbedMsgsBelow Integer

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

sleep Integer

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

sslCertLoginFrom String

Determines which certificate field to use as the username for TLS-based authentication.

sslOptionsFailIfNoPeerCert Boolean

When set to true, TLS connections will fail if the client does not provide a certificate.

sslOptionsVerify String

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

timeout Integer

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

vmMemoryHighWatermark Double

When the server will enter memory based flow-control as relative to the maximum available memory.

instanceId number

The CloudAMQP instance ID.

channelMax number

Set the maximum permissible number of channels per connection.

clusterPartitionHandling string

Set how the cluster should handle network partition.

connectionMax number

Set the maximum permissible number of connection.

consumerTimeout number

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

heartbeat number

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

logExchangeLevel string

Log level for the logger used for log integrations and the CloudAMQP Console log view.

maxMessageSize number

The largest allowed message payload size in bytes.

messageInterceptorsTimestampOverwrite string

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

mqttExchange string

The exchange option determines which exchange messages from MQTT clients are published to.

mqttSslCertLogin boolean

Enable SSL certificate-based authentication for MQTT connections.

mqttVhost string

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

queueIndexEmbedMsgsBelow number

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

sleep number

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

sslCertLoginFrom string

Determines which certificate field to use as the username for TLS-based authentication.

sslOptionsFailIfNoPeerCert boolean

When set to true, TLS connections will fail if the client does not provide a certificate.

sslOptionsVerify string

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

timeout number

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

vmMemoryHighWatermark number

When the server will enter memory based flow-control as relative to the maximum available memory.

instance_id int

The CloudAMQP instance ID.

channel_max int

Set the maximum permissible number of channels per connection.

cluster_partition_handling str

Set how the cluster should handle network partition.

connection_max int

Set the maximum permissible number of connection.

consumer_timeout int

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

heartbeat int

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

log_exchange_level str

Log level for the logger used for log integrations and the CloudAMQP Console log view.

max_message_size int

The largest allowed message payload size in bytes.

message_interceptors_timestamp_overwrite str

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

mqtt_exchange str

The exchange option determines which exchange messages from MQTT clients are published to.

mqtt_ssl_cert_login bool

Enable SSL certificate-based authentication for MQTT connections.

mqtt_vhost str

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

queue_index_embed_msgs_below int

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

sleep int

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

ssl_cert_login_from str

Determines which certificate field to use as the username for TLS-based authentication.

ssl_options_fail_if_no_peer_cert bool

When set to true, TLS connections will fail if the client does not provide a certificate.

ssl_options_verify str

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

timeout int

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

vm_memory_high_watermark float

When the server will enter memory based flow-control as relative to the maximum available memory.

instanceId Number

The CloudAMQP instance ID.

channelMax Number

Set the maximum permissible number of channels per connection.

clusterPartitionHandling String

Set how the cluster should handle network partition.

connectionMax Number

Set the maximum permissible number of connection.

consumerTimeout Number

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

heartbeat Number

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

logExchangeLevel String

Log level for the logger used for log integrations and the CloudAMQP Console log view.

maxMessageSize Number

The largest allowed message payload size in bytes.

messageInterceptorsTimestampOverwrite String

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

mqttExchange String

The exchange option determines which exchange messages from MQTT clients are published to.

mqttSslCertLogin Boolean

Enable SSL certificate-based authentication for MQTT connections.

mqttVhost String

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

queueIndexEmbedMsgsBelow Number

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

sleep Number

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

sslCertLoginFrom String

Determines which certificate field to use as the username for TLS-based authentication.

sslOptionsFailIfNoPeerCert Boolean

When set to true, TLS connections will fail if the client does not provide a certificate.

sslOptionsVerify String

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

timeout Number

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

vmMemoryHighWatermark Number

When the server will enter memory based flow-control as relative to the maximum available memory.

Outputs

All input properties are implicitly available as output properties. Additionally, the RabbitConfiguration resource produces the following output properties:

Id string: The provider-assigned unique ID for this managed resource.

Id string: The provider-assigned unique ID for this managed resource.

id String: The provider-assigned unique ID for this managed resource.

id string: The provider-assigned unique ID for this managed resource.

id str: The provider-assigned unique ID for this managed resource.

id String: The provider-assigned unique ID for this managed resource.

Look up Existing RabbitConfiguration Resource

Get an existing RabbitConfiguration resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

public static get(name: string, id: Input<ID>, state?: RabbitConfigurationState, opts?: CustomResourceOptions): RabbitConfiguration

@staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        channel_max: Optional[int] = None,
        cluster_partition_handling: Optional[str] = None,
        connection_max: Optional[int] = None,
        consumer_timeout: Optional[int] = None,
        heartbeat: Optional[int] = None,
        instance_id: Optional[int] = None,
        log_exchange_level: Optional[str] = None,
        max_message_size: Optional[int] = None,
        message_interceptors_timestamp_overwrite: Optional[str] = None,
        mqtt_exchange: Optional[str] = None,
        mqtt_ssl_cert_login: Optional[bool] = None,
        mqtt_vhost: Optional[str] = None,
        queue_index_embed_msgs_below: Optional[int] = None,
        sleep: Optional[int] = None,
        ssl_cert_login_from: Optional[str] = None,
        ssl_options_fail_if_no_peer_cert: Optional[bool] = None,
        ssl_options_verify: Optional[str] = None,
        timeout: Optional[int] = None,
        vm_memory_high_watermark: Optional[float] = None) -> RabbitConfiguration

func GetRabbitConfiguration(ctx *Context, name string, id IDInput, state *RabbitConfigurationState, opts ...ResourceOption) (*RabbitConfiguration, error)

public static RabbitConfiguration Get(string name, Input<string> id, RabbitConfigurationState? state, CustomResourceOptions? opts = null)

public static RabbitConfiguration get(String name, Output<String> id, RabbitConfigurationState state, CustomResourceOptions options)

resources:  _:    type: cloudamqp:RabbitConfiguration    get:      id: ${id}

name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.
state: Any extra arguments used during the lookup.
opts: A bag of options that control this resource's behavior.

resource_name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.

name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.
state: Any extra arguments used during the lookup.
opts: A bag of options that control this resource's behavior.

name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.
state: Any extra arguments used during the lookup.
opts: A bag of options that control this resource's behavior.

name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.
state: Any extra arguments used during the lookup.
opts: A bag of options that control this resource's behavior.

The following state arguments are supported:

ChannelMax int

Set the maximum permissible number of channels per connection.

ClusterPartitionHandling string

Set how the cluster should handle network partition.

ConnectionMax int

Set the maximum permissible number of connection.

ConsumerTimeout int

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

Heartbeat int

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

InstanceId int

The CloudAMQP instance ID.

LogExchangeLevel string

Log level for the logger used for log integrations and the CloudAMQP Console log view.

MaxMessageSize int

The largest allowed message payload size in bytes.

MessageInterceptorsTimestampOverwrite string

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

MqttExchange string

The exchange option determines which exchange messages from MQTT clients are published to.

MqttSslCertLogin bool

Enable SSL certificate-based authentication for MQTT connections.

MqttVhost string

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

QueueIndexEmbedMsgsBelow int

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

Sleep int

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

SslCertLoginFrom string

Determines which certificate field to use as the username for TLS-based authentication.

SslOptionsFailIfNoPeerCert bool

When set to true, TLS connections will fail if the client does not provide a certificate.

SslOptionsVerify string

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

Timeout int

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

VmMemoryHighWatermark double

When the server will enter memory based flow-control as relative to the maximum available memory.

ChannelMax int

Set the maximum permissible number of channels per connection.

ClusterPartitionHandling string

Set how the cluster should handle network partition.

ConnectionMax int

Set the maximum permissible number of connection.

ConsumerTimeout int

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

Heartbeat int

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

InstanceId int

The CloudAMQP instance ID.

LogExchangeLevel string

Log level for the logger used for log integrations and the CloudAMQP Console log view.

MaxMessageSize int

The largest allowed message payload size in bytes.

MessageInterceptorsTimestampOverwrite string

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

MqttExchange string

The exchange option determines which exchange messages from MQTT clients are published to.

MqttSslCertLogin bool

Enable SSL certificate-based authentication for MQTT connections.

MqttVhost string

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

QueueIndexEmbedMsgsBelow int

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

Sleep int

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

SslCertLoginFrom string

Determines which certificate field to use as the username for TLS-based authentication.

SslOptionsFailIfNoPeerCert bool

When set to true, TLS connections will fail if the client does not provide a certificate.

SslOptionsVerify string

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

Timeout int

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

VmMemoryHighWatermark float64

When the server will enter memory based flow-control as relative to the maximum available memory.

channelMax Integer

Set the maximum permissible number of channels per connection.

clusterPartitionHandling String

Set how the cluster should handle network partition.

connectionMax Integer

Set the maximum permissible number of connection.

consumerTimeout Integer

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

heartbeat Integer

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

instanceId Integer

The CloudAMQP instance ID.

logExchangeLevel String

Log level for the logger used for log integrations and the CloudAMQP Console log view.

maxMessageSize Integer

The largest allowed message payload size in bytes.

messageInterceptorsTimestampOverwrite String

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

mqttExchange String

The exchange option determines which exchange messages from MQTT clients are published to.

mqttSslCertLogin Boolean

Enable SSL certificate-based authentication for MQTT connections.

mqttVhost String

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

queueIndexEmbedMsgsBelow Integer

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

sleep Integer

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

sslCertLoginFrom String

Determines which certificate field to use as the username for TLS-based authentication.

sslOptionsFailIfNoPeerCert Boolean

When set to true, TLS connections will fail if the client does not provide a certificate.

sslOptionsVerify String

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

timeout Integer

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

vmMemoryHighWatermark Double

When the server will enter memory based flow-control as relative to the maximum available memory.

channelMax number

Set the maximum permissible number of channels per connection.

clusterPartitionHandling string

Set how the cluster should handle network partition.

connectionMax number

Set the maximum permissible number of connection.

consumerTimeout number

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

heartbeat number

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

instanceId number

The CloudAMQP instance ID.

logExchangeLevel string

Log level for the logger used for log integrations and the CloudAMQP Console log view.

maxMessageSize number

The largest allowed message payload size in bytes.

messageInterceptorsTimestampOverwrite string

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

mqttExchange string

The exchange option determines which exchange messages from MQTT clients are published to.

mqttSslCertLogin boolean

Enable SSL certificate-based authentication for MQTT connections.

mqttVhost string

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

queueIndexEmbedMsgsBelow number

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

sleep number

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

sslCertLoginFrom string

Determines which certificate field to use as the username for TLS-based authentication.

sslOptionsFailIfNoPeerCert boolean

When set to true, TLS connections will fail if the client does not provide a certificate.

sslOptionsVerify string

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

timeout number

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

vmMemoryHighWatermark number

When the server will enter memory based flow-control as relative to the maximum available memory.

channel_max int

Set the maximum permissible number of channels per connection.

cluster_partition_handling str

Set how the cluster should handle network partition.

connection_max int

Set the maximum permissible number of connection.

consumer_timeout int

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

heartbeat int

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

instance_id int

The CloudAMQP instance ID.

log_exchange_level str

Log level for the logger used for log integrations and the CloudAMQP Console log view.

max_message_size int

The largest allowed message payload size in bytes.

message_interceptors_timestamp_overwrite str

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

mqtt_exchange str

The exchange option determines which exchange messages from MQTT clients are published to.

mqtt_ssl_cert_login bool

Enable SSL certificate-based authentication for MQTT connections.

mqtt_vhost str

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

queue_index_embed_msgs_below int

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

sleep int

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

ssl_cert_login_from str

Determines which certificate field to use as the username for TLS-based authentication.

ssl_options_fail_if_no_peer_cert bool

When set to true, TLS connections will fail if the client does not provide a certificate.

ssl_options_verify str

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

timeout int

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

vm_memory_high_watermark float

When the server will enter memory based flow-control as relative to the maximum available memory.

channelMax Number

Set the maximum permissible number of channels per connection.

clusterPartitionHandling String

Set how the cluster should handle network partition.

connectionMax Number

Set the maximum permissible number of connection.

consumerTimeout Number

A consumer that has received a message and does not acknowledge that message within the timeout in milliseconds

heartbeat Number

Set the server AMQP 0-9-1 heartbeat timeout in seconds.

instanceId Number

The CloudAMQP instance ID.

logExchangeLevel String

Log level for the logger used for log integrations and the CloudAMQP Console log view.

maxMessageSize Number

The largest allowed message payload size in bytes.

messageInterceptorsTimestampOverwrite String

Sets a timestamp header on incoming messages. enabled_with_overwrite will overwrite any existing timestamps in the header.

mqttExchange String

The exchange option determines which exchange messages from MQTT clients are published to.

mqttSslCertLogin Boolean

Enable SSL certificate-based authentication for MQTT connections.

mqttVhost String

Virtual host for MQTT connections. Default set to newly created vhost, same as cloudamqp_instance.instance.vhost.

queueIndexEmbedMsgsBelow Number

Size in bytes below which to embed messages in the queue index. 0 will turn off payload embedding in the queue index.

sleep Number

Configurable sleep time in seconds between retries for RabbitMQ configuration. Default set to 60 seconds.

sslCertLoginFrom String

Determines which certificate field to use as the username for TLS-based authentication.

sslOptionsFailIfNoPeerCert Boolean

When set to true, TLS connections will fail if the client does not provide a certificate.

sslOptionsVerify String

Controls peer certificate verification for TLS connections.

Configure sleep and timeout for API requests retries

timeout Number

Configurable timeout time in seconds for RabbitMQ configuration. Default set to 3600 seconds.

vmMemoryHighWatermark Number

When the server will enter memory based flow-control as relative to the maximum available memory.

Package Details

Repository: CloudAMQP pulumi/pulumi-cloudamqp
License: Apache-2.0
Notes: This Pulumi package is based on the cloudamqp Terraform Provider.

Viewing docs for CloudAMQP v3.27.1
published on Friday, Mar 20, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-cloudamqp

cloudamqp.RabbitConfiguration

On this page

On this page

Example Usage

Argument threshold values

heartbeat

Dependency

Known issues

Create RabbitConfiguration Resource

Constructor syntax

Parameters

Constructor example

RabbitConfiguration Resource Properties

Inputs

Outputs

Look up Existing RabbitConfiguration Resource

Package Details

On this page

On this page