Commit fe08762f by Dave Syer

Rename package that was missing 'cloud'

parent e100207e
...@@ -14,12 +14,12 @@ ...@@ -14,12 +14,12 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.cloud.netflix; package org.springframework.cloud.netflix.hystrix;
/** /**
* @author Spencer Gibb * @author Spencer Gibb
*/ */
public interface Constants { public interface HystrixConstants {
String HYSTRIX_STREAM_NAME = "spring.cloud.hystrix.stream"; String HYSTRIX_STREAM_NAME = "spring.cloud.hystrix.stream";
......
...@@ -14,7 +14,7 @@ ...@@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.netflix.hystrix.amqp; package org.springframework.cloud.netflix.hystrix.amqp;
import lombok.Data; import lombok.Data;
......
...@@ -14,7 +14,7 @@ ...@@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.netflix.hystrix.amqp; package org.springframework.cloud.netflix.hystrix.amqp;
import javax.annotation.PostConstruct; import javax.annotation.PostConstruct;
...@@ -25,7 +25,7 @@ import org.springframework.beans.factory.annotation.Autowired; ...@@ -25,7 +25,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.cloud.netflix.Constants; import org.springframework.cloud.netflix.hystrix.HystrixConstants;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.integration.annotation.IntegrationComponentScan; import org.springframework.integration.annotation.IntegrationComponentScan;
...@@ -78,7 +78,7 @@ public class HystrixStreamAutoConfiguration { ...@@ -78,7 +78,7 @@ public class HystrixStreamAutoConfiguration {
@Bean @Bean
public DirectExchange hystrixStreamExchange() { public DirectExchange hystrixStreamExchange() {
DirectExchange exchange = new DirectExchange(Constants.HYSTRIX_STREAM_NAME); DirectExchange exchange = new DirectExchange(HystrixConstants.HYSTRIX_STREAM_NAME);
return exchange; return exchange;
} }
...@@ -94,7 +94,7 @@ public class HystrixStreamAutoConfiguration { ...@@ -94,7 +94,7 @@ public class HystrixStreamAutoConfiguration {
* spec.header("content-type", "application/json", true); } }) * spec.header("content-type", "application/json", true); } })
*/ */
.handle(Amqp.outboundAdapter(this.amqpTemplate).exchangeName( .handle(Amqp.outboundAdapter(this.amqpTemplate).exchangeName(
Constants.HYSTRIX_STREAM_NAME)).get(); HystrixConstants.HYSTRIX_STREAM_NAME)).get();
} }
private Jackson2JsonMessageConverter messageConverter() { private Jackson2JsonMessageConverter messageConverter() {
......
...@@ -14,7 +14,7 @@ ...@@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.netflix.hystrix.amqp; package org.springframework.cloud.netflix.hystrix.amqp;
import org.springframework.integration.annotation.Gateway; import org.springframework.integration.annotation.Gateway;
import org.springframework.integration.annotation.MessagingGateway; import org.springframework.integration.annotation.MessagingGateway;
......
...@@ -14,7 +14,7 @@ ...@@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.springframework.netflix.hystrix.amqp; package org.springframework.cloud.netflix.hystrix.amqp;
import java.io.IOException; import java.io.IOException;
import java.io.StringWriter; import java.io.StringWriter;
......
...@@ -32,7 +32,7 @@ import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter; ...@@ -32,7 +32,7 @@ import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.cloud.netflix.Constants; import org.springframework.cloud.netflix.hystrix.HystrixConstants;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.integration.dsl.IntegrationFlow; import org.springframework.integration.dsl.IntegrationFlow;
...@@ -66,7 +66,7 @@ public class TurbineAmqpAutoConfiguration { ...@@ -66,7 +66,7 @@ public class TurbineAmqpAutoConfiguration {
@Bean @Bean
public DirectExchange hystrixStreamExchange() { public DirectExchange hystrixStreamExchange() {
DirectExchange exchange = new DirectExchange(Constants.HYSTRIX_STREAM_NAME); DirectExchange exchange = new DirectExchange(HystrixConstants.HYSTRIX_STREAM_NAME);
return exchange; return exchange;
} }
...@@ -80,7 +80,7 @@ public class TurbineAmqpAutoConfiguration { ...@@ -80,7 +80,7 @@ public class TurbineAmqpAutoConfiguration {
public Queue hystrixStreamQueue() { public Queue hystrixStreamQueue() {
Map<String, Object> args = new HashMap<>(); Map<String, Object> args = new HashMap<>();
args.put("x-message-ttl", 60000); // TODO: configure TTL args.put("x-message-ttl", 60000); // TODO: configure TTL
Queue queue = new Queue(Constants.HYSTRIX_STREAM_NAME, false, false, false, args); Queue queue = new Queue(HystrixConstants.HYSTRIX_STREAM_NAME, false, false, false, args);
return queue; return queue;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment