Commit 2464b23c authored by chenkai's avatar chenkai

V1.1.0

parent f81854f4
...@@ -105,17 +105,13 @@ public class MQSender { ...@@ -105,17 +105,13 @@ public class MQSender {
} }
} }
public void sendAndForget(SendAndForgetMsg message) throws Exception { public void sendAndForget(String content) throws Exception {
if (message == null || !message.checkIntegrity()) {
return;
}
message.setSource(source);
String messageStr = GSON.toJson(message);
Channel channel = null; Channel channel = null;
try { try {
channel = channelPool.borrowObject(); channel = channelPool.borrowObject();
channel.basicPublish(exchangeName, "send", false, false, channel.basicPublish(exchangeName, "qunar_baitiaodebt", false, false,
PROPERTIES, messageStr.getBytes("utf8")); PROPERTIES, content.getBytes("utf8"));
} finally { } finally {
if (channel != null) { if (channel != null) {
channelPool.returnObject(channel); channelPool.returnObject(channel);
......
package cn.quantgroup.fundmanage;
import java.util.List;
/**
* Created by Miraculous on 16/6/30.
*/
public class SendAndForgetMsg {
private String source;
private String merchantId;
private String phoneNo;
private String contentId;
private List<String> args;
private boolean isEmpty(String arg) {
return arg == null || "".equals(arg);
}
public boolean checkIntegrity() {
return !(isEmpty(merchantId) || isEmpty(phoneNo) ||
isEmpty(contentId));
}
public SendAndForgetMsg(List<String> args, String contentId, String merchantId, String phoneNo) {
this.args = args;
this.contentId = contentId;
this.merchantId = merchantId;
this.phoneNo = phoneNo;
}
public List<String> getArgs() {
return args;
}
public void setArgs(List<String> args) {
this.args = args;
}
public String getContentId() {
return contentId;
}
public void setContentId(String contentId) {
this.contentId = contentId;
}
public String getMerchantId() {
return merchantId;
}
public void setMerchantId(String merchantId) {
this.merchantId = merchantId;
}
public String getPhoneNo() {
return phoneNo;
}
public void setPhoneNo(String phoneNo) {
this.phoneNo = phoneNo;
}
public String getSource() {
return source;
}
protected void setSource(String source) {
this.source = source;
}
}
fundmanage.rabbitmq.host=192.168.192.243 fundmanage.rabbitmq.host=192.168.192.153
fundmanage.rabbitmq.port=5672 fundmanage.rabbitmq.port=5672
fundmanage.rabbitmq.user=rabbit_admin fundmanage.rabbitmq.user=rabbitadmin
fundmanage.rabbitmq.password=abc1234 fundmanage.rabbitmq.password=123456
fundmanage.rabbitmq.exchange-name=fundmanage fundmanage.rabbitmq.exchange-name=baitiaodebt_orderinfo
fundmanage.rabbitmq.vhost=fundmanage fundmanage.rabbitmq.vhost=baitiao_debt
\ No newline at end of file
fundmanage.rabbitmq.host=192.168.192.243 fundmanage.rabbitmq.host=192.168.192.153
fundmanage.rabbitmq.port=5672 fundmanage.rabbitmq.port=5672
fundmanage.rabbitmq.user=rabbit_admin fundmanage.rabbitmq.user=rabbitadmin
fundmanage.rabbitmq.password=abc1234 fundmanage.rabbitmq.password=123456
fundmanage.rabbitmq.exchange-name=sms-control fundmanage.rabbitmq.exchange-name=baitiaodebt_orderinfo
fundmanage.rabbitmq.vhost=sms fundmanage.rabbitmq.vhost=baitiao_debt
\ No newline at end of file
fundmanage.rabbitmq.host=192.168.192.243 fundmanage.rabbitmq.host=192.168.192.153
fundmanage.rabbitmq.port=5672 fundmanage.rabbitmq.port=5672
fundmanage.rabbitmq.user=rabbit_admin fundmanage.rabbitmq.user=rabbitadmin
fundmanage.rabbitmq.password=abc1234 fundmanage.rabbitmq.password=123456
fundmanage.rabbitmq.exchange-name=sms-control fundmanage.rabbitmq.exchange-name=baitiaodebt_orderinfo
fundmanage.rabbitmq.vhost=sms fundmanage.rabbitmq.vhost=baitiao_debt
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment