Gordon Zhang americanstone

Want to know the behavoir of your app if a Hystrix Circuit is open?

Run with the circuit open

Run your spring cloud app with -Dhystrix.command.<circuitKeyName>.circuitBreaker.forceOpen=true

<circuiktKeyName> is the name of you hystrix circuit. If you used @HystrixCommand it is the name of the method. If you used @HystrixCommand(commandKey="mykey") is is the value of the commandKey attribute.

	<!DOCTYPE html>
	<html lang="en">
	<head>
	<meta charset="utf-8">
	<meta http-equiv="X-UA-Compatible" content="IE=edge">
	<meta name="viewport" content="width=device-width, initial-scale=1">
	<title>Bootstrap 101 Template</title>

	<!-- Bootstrap -->
	<!-- Latest compiled and minified CSS -->

	public class Spawner {
	public static void main(String[] args) {
	Thread t = new Thread(new Runnable() {
	public void run() {
	while (true) {
	System.out.println("I'm still alive");
	}
	}
	});
	t.start();

	(function(){
	var sequence = Promise.resolve();
	for(var i = 0; i < 10 ; i++){
	const timeout = Math.random() * 1000;
	sequence = sequence.then((function(icopy){
	return new Promise((resolve, reject) => {setTimeout(() => { console.log(icopy); resolve();}, timeout);});
	})(i));
	}
	})()

	async function getResponseSize(url) {
	const response = await fetch(url);
	const reader = response.body.getReader();
	let result = await reader.read();
	let total = 0;

	while (!result.done) {
	const value = result.value;
	total += value.length;
	console.log('Received chunk', value);

	import java.util.concurrent.BlockingQueue;
	import java.util.concurrent.CompletableFuture;
	import java.util.concurrent.LinkedBlockingQueue;
	import java.util.concurrent.TimeUnit;

	public class CommonPoolCompletionService<V> {
	private final BlockingQueue<V> completionQueue;

	private final BlockingQueue<CompletableFuture<V>> completionQueue1;

	package com.dealer.modules.cms.promotions.services;
	import org.apache.commons.logging.Log;
	import org.apache.commons.logging.LogFactory;

	import java.util.List;
	import java.util.concurrent.RecursiveAction;
	import java.util.function.BiFunction;

	/***
	* A recursive resultless ForkJoinTask. The BiFunction knows how to take a list of feed and context to generate a ordered results.


	Stream<Foo> stream = stream1.collect(concat(stream2)).collect(concat(element));

	Stream<Foo> stream = stream1
	.filter(x -> x!=0)
	.collect(concat(stream2))
	.filter(x -> x!=1)
	.collect(concat(element))
	.filter(x -> x!=2);

Gordon Zhang americanstone

Run with the circuit open

Dynamically force open the circuit