lingwei.kong/hawkbit
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

TTL

Browse Source 
Signed-off-by: SirWayne <dennis.melzer@bosch-si.com>
This commit is contained in:
SirWayne
2016-04-13 17:27:49 +02:00
parent ee0fc26678
commit 30ba98ff8e
2 changed files with 8 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
hawkbit-dmf-amqp/src/main/java/org/eclipse/hawkbit/amqp/AmqpConfiguration.java
View File

@@ -15,6 +15,7 @@ import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
@@ -40,16 +41,12 @@ public class AmqpConfiguration {
@Autowired
private ConnectionFactory connectionFactory;
// /**
// * Method to set the Jackson2JsonMessageConverter.
// *
// * @return the Jackson2JsonMessageConverter
// */
// @Bean
// public RabbitAdmin rabbitAdmin(final RabbitAdmin rabbitAdmin) {
// rabbitAdmin.setIgnoreDeclarationExceptions(true);
// return rabbitAdmin;
// }
@Bean
public RabbitAdmin rabbitAdmin() {
final RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
rabbitAdmin.setIgnoreDeclarationExceptions(true);
return rabbitAdmin;
}
/**
* Method to set the Jackson2JsonMessageConverter.

3
hawkbit-dmf-amqp/src/main/java/org/eclipse/hawkbit/amqp/AmqpDeadletterProperties.java
View File

@@ -48,8 +48,7 @@ public class AmqpDeadletterProperties {
* @return the deadletter queue
*/
public Queue createDeadletterQueue(final String queueName) {
// getTTLArgs()
return new Queue(queueName, true, false, false, null);
return new Queue(queueName, true, false, false, getTTLArgs());
}
private Map<String, Object> getTTLArgs() {