|
|
@ -1,5 +1,5 @@
|
|
|
|
/*
|
|
|
|
/*
|
|
|
|
* Copyright 2012-2018 the original author or authors.
|
|
|
|
* Copyright 2012-2019 the original author or authors.
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
|
|
* you may not use this file except in compliance with the License.
|
|
|
|
* you may not use this file except in compliance with the License.
|
|
|
@ -497,7 +497,8 @@ public class RabbitProperties {
|
|
|
|
@NestedConfigurationProperty
|
|
|
|
@NestedConfigurationProperty
|
|
|
|
private final AmqpContainer simple = new AmqpContainer();
|
|
|
|
private final AmqpContainer simple = new AmqpContainer();
|
|
|
|
|
|
|
|
|
|
|
|
@DeprecatedConfigurationProperty(replacement = "spring.rabbitmq.listener.simple.auto-startup")
|
|
|
|
@DeprecatedConfigurationProperty(
|
|
|
|
|
|
|
|
replacement = "spring.rabbitmq.listener.simple.auto-startup")
|
|
|
|
@Deprecated
|
|
|
|
@Deprecated
|
|
|
|
public boolean isAutoStartup() {
|
|
|
|
public boolean isAutoStartup() {
|
|
|
|
return getSimple().isAutoStartup();
|
|
|
|
return getSimple().isAutoStartup();
|
|
|
@ -508,7 +509,8 @@ public class RabbitProperties {
|
|
|
|
getSimple().setAutoStartup(autoStartup);
|
|
|
|
getSimple().setAutoStartup(autoStartup);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@DeprecatedConfigurationProperty(replacement = "spring.rabbitmq.listener.simple.acknowledge-mode")
|
|
|
|
@DeprecatedConfigurationProperty(
|
|
|
|
|
|
|
|
replacement = "spring.rabbitmq.listener.simple.acknowledge-mode")
|
|
|
|
@Deprecated
|
|
|
|
@Deprecated
|
|
|
|
public AcknowledgeMode getAcknowledgeMode() {
|
|
|
|
public AcknowledgeMode getAcknowledgeMode() {
|
|
|
|
return getSimple().getAcknowledgeMode();
|
|
|
|
return getSimple().getAcknowledgeMode();
|
|
|
@ -519,7 +521,8 @@ public class RabbitProperties {
|
|
|
|
getSimple().setAcknowledgeMode(acknowledgeMode);
|
|
|
|
getSimple().setAcknowledgeMode(acknowledgeMode);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@DeprecatedConfigurationProperty(replacement = "spring.rabbitmq.listener.simple.concurrency")
|
|
|
|
@DeprecatedConfigurationProperty(
|
|
|
|
|
|
|
|
replacement = "spring.rabbitmq.listener.simple.concurrency")
|
|
|
|
@Deprecated
|
|
|
|
@Deprecated
|
|
|
|
public Integer getConcurrency() {
|
|
|
|
public Integer getConcurrency() {
|
|
|
|
return getSimple().getConcurrency();
|
|
|
|
return getSimple().getConcurrency();
|
|
|
@ -530,7 +533,8 @@ public class RabbitProperties {
|
|
|
|
getSimple().setConcurrency(concurrency);
|
|
|
|
getSimple().setConcurrency(concurrency);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@DeprecatedConfigurationProperty(replacement = "spring.rabbitmq.listener.simple.max-concurrency")
|
|
|
|
@DeprecatedConfigurationProperty(
|
|
|
|
|
|
|
|
replacement = "spring.rabbitmq.listener.simple.max-concurrency")
|
|
|
|
@Deprecated
|
|
|
|
@Deprecated
|
|
|
|
public Integer getMaxConcurrency() {
|
|
|
|
public Integer getMaxConcurrency() {
|
|
|
|
return getSimple().getMaxConcurrency();
|
|
|
|
return getSimple().getMaxConcurrency();
|
|
|
@ -541,7 +545,8 @@ public class RabbitProperties {
|
|
|
|
getSimple().setMaxConcurrency(maxConcurrency);
|
|
|
|
getSimple().setMaxConcurrency(maxConcurrency);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@DeprecatedConfigurationProperty(replacement = "spring.rabbitmq.listener.simple.prefetch")
|
|
|
|
@DeprecatedConfigurationProperty(
|
|
|
|
|
|
|
|
replacement = "spring.rabbitmq.listener.simple.prefetch")
|
|
|
|
@Deprecated
|
|
|
|
@Deprecated
|
|
|
|
public Integer getPrefetch() {
|
|
|
|
public Integer getPrefetch() {
|
|
|
|
return getSimple().getPrefetch();
|
|
|
|
return getSimple().getPrefetch();
|
|
|
@ -552,7 +557,8 @@ public class RabbitProperties {
|
|
|
|
getSimple().setPrefetch(prefetch);
|
|
|
|
getSimple().setPrefetch(prefetch);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@DeprecatedConfigurationProperty(replacement = "spring.rabbitmq.listener.simple.transaction-size")
|
|
|
|
@DeprecatedConfigurationProperty(
|
|
|
|
|
|
|
|
replacement = "spring.rabbitmq.listener.simple.transaction-size")
|
|
|
|
@Deprecated
|
|
|
|
@Deprecated
|
|
|
|
public Integer getTransactionSize() {
|
|
|
|
public Integer getTransactionSize() {
|
|
|
|
return getSimple().getTransactionSize();
|
|
|
|
return getSimple().getTransactionSize();
|
|
|
@ -563,7 +569,8 @@ public class RabbitProperties {
|
|
|
|
getSimple().setTransactionSize(transactionSize);
|
|
|
|
getSimple().setTransactionSize(transactionSize);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@DeprecatedConfigurationProperty(replacement = "spring.rabbitmq.listener.simple.default-requeue-rejected")
|
|
|
|
@DeprecatedConfigurationProperty(
|
|
|
|
|
|
|
|
replacement = "spring.rabbitmq.listener.simple.default-requeue-rejected")
|
|
|
|
@Deprecated
|
|
|
|
@Deprecated
|
|
|
|
public Boolean getDefaultRequeueRejected() {
|
|
|
|
public Boolean getDefaultRequeueRejected() {
|
|
|
|
return getSimple().getDefaultRequeueRejected();
|
|
|
|
return getSimple().getDefaultRequeueRejected();
|
|
|
@ -574,7 +581,8 @@ public class RabbitProperties {
|
|
|
|
getSimple().setDefaultRequeueRejected(defaultRequeueRejected);
|
|
|
|
getSimple().setDefaultRequeueRejected(defaultRequeueRejected);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@DeprecatedConfigurationProperty(replacement = "spring.rabbitmq.listener.simple.idle-event-interval")
|
|
|
|
@DeprecatedConfigurationProperty(
|
|
|
|
|
|
|
|
replacement = "spring.rabbitmq.listener.simple.idle-event-interval")
|
|
|
|
@Deprecated
|
|
|
|
@Deprecated
|
|
|
|
public Long getIdleEventInterval() {
|
|
|
|
public Long getIdleEventInterval() {
|
|
|
|
return getSimple().getIdleEventInterval();
|
|
|
|
return getSimple().getIdleEventInterval();
|
|
|
@ -585,7 +593,8 @@ public class RabbitProperties {
|
|
|
|
getSimple().setIdleEventInterval(idleEventInterval);
|
|
|
|
getSimple().setIdleEventInterval(idleEventInterval);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@DeprecatedConfigurationProperty(replacement = "spring.rabbitmq.listener.simple.retry")
|
|
|
|
@DeprecatedConfigurationProperty(
|
|
|
|
|
|
|
|
replacement = "spring.rabbitmq.listener.simple.retry")
|
|
|
|
@Deprecated
|
|
|
|
@Deprecated
|
|
|
|
public ListenerRetry getRetry() {
|
|
|
|
public ListenerRetry getRetry() {
|
|
|
|
return getSimple().getRetry();
|
|
|
|
return getSimple().getRetry();
|
|
|
|