|
|
@ -16,6 +16,7 @@
|
|
|
|
|
|
|
|
|
|
|
|
package org.springframework.boot.autoconfigure.amqp;
|
|
|
|
package org.springframework.boot.autoconfigure.amqp;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import com.rabbitmq.client.ConnectionFactory;
|
|
|
|
import org.junit.jupiter.api.Test;
|
|
|
|
import org.junit.jupiter.api.Test;
|
|
|
|
|
|
|
|
|
|
|
|
import org.springframework.amqp.rabbit.config.DirectRabbitListenerContainerFactory;
|
|
|
|
import org.springframework.amqp.rabbit.config.DirectRabbitListenerContainerFactory;
|
|
|
@ -313,6 +314,13 @@ class RabbitPropertiesTests {
|
|
|
|
assertThat(this.properties.getSsl().determineEnabled()).isTrue();
|
|
|
|
assertThat(this.properties.getSsl().determineEnabled()).isTrue();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
|
|
|
|
void propertiesUseConsistentDefaultValues() {
|
|
|
|
|
|
|
|
ConnectionFactory connectionFactory = new ConnectionFactory();
|
|
|
|
|
|
|
|
assertThat(connectionFactory).hasFieldOrPropertyWithValue("maxInboundMessageBodySize",
|
|
|
|
|
|
|
|
(int) this.properties.getMaxInboundMessageBodySize().toBytes());
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
@Test
|
|
|
|
void simpleContainerUseConsistentDefaultValues() {
|
|
|
|
void simpleContainerUseConsistentDefaultValues() {
|
|
|
|
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
|
|
|
|
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
|
|
|
|