本文整理汇总了Java中com.alibaba.rocketmq.client.producer.SendStatus类的典型用法代码示例。如果您正苦于以下问题:Java SendStatus类的具体用法?Java SendStatus怎么用?Java SendStatus使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SendStatus类属于com.alibaba.rocketmq.client.producer包,在下文中一共展示了SendStatus类的6个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: send
import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
@Override
public boolean send(Message data) throws Exception {
if(data == null){
return false;
}
try{
SendResult sr = producer.send(data);
if(sr.getSendStatus() != SendStatus.SEND_OK){
logger.warn(String.format("Message(%s) has been sent successfully, but send status is %s.",
data.getTopic(), sr.getSendStatus()));
}
}catch(Exception e){
if(needFaultTolerant){
putInErrorQueue(data);
}
throw e;
}
return true;
}
开发者ID:leopardoooo,项目名称:easyooo-framework,代码行数:20,代码来源:RocketMQSender.java
示例2: sendMixMessage
import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
public boolean sendMixMessage(User user) {
Message message = new Message(TOPIC, TAG, user.getUserId().toString(), JSON.toJSONString(user).getBytes());
try {
SendResult sendResult = producer.send(message);
if (SendStatus.SEND_OK.equals(sendResult.getSendStatus())) {
logger.info("send mix message successfully");
return true;
} else {
logger.info("send mix message unsuccessfully");
return false;
}
} catch (Exception e) {
logger.info("send mix message unsuccessfully, {}", e.getMessage());
return false;
}
}
开发者ID:colddew,项目名称:mix-web,代码行数:19,代码来源:RocketMQService.java
示例3: push
import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
@Override
public void push(List<Span> spanList) {
byte[] bytes = JSON.toJSONBytes(spanList);
Message message = new Message(DstConstants.ROCKET_MQ_TOPIC,bytes);
try {
SendResult sendResult = defaultMQProducer.send(message);
if(sendResult.getSendStatus()!= SendStatus.SEND_OK){
logger.error("send mq message return ["+sendResult.getSendStatus()+"]");
}
} catch (Exception e) {
logger.error("fail to send message.",e);
}
}
开发者ID:dubboclub,项目名称:dubbo-plus,代码行数:14,代码来源:RocketMqTracingCollector.java
示例4: send
import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
/**
* 发送数据到MQ方法
*
* @param Topic 队列名称
* @param Tags 标签名称
* @param body 发送的数据 推荐 JSOM 或者 XML 结构
* @param Encoding 数据编码格式 默认UTF-8
* @return 响应信息进行了内部处理 确认已经保存到 MQ 并且 日志已经记录 只要值不是NULL 就是成功发送
* @throws UnsupportedEncodingException 转换字符集出错 请检查是否可以转换
*/
public SendResult send(String Topic, String Tags, String body, String Encoding)
throws UnsupportedEncodingException
{
String loggerString = MessageFormat.format(
"将要发送到Mq的数据 Topic={0} Tags={1} body={2} Encoding={3} ", Topic, Tags, body,
Encoding);
if (Encoding == null || "".equals(Encoding))
{
Encoding = "UTF-8";
}
if (Tags == null || "".equals(Tags))
{
Tags = "*";
}
LOGGER.info(loggerString);
Message me = new Message();
// 标示
me.setTopic(Topic);
// 标签
me.setTags(Tags);
// 内容
me.setBody(body.getBytes(Encoding));
// 发送信息到MQ SendResult 是当前发送的状态 官方说 不出异常 就是成功
SendResult sendResult = null;
try
{
sendResult = producer.send(me);
}
catch (Exception e)
{
LOGGER.error(" 发送 数据给MQ出现异常 " + loggerString, e);
}
// 当消息发送失败时如何处理 getSendStatus 获取发送的状态
if (sendResult == null || sendResult.getSendStatus() != SendStatus.SEND_OK)
{
LOGGER.info(loggerString + "发送消息失败" + " MQ状态值 SendResult=" + sendResult);
sendResult = null;
}
LOGGER.info("发送到MQ成功" + sendResult);
return sendResult;
}
开发者ID:atliwen,项目名称:EDIOrderPlatform,代码行数:57,代码来源:MqProducer.java
示例5: sendBytesMessage
import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
public void sendBytesMessage(String topic, String tags, byte[] body){
SendResult result = sendBytesMessage(topic, tags, body, errorHandler);
if(result.getSendStatus()!=SendStatus.SEND_OK){
throw BaseException.formatMessage("发送消息失败!(%s)", result.getSendStatus());
}
}
开发者ID:wayshall,项目名称:onetwo,代码行数:7,代码来源:RocketMQProducerService.java
示例6: sendRawMessage
import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
public void sendRawMessage(Message message){
SendResult result = sendRawMessage(message, errorHandler);
if(result.getSendStatus()!=SendStatus.SEND_OK){
throw BaseException.formatMessage("发送消息失败!(%s)", result.getSendStatus());
}
}
开发者ID:wayshall,项目名称:onetwo,代码行数:7,代码来源:RocketMQProducerService.java
注:本文中的com.alibaba.rocketmq.client.producer.SendStatus类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论