Back to Repositories

Testing Observable Reactive Execution Patterns in Netflix Hystrix

This test suite validates reactive execution functionality in Netflix’s Hystrix library using Spring and Observable patterns. It extends BasicObservableTest to verify asynchronous operations and reactive streams integration with Hystrix commands.

Test Coverage Overview

The test suite focuses on verifying Hystrix’s reactive execution capabilities through Observable patterns.

Key areas covered include:

Spring AOP integration with CGLIB
Reactive command execution flows
UserService observable operations
Spring context configuration validation

Implementation Analysis

The implementation leverages Spring’s testing framework with JUnit4 for reactive execution testing.

Notable patterns include:

Spring context configuration using @ContextConfiguration
Dependency injection with @Autowired
Bean configuration through @Configurable
Extension of BasicObservableTest for core functionality

Technical Details

Testing infrastructure includes:

SpringJUnit4ClassRunner for test execution
AopCglibConfig for aspect-oriented programming setup
Spring context configuration management
Observable pattern implementation with UserService

Best Practices Demonstrated

The test suite exemplifies several testing best practices in reactive programming context.

Notable practices include:

Clear separation of configuration and test logic
Proper dependency injection usage
Extension of base test class for reusability
Explicit context configuration management

netflix/hystrix

hystrix-contrib/hystrix-javanica/src/test/java/com/netflix/hystrix/contrib/javanica/test/spring/observable/ObservableTest.java

            
/**
 * Copyright 2015 Netflix, Inc.
 * <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.hystrix.contrib.javanica.test.spring.observable;

import com.netflix.hystrix.contrib.javanica.test.common.observable.BasicObservableTest;
import com.netflix.hystrix.contrib.javanica.test.spring.conf.AopCglibConfig;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Configurable;
import org.springframework.context.annotation.Bean;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

/**
 * Test covers "Reactive Execution" functionality.
 * https://github.com/Netflix/Hystrix/wiki/How-To-Use#Reactive-Execution
 */
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes = {AopCglibConfig.class, ObservableTest.ObservableTestConfig.class})
public class ObservableTest extends BasicObservableTest {

    @Autowired
    private UserService userService;

    @Override
    protected UserService createUserService() {
        return userService;
    }

    @Configurable
    public static class ObservableTestConfig {

        @Bean
        public BasicObservableTest.UserService userService() {
            return new UserService();
        }
    }

}