package doumeemes.config.rocketmq;
|
import com.aliyun.openservices.ons.api.PropertyKeyConst;
|
import org.springframework.boot.context.properties.ConfigurationProperties;
|
import org.springframework.context.annotation.Configuration;
|
|
import java.util.Properties;
|
|
//@Configuration
|
//@ConfigurationProperties(prefix = "rocketmq")
|
public class MqConfig {
|
|
private String accessKey;
|
private String secretKey;
|
private String nameSrvAddr;
|
private String topic;
|
private String groupId;
|
private String instanceId;
|
|
|
public Properties getMqPropertie() {
|
Properties properties = new Properties();
|
properties.setProperty(PropertyKeyConst.AccessKey, this.accessKey);
|
properties.setProperty(PropertyKeyConst.SecretKey, this.secretKey);
|
properties.setProperty(PropertyKeyConst.NAMESRV_ADDR, this.nameSrvAddr);
|
properties.setProperty(PropertyKeyConst.GROUP_ID, this.groupId);
|
properties.setProperty(PropertyKeyConst.INSTANCE_ID, this.instanceId);
|
return properties;
|
}
|
|
public String getAccessKey() {
|
return accessKey;
|
}
|
|
public void setAccessKey(String accessKey) {
|
this.accessKey = accessKey;
|
}
|
|
public String getSecretKey() {
|
return secretKey;
|
}
|
|
public void setSecretKey(String secretKey) {
|
this.secretKey = secretKey;
|
}
|
|
public String getNameSrvAddr() {
|
return nameSrvAddr;
|
}
|
|
public void setNameSrvAddr(String nameSrvAddr) {
|
this.nameSrvAddr = nameSrvAddr;
|
}
|
|
public String getTopic() {
|
return topic;
|
}
|
|
public void setTopic(String topic) {
|
this.topic = topic;
|
}
|
|
public String getGroupId() {
|
return groupId;
|
}
|
|
public void setGroupId(String groupId) {
|
this.groupId = groupId;
|
}
|
|
|
public String getInstanceId() {
|
return instanceId;
|
}
|
|
public void setInstanceId(String instanceId) {
|
this.instanceId = instanceId;
|
}
|
}
|