Update - adding conformance tests

Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>

Author: Lior Nabat

.github/infrastructure/docker-compose-kubemq.yml

@@ -0,0 +1,8 @@
+version: '2'
+services:
+  rabbitmq:
+    image: kubemq/kubemq-community:latest
+    ports:
+      - 8080:8080
+      - 9090:9090
+      - 50000:50000

.github/workflows/conformance.yml

@@ -70,6 +70,7 @@ jobs:
         - pubsub.redis
         - pubsub.kafka-wurstmeister
         - pubsub.kafka-confluent
+        - pubsub.kubemq
         - secretstores.kubernetes
         - secretstores.localenv
         - secretstores.localfile
@@ -292,7 +293,7 @@ jobs:
     - name: Start Eclipse Mosquitto (MQTT)
       run: docker-compose -f ./.github/infrastructure/docker-compose-mosquitto.yml -p mosquitto up -d
       if: contains(matrix.component, 'mqtt-mosquitto')
-    
+
     - name: Start EMQ X (MQTT)
       run: docker-compose -f ./.github/infrastructure/docker-compose-emqx.yml -p emqx up -d
       if: contains(matrix.component, 'mqtt-emqx')
@@ -348,7 +349,7 @@ jobs:
       run: |
         docker-compose -f ./.github/infrastructure/docker-compose-cockroachdb.yml -p cockroachdb up -d
       if: contains(matrix.component, 'cockroachdb')
-    
+
     - name: Start vault
       run: |
         docker-compose -f ./.github/infrastructure/docker-compose-hashicorp-vault.yml -p vault up -d
@@ -359,6 +360,10 @@ jobs:
         docker-compose -f ./.github/infrastructure/docker-compose-rethinkdb.yml -p rethinkdb up -d
       if: contains(matrix.component, 'rethinkdb')
 
+    - name: Start kubemq
+      run: docker-compose -f ./.github/infrastructure/docker-compose-kubemq.yml -p kubemq up -d
+      if: contains(matrix.component, 'kubemq')
+
     - name: Setup KinD test data
       if: contains(matrix.component, 'kubernetes')
       run: |
@@ -369,7 +374,7 @@ jobs:
       uses: actions/setup-go@v3
       with:
         go-version: '^1.19'
-    
+
     - name: Download Go dependencies
       run: |
         go mod download

tests/config/pubsub/tests.yml

@@ -81,4 +81,4 @@ components:
     config:
       checkInOrderProcessing: false
   - component: kubemq
-    allOperations: true
+    operations: ["publish", "subscribe", "multiplehandlers"]