更新 空值临时方案处理

xufenglei

2017-10-30 c4e74acf7f33065d6da449f4f51d178225695fa5

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
package com.moral.monitor.listener.message; 
 
import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
import org.springframework.amqp.core.Message; 
import org.springframework.amqp.core.MessageProperties; 
import org.springframework.amqp.rabbit.core.RabbitTemplate; 
 
import java.util.Date; 
 
/** 
 * Created by a on 2017/3/22. 
 */ 
public class Tomq implements Runnable { 
    private Logger logger = LoggerFactory.getLogger(Tomq.class); 
    RabbitTemplate rabbitTemplate; 
    String message; 
    public void run() { 
        try { 
            long ssatime = new Date().getTime(); 
            sentRabbitMq(); 
            long esatime = new Date().getTime(); 
            logger.warn(" 转发报警信息致MQ耗时 " + (esatime - ssatime) + "==========" + Thread.currentThread().getName() + "========="); 
        } catch (Exception e) { 
            logger.warn("报警信息转发致MQ失败 " + e.getMessage()); 
        } 
    } 
 
    public void sentRabbitMq() { 
        rabbitTemplate.send("exchange_alarm", "", new Message(message.getBytes(), new MessageProperties())); 
    } 
 
    public Tomq(RabbitTemplate rabbitTemplate, String message) { 
        this.rabbitTemplate = rabbitTemplate; 
        this.message = message; 
    } 
}