README.md

disruptor

library for introducing disruptions to your code to replicate an unstable live environment.

Modules

• core: core disruptor API
• spring: spring integration
• openfeign: feign integration

Example

Pure Java

final Disruptor disruptor = Disruptor.builder()
        .group(
                // Creates a new group called "test"...
                "test",
                group -> group
                        .config(
                                // which triggers 25% of the time, and lasts for 5 seconds once triggered
                                DisruptionTrigger.random(0.25f).lasting(Duration.ofSeconds(5L)),
                                config -> config
                                        // running before the method that is disrupted
                                        .mode(DisruptionMode.BEFORE)
                                        // introducing a delay of 5 seconds
                                        .delay(Duration.ofSeconds(5L))
                                        // then throwing an exception
                                        .throwException(ctx -> new RuntimeException("hello :)"))
                        )
        )
        .build();

disruptor.disruptWithoutResult("test", () -> {
    System.out.println("test");
});

OpenFeign

final DisruptorCapability capability = DisruptorCapability.of(
        disruptor,
        "group"
);
Feign.builder()/*...*/.addCapability(capability)/*...*/;

// Or, if using spring-cloud-openfeign:
@Bean
Capability disruptorCapability() {
    return DisruptorCapability(disruptor, "group");
}

Spring

import java.beans.BeanProperty;

@Configuration
public class YourConfig {

    @Bean
    Disruptor disruptor() {
        return Disruptor.builder()/*...*/.build();
    }
}

@Disrupt("group") // You may annotate a class...
public class YourService {
    
    @Disrupt("other-group") //... or a method
    public void yourMethod() {
    }
}