Back to Repositories

Validating AMQP Event Queue Provider Configuration in Conductor OSS

This test suite validates the AMQP Event Queue Provider functionality in Conductor OSS, focusing on queue and exchange configurations. The tests ensure proper initialization and behavior of AMQP message queues with various configuration parameters.

Test Coverage Overview

The test suite provides comprehensive coverage of AMQP queue provider initialization and configuration scenarios.

Tests default configuration for both exchange and queue-based implementations
Validates queue name and type assertions
Covers AMQP-specific parameters like delivery mode, durability, and auto-delete settings

Implementation Analysis

The testing approach utilizes JUnit with Mockito for dependency mocking. The implementation demonstrates proper test isolation by mocking AMQPEventQueueProperties and verifying queue configuration outcomes.

Uses @Before setup for common test configurations
Implements mock configurations for AMQP connection parameters
Validates both exchange and queue-based messaging scenarios

Technical Details

Testing tools and configuration:

JUnit 4 testing framework
Mockito for mocking dependencies
RabbitMQ client library integration
Configuration parameters including connection timeout, delivery modes, and exchange types

Best Practices Demonstrated

The test suite exemplifies several testing best practices in Java unit testing.

Proper test setup and initialization using @Before
Clear test method naming conventions
Thorough mock configuration for external dependencies
Explicit assertions for expected outcomes
Separation of exchange and queue testing scenarios

conductor-oss/conductor

amqp/src/test/java/com/netflix/conductor/contribs/queue/amqp/AMQPEventQueueProviderTest.java

            
/*
 * Copyright 2023 Conductor Authors.
 * <p>
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
 * the License. You may obtain a copy of the License at
 * <p>
 * http://www.apache.org/licenses/LICENSE-2.0
 * <p>
 * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
 * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
 * specific language governing permissions and limitations under the License.
 */
package com.netflix.conductor.contribs.queue.amqp;

import java.time.Duration;

import org.junit.Before;
import org.junit.Test;

import com.netflix.conductor.contribs.queue.amqp.config.AMQPEventQueueProperties;
import com.netflix.conductor.contribs.queue.amqp.config.AMQPEventQueueProvider;
import com.netflix.conductor.contribs.queue.amqp.util.AMQPConstants;
import com.netflix.conductor.core.events.queue.ObservableQueue;

import com.rabbitmq.client.AMQP.PROTOCOL;
import com.rabbitmq.client.ConnectionFactory;

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;

public class AMQPEventQueueProviderTest {

    private AMQPEventQueueProperties properties;

    @Before
    public void setUp() {
        properties = mock(AMQPEventQueueProperties.class);
        when(properties.getBatchSize()).thenReturn(1);
        when(properties.getPollTimeDuration()).thenReturn(Duration.ofMillis(100));
        when(properties.getHosts()).thenReturn(ConnectionFactory.DEFAULT_HOST);
        when(properties.getUsername()).thenReturn(ConnectionFactory.DEFAULT_USER);
        when(properties.getPassword()).thenReturn(ConnectionFactory.DEFAULT_PASS);
        when(properties.getVirtualHost()).thenReturn(ConnectionFactory.DEFAULT_VHOST);
        when(properties.getPort()).thenReturn(PROTOCOL.PORT);
        when(properties.getConnectionTimeoutInMilliSecs()).thenReturn(60000);
        when(properties.isUseNio()).thenReturn(false);
        when(properties.isDurable()).thenReturn(true);
        when(properties.isExclusive()).thenReturn(false);
        when(properties.isAutoDelete()).thenReturn(false);
        when(properties.getContentType()).thenReturn("application/json");
        when(properties.getContentEncoding()).thenReturn("UTF-8");
        when(properties.getExchangeType()).thenReturn("topic");
        when(properties.getDeliveryMode()).thenReturn(2);
        when(properties.isUseExchange()).thenReturn(true);
    }

    @Test
    public void testAMQPEventQueueProvider_defaultconfig_exchange() {
        String exchangestring =
                "amqp_exchange:myExchangeName?exchangeType=topic&routingKey=test&deliveryMode=2";
        AMQPEventQueueProvider eventqProvider =
                new AMQPEventQueueProvider(properties, "amqp_exchange", true);
        ObservableQueue queue = eventqProvider.getQueue(exchangestring);
        assertNotNull(queue);
        assertEquals(exchangestring, queue.getName());
        assertEquals(AMQPConstants.AMQP_EXCHANGE_TYPE, queue.getType());
    }

    @Test
    public void testAMQPEventQueueProvider_defaultconfig_queue() {
        String exchangestring =
                "amqp_queue:myQueueName?deliveryMode=2&durable=false&autoDelete=true&exclusive=true";
        AMQPEventQueueProvider eventqProvider =
                new AMQPEventQueueProvider(properties, "amqp_queue", false);
        ObservableQueue queue = eventqProvider.getQueue(exchangestring);
        assertNotNull(queue);
        assertEquals(exchangestring, queue.getName());
        assertEquals(AMQPConstants.AMQP_QUEUE_TYPE, queue.getType());
    }
}