Creating a RabbitMQ Broker

This topic describes how to create a RabbitMQ Broker.

Prerequisites

To use the RabbitMQ Broker, you must have the following installed:

  1. Knative Eventing
  2. RabbitMQ Cluster Operator - our recommendation is latest release
  3. CertManager v1.5.4 - easiest integration with RabbitMQ Messaging Topology Operator
  4. RabbitMQ Messaging Topology Operator - our recommendation is latest release with CertManager

Install the RabbitMQ controller

  1. Install the RabbitMQ controller by running the command:

    1. kubectl apply -f https://github.com/knative-sandbox/eventing-rabbitmq/releases/download/knative-v1.5.1/rabbitmq-broker.yaml

  2. Verify that rabbitmq-broker-controller and rabbitmq-broker-webhook are running:

    1. kubectl get deployments.apps -n knative-eventing

    Example output:

    1. NAME                           READY   UP-TO-DATE   AVAILABLE   AGE
    2. eventing-controller            1/1     1            1           10s
    3. eventing-webhook               1/1     1            1           9s
    4. rabbitmq-broker-controller     1/1     1            1           3s
    5. rabbitmq-broker-webhook        1/1     1            1           4s

Create a RabbitMQ cluster

  1. Deploy a RabbitMQ cluster:

    1. Create a YAML file using the following template:

      1. apiVersion: rabbitmq.com/v1beta1
      2. kind: RabbitmqCluster
      3. metadata:
      4.   name: <cluster-name>
      5.   annotations:
      6.     # A single RabbitMQ cluster per Knative Eventing installation
      7.     rabbitmq.com/topology-allowed-namespaces: "*"

      Where <cluster-name> is the name you want for your RabbitMQ cluster, for example, rabbitmq.

    2. Apply the YAML file by running the command:

      1. kubectl create -f <filename>

      Where <filename> is the name of the file you created in the previous step.

  2. Wait for the cluster to become ready. When the cluster is ready, ALLREPLICASREADY will be true in the output of the following command:

    1. kubectl get rmq <cluster-name>

    Where <cluster-name> is the name you gave your cluster in the step above.

    Example output:

    1. NAME          ALLREPLICASREADY   RECONCILESUCCESS   AGE
    2. rabbitmq      True               True               38s

For more information about configuring the RabbitmqCluster CRD, see the RabbitMQ website.

Create a RabbitMQ Broker object

  1. Create a YAML file using the following template:

    1. apiVersion: eventing.knative.dev/v1
    2. kind: Broker
    3. metadata:
    4.   annotations:
    5.     eventing.knative.dev/broker.class: RabbitMQBroker
    6.   name: <cluster-name>
    7. spec:
    8.   config:
    9.     apiVersion: rabbitmq.com/v1beta1
    10.     kind: RabbitmqCluster
    11.     name: <cluster-name>

    Where <cluster-name> is the name you gave your RabbitMQ cluster in the step above.

  2. Apply the YAML file by running the command:

    1. kubectl apply -f <filename>

    Where <filename> is the name of the file you created in the previous step.

Additional information

To report a bug or request a feature, open an issue in the eventing-rabbitmq repository.