Subversion Repositories SmartDukaan

Rev

Rev 34860 | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 34860 Rev 34865
Line 6... Line 6...
6 
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
 6 
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
7 
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
 7 
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
8 
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 8 
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
9 
import org.springframework.amqp.rabbit.core.RabbitTemplate;
 9 
import org.springframework.amqp.rabbit.core.RabbitTemplate;
10 
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
 10 
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
- 
 
 11 
import org.springframework.beans.factory.annotation.Value;
11 
import org.springframework.context.annotation.Bean;
 12 
import org.springframework.context.annotation.Bean;
12 
import org.springframework.context.annotation.Configuration;
 13 
import org.springframework.context.annotation.Configuration;
13 
import org.springframework.context.annotation.Primary;
 14 
import org.springframework.context.annotation.Primary;
14 
 
 15 
 
15 
@EnableRabbit
 16 
@EnableRabbit
Line 19... Line 20...
19 
    public static final String TXN_QUEUE = "transaction.queue";
 20 
    public static final String TXN_QUEUE = "transaction.queue";
20 
    public static final String TXN_EXCHANGE = "transaction.exchange";
 21 
    public static final String TXN_EXCHANGE = "transaction.exchange";
21 
    public static final String TXN_ROUTING_KEY = "transaction.key";
 22 
    public static final String TXN_ROUTING_KEY = "transaction.key";
22 
 
 23 
 
23 
    @Bean
 24 
    @Bean
24 
    public ConnectionFactory connectionFactory() {
 25 
    public ConnectionFactory connectionFactory(
- 
 
 26 
            @Value("${spring.rabbitmq.host}") String host,
- 
 
 27 
            @Value("${spring.rabbitmq.port}") int port,
- 
 
 28 
            @Value("${spring.rabbitmq.username}") String username,
- 
 
 29 
            @Value("${spring.rabbitmq.password}") String password) {
- 
 
 30 
 
25 
        return new CachingConnectionFactory("localhost");
 31 
        CachingConnectionFactory factory = new CachingConnectionFactory(host, port);
- 
 
 32 
        factory.setUsername(username);
- 
 
 33 
        factory.setPassword(password);
- 
 
 34 
        return factory;
26 
    }
 35 
    }
27 
 
 36 
 
28 
    @Bean
 37 
    @Bean
29 
    public Queue transactionQueue() {
 38 
    public Queue transactionQueue() {
30 
        return new Queue(TXN_QUEUE, true);
 39 
        return new Queue(TXN_QUEUE, true);