Exchange
Provides a RabbitMQ (AMQP) Exchange resource. For information about RabbitMQ (AMQP) Exchange and how to use it, see What is Exchange.
NOTE: Available since v1.128.0.
Example Usage
Basic Usage
import * as pulumi from "@pulumi/pulumi";
import * as alicloud from "@pulumi/alicloud";
const _default = new alicloud.amqp.Instance("default", {
instanceType: "professional",
maxTps: "1000",
queueCapacity: "50",
supportEip: true,
maxEipTps: "128",
paymentType: "Subscription",
period: 1,
});
const defaultVirtualHost = new alicloud.amqp.VirtualHost("default", {
instanceId: _default.id,
virtualHostName: "tf-example",
});
const defaultExchange = new alicloud.amqp.Exchange("default", {
autoDeleteState: false,
exchangeName: "tf-example",
exchangeType: "DIRECT",
instanceId: _default.id,
internal: false,
virtualHostName: defaultVirtualHost.virtualHostName,
});
import pulumi
import pulumi_alicloud as alicloud
default = alicloud.amqp.Instance("default",
instance_type="professional",
max_tps="1000",
queue_capacity="50",
support_eip=True,
max_eip_tps="128",
payment_type="Subscription",
period=1)
default_virtual_host = alicloud.amqp.VirtualHost("default",
instance_id=default.id,
virtual_host_name="tf-example")
default_exchange = alicloud.amqp.Exchange("default",
auto_delete_state=False,
exchange_name="tf-example",
exchange_type="DIRECT",
instance_id=default.id,
internal=False,
virtual_host_name=default_virtual_host.virtual_host_name)
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AliCloud = Pulumi.AliCloud;
return await Deployment.RunAsync(() =>
{
var @default = new AliCloud.Amqp.Instance("default", new()
{
InstanceType = "professional",
MaxTps = "1000",
QueueCapacity = "50",
SupportEip = true,
MaxEipTps = "128",
PaymentType = "Subscription",
Period = 1,
});
var defaultVirtualHost = new AliCloud.Amqp.VirtualHost("default", new()
{
InstanceId = @default.Id,
VirtualHostName = "tf-example",
});
var defaultExchange = new AliCloud.Amqp.Exchange("default", new()
{
AutoDeleteState = false,
ExchangeName = "tf-example",
ExchangeType = "DIRECT",
InstanceId = @default.Id,
Internal = false,
VirtualHostName = defaultVirtualHost.VirtualHostName,
});
});
package main
import (
"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/amqp"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_default, err := amqp.NewInstance(ctx, "default", &amqp.InstanceArgs{
InstanceType: pulumi.String("professional"),
MaxTps: pulumi.String("1000"),
QueueCapacity: pulumi.String("50"),
SupportEip: pulumi.Bool(true),
MaxEipTps: pulumi.String("128"),
PaymentType: pulumi.String("Subscription"),
Period: pulumi.Int(1),
})
if err != nil {
return err
}
defaultVirtualHost, err := amqp.NewVirtualHost(ctx, "default", &amqp.VirtualHostArgs{
InstanceId: _default.ID(),
VirtualHostName: pulumi.String("tf-example"),
})
if err != nil {
return err
}
_, err = amqp.NewExchange(ctx, "default", &amqp.ExchangeArgs{
AutoDeleteState: pulumi.Bool(false),
ExchangeName: pulumi.String("tf-example"),
ExchangeType: pulumi.String("DIRECT"),
InstanceId: _default.ID(),
Internal: pulumi.Bool(false),
VirtualHostName: defaultVirtualHost.VirtualHostName,
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.alicloud.amqp.Instance;
import com.pulumi.alicloud.amqp.InstanceArgs;
import com.pulumi.alicloud.amqp.VirtualHost;
import com.pulumi.alicloud.amqp.VirtualHostArgs;
import com.pulumi.alicloud.amqp.Exchange;
import com.pulumi.alicloud.amqp.ExchangeArgs;
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 default_ = new Instance("default", InstanceArgs.builder()
.instanceType("professional")
.maxTps(1000)
.queueCapacity(50)
.supportEip(true)
.maxEipTps(128)
.paymentType("Subscription")
.period(1)
.build());
var defaultVirtualHost = new VirtualHost("defaultVirtualHost", VirtualHostArgs.builder()
.instanceId(default_.id())
.virtualHostName("tf-example")
.build());
var defaultExchange = new Exchange("defaultExchange", ExchangeArgs.builder()
.autoDeleteState(false)
.exchangeName("tf-example")
.exchangeType("DIRECT")
.instanceId(default_.id())
.internal(false)
.virtualHostName(defaultVirtualHost.virtualHostName())
.build());
}
}
resources:
default:
type: alicloud:amqp:Instance
properties:
instanceType: professional
maxTps: 1000
queueCapacity: 50
supportEip: true
maxEipTps: 128
paymentType: Subscription
period: 1
defaultVirtualHost:
type: alicloud:amqp:VirtualHost
name: default
properties:
instanceId: ${default.id}
virtualHostName: tf-example
defaultExchange:
type: alicloud:amqp:Exchange
name: default
properties:
autoDeleteState: false
exchangeName: tf-example
exchangeType: DIRECT
instanceId: ${default.id}
internal: false
virtualHostName: ${defaultVirtualHost.virtualHostName}
Import
RabbitMQ (AMQP) Exchange can be imported using the id, e.g.
$ pulumi import alicloud:amqp/exchange:Exchange example <instance_id>:<virtual_host_name>:<exchange_name>
Properties
The alternate exchange. An alternate exchange is configured for an existing exchange. It is used to receive messages that fail to be routed to queues from the existing exchange.
Specifies whether the Auto Delete attribute is configured. Valid values:
The name of the exchange. It must be 1 to 255 characters in length, and can contain only letters, digits, hyphens (-), underscores (_), periods (.), and at signs (@).
The type of the exchange. Valid values:
The ID of the instance.
The name of virtual host where an exchange resides.