rabbitmq.FederationUpstream

using System.Collections.Generic;
using Pulumi;
using RabbitMQ = Pulumi.RabbitMQ;

return await Deployment.RunAsync(() => 
{
    var test = new RabbitMQ.VHost("test");

    var guest = new RabbitMQ.Permissions("guest", new()
    {
        User = "guest",
        Vhost = test.Name,
        PermissionDetails = new RabbitMQ.Inputs.PermissionsPermissionsArgs
        {
            Configure = ".*",
            Write = ".*",
            Read = ".*",
        },
    });

    // downstream exchange
    var fooExchange = new RabbitMQ.Exchange("fooExchange", new()
    {
        Vhost = guest.Vhost,
        Settings = new RabbitMQ.Inputs.ExchangeSettingsArgs
        {
            Type = "topic",
            Durable = true,
        },
    });

    // upstream broker
    var fooFederationUpstream = new RabbitMQ.FederationUpstream("fooFederationUpstream", new()
    {
        Vhost = guest.Vhost,
        Definition = new RabbitMQ.Inputs.FederationUpstreamDefinitionArgs
        {
            Uri = "amqp://guest:guest@upstream-server-name:5672/%2f",
            PrefetchCount = 1000,
            ReconnectDelay = 5,
            AckMode = "on-confirm",
            TrustUserId = false,
            MaxHops = 1,
        },
    });

    var fooPolicy = new RabbitMQ.Policy("fooPolicy", new()
    {
        Vhost = guest.Vhost,
        PolicyBlock = new RabbitMQ.Inputs.PolicyPolicyArgs
        {
            Pattern = fooExchange.Name.Apply(name => $"(^{name}$)"),
            Priority = 1,
            ApplyTo = "exchanges",
            Definition = 
            {
                { "federation-upstream", fooFederationUpstream.Name },
            },
        },
    });

});

package main

import (
	"fmt"

	"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		test, err := rabbitmq.NewVHost(ctx, "test", nil)
		if err != nil {
			return err
		}
		guest, err := rabbitmq.NewPermissions(ctx, "guest", &rabbitmq.PermissionsArgs{
			User:  pulumi.String("guest"),
			Vhost: test.Name,
			Permissions: &rabbitmq.PermissionsPermissionsArgs{
				Configure: pulumi.String(".*"),
				Write:     pulumi.String(".*"),
				Read:      pulumi.String(".*"),
			},
		})
		if err != nil {
			return err
		}
		fooExchange, err := rabbitmq.NewExchange(ctx, "fooExchange", &rabbitmq.ExchangeArgs{
			Vhost: guest.Vhost,
			Settings: &rabbitmq.ExchangeSettingsArgs{
				Type:    pulumi.String("topic"),
				Durable: pulumi.Bool(true),
			},
		})
		if err != nil {
			return err
		}
		fooFederationUpstream, err := rabbitmq.NewFederationUpstream(ctx, "fooFederationUpstream", &rabbitmq.FederationUpstreamArgs{
			Vhost: guest.Vhost,
			Definition: &rabbitmq.FederationUpstreamDefinitionArgs{
				Uri:            pulumi.String("amqp://guest:guest@upstream-server-name:5672/%2f"),
				PrefetchCount:  pulumi.Int(1000),
				ReconnectDelay: pulumi.Int(5),
				AckMode:        pulumi.String("on-confirm"),
				TrustUserId:    pulumi.Bool(false),
				MaxHops:        pulumi.Int(1),
			},
		})
		if err != nil {
			return err
		}
		_, err = rabbitmq.NewPolicy(ctx, "fooPolicy", &rabbitmq.PolicyArgs{
			Vhost: guest.Vhost,
			Policy: &rabbitmq.PolicyPolicyArgs{
				Pattern: fooExchange.Name.ApplyT(func(name string) (string, error) {
					return fmt.Sprintf("(^%v$)", name), nil
				}).(pulumi.StringOutput),
				Priority: pulumi.Int(1),
				ApplyTo:  pulumi.String("exchanges"),
				Definition: pulumi.AnyMap{
					"federation-upstream": fooFederationUpstream.Name,
				},
			},
		})
		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.rabbitmq.VHost;
import com.pulumi.rabbitmq.Permissions;
import com.pulumi.rabbitmq.PermissionsArgs;
import com.pulumi.rabbitmq.inputs.PermissionsPermissionsArgs;
import com.pulumi.rabbitmq.Exchange;
import com.pulumi.rabbitmq.ExchangeArgs;
import com.pulumi.rabbitmq.inputs.ExchangeSettingsArgs;
import com.pulumi.rabbitmq.FederationUpstream;
import com.pulumi.rabbitmq.FederationUpstreamArgs;
import com.pulumi.rabbitmq.inputs.FederationUpstreamDefinitionArgs;
import com.pulumi.rabbitmq.Policy;
import com.pulumi.rabbitmq.PolicyArgs;
import com.pulumi.rabbitmq.inputs.PolicyPolicyArgs;
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 test = new VHost("test");

        var guest = new Permissions("guest", PermissionsArgs.builder()        
            .user("guest")
            .vhost(test.name())
            .permissions(PermissionsPermissionsArgs.builder()
                .configure(".*")
                .write(".*")
                .read(".*")
                .build())
            .build());

        var fooExchange = new Exchange("fooExchange", ExchangeArgs.builder()        
            .vhost(guest.vhost())
            .settings(ExchangeSettingsArgs.builder()
                .type("topic")
                .durable("true")
                .build())
            .build());

        var fooFederationUpstream = new FederationUpstream("fooFederationUpstream", FederationUpstreamArgs.builder()        
            .vhost(guest.vhost())
            .definition(FederationUpstreamDefinitionArgs.builder()
                .uri("amqp://guest:guest@upstream-server-name:5672/%2f")
                .prefetchCount(1000)
                .reconnectDelay(5)
                .ackMode("on-confirm")
                .trustUserId(false)
                .maxHops(1)
                .build())
            .build());

        var fooPolicy = new Policy("fooPolicy", PolicyArgs.builder()        
            .vhost(guest.vhost())
            .policy(PolicyPolicyArgs.builder()
                .pattern(fooExchange.name().applyValue(name -> String.format("(^%s$)", name)))
                .priority(1)
                .applyTo("exchanges")
                .definition(Map.of("federation-upstream", fooFederationUpstream.name()))
                .build())
            .build());

    }
}

import pulumi
import pulumi_rabbitmq as rabbitmq

test = rabbitmq.VHost("test")
guest = rabbitmq.Permissions("guest",
    user="guest",
    vhost=test.name,
    permissions=rabbitmq.PermissionsPermissionsArgs(
        configure=".*",
        write=".*",
        read=".*",
    ))
# downstream exchange
foo_exchange = rabbitmq.Exchange("fooExchange",
    vhost=guest.vhost,
    settings=rabbitmq.ExchangeSettingsArgs(
        type="topic",
        durable=True,
    ))
# upstream broker
foo_federation_upstream = rabbitmq.FederationUpstream("fooFederationUpstream",
    vhost=guest.vhost,
    definition=rabbitmq.FederationUpstreamDefinitionArgs(
        uri="amqp://guest:guest@upstream-server-name:5672/%2f",
        prefetch_count=1000,
        reconnect_delay=5,
        ack_mode="on-confirm",
        trust_user_id=False,
        max_hops=1,
    ))
foo_policy = rabbitmq.Policy("fooPolicy",
    vhost=guest.vhost,
    policy=rabbitmq.PolicyPolicyArgs(
        pattern=foo_exchange.name.apply(lambda name: f"(^{name}$)"),
        priority=1,
        apply_to="exchanges",
        definition={
            "federation-upstream": foo_federation_upstream.name,
        },
    ))

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

const test = new rabbitmq.VHost("test", {});
const guest = new rabbitmq.Permissions("guest", {
    user: "guest",
    vhost: test.name,
    permissions: {
        configure: ".*",
        write: ".*",
        read: ".*",
    },
});
// downstream exchange
const fooExchange = new rabbitmq.Exchange("fooExchange", {
    vhost: guest.vhost,
    settings: {
        type: "topic",
        durable: true,
    },
});
// upstream broker
const fooFederationUpstream = new rabbitmq.FederationUpstream("fooFederationUpstream", {
    vhost: guest.vhost,
    definition: {
        uri: "amqp://guest:guest@upstream-server-name:5672/%2f",
        prefetchCount: 1000,
        reconnectDelay: 5,
        ackMode: "on-confirm",
        trustUserId: false,
        maxHops: 1,
    },
});
const fooPolicy = new rabbitmq.Policy("fooPolicy", {
    vhost: guest.vhost,
    policy: {
        pattern: pulumi.interpolate`(^${fooExchange.name}$)`,
        priority: 1,
        applyTo: "exchanges",
        definition: {
            "federation-upstream": fooFederationUpstream.name,
        },
    },
});

resources:
  test:
    type: rabbitmq:VHost
  guest:
    type: rabbitmq:Permissions
    properties:
      user: guest
      vhost: ${test.name}
      permissions:
        configure: .*
        write: .*
        read: .*
  # downstream exchange
  fooExchange:
    type: rabbitmq:Exchange
    properties:
      vhost: ${guest.vhost}
      settings:
        type: topic
        durable: 'true'
  # upstream broker
  fooFederationUpstream:
    type: rabbitmq:FederationUpstream
    properties:
      vhost: ${guest.vhost}
      definition:
        uri: amqp://guest:guest@upstream-server-name:5672/%2f
        prefetchCount: 1000
        reconnectDelay: 5
        ackMode: on-confirm
        trustUserId: false
        maxHops: 1
  fooPolicy:
    type: rabbitmq:Policy
    properties:
      vhost: ${guest.vhost}
      policy:
        pattern: (^${fooExchange.name}$)
        priority: 1
        applyTo: exchanges
        definition:
          federation-upstream: ${fooFederationUpstream.name}