Java SendResult类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.aliyun.openservices.ons.api.SendResult类的典型用法代码示例。如果您正苦于以下问题：Java SendResult类的具体用法？Java SendResult怎么用？Java SendResult使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

SendResult类属于com.aliyun.openservices.ons.api包，在下文中一共展示了SendResult类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: publish

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
@Override
public EasyTransMsgPublishResult publish(String topic, String tag, String key, Map<String,Object> header, byte[] msgByte) {
	byte[] headerBytes = serializer.serialization(header);
	int headerBytesLen = headerBytes.length;
	int messageByteLen = msgByte.length;
	byte[] combine = new byte[headerBytesLen + messageByteLen];
	System.arraycopy(headerBytes, 0, combine, 0, headerBytes.length);
	System.arraycopy(msgByte, 0, combine, headerBytes.length , msgByte.length);
	
	Message message =  new Message(topic, tag, key, combine);
	Properties properties = new Properties();
	properties.put(HEADER_LEN, headerBytesLen);
	properties.put(MESSAGE_LEN, messageByteLen);
	message.setUserProperties(properties);
	SendResult send = producer.send(message);
	EasyTransMsgPublishResult easyTransMsgPublishResult = new EasyTransMsgPublishResult();
	easyTransMsgPublishResult.setTopic(send.getTopic());
	easyTransMsgPublishResult.setMessageId(send.getMessageId());
	return easyTransMsgPublishResult;
}

开发者ID:QNJR-GROUP，项目名称:EasyTransaction，代码行数:21，代码来源:OnsEasyTransMsgPublisherImpl.java

示例2: run

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
@Override
    public void run(String... args) throws Exception {
        producerFactory.sendAsync(TestProducer.DISH_ADD, new Dish(1L, "name"));

//        producerFactory.sendAsync(TestProducer.DISH_UPDATE,
//                new Dish(2L, "name"),
//                new DeliveryOption("key").setDeliverTime(System.currentTimeMillis() + 1000 * 60));
//
//        producerFactory.sendAsync(TestProducer.DISH_DEL, 1L, new SendCallback() {
//            @Override
//            public void onSuccess(SendResult sendResult) {
//                //send success
//                //do some thing...
//            }
//
//            @Override
//            public void onException(OnExceptionContext context) {
//                //send fail
//                //do some thing...
//            }
//        });
        SendResult sendResult = producerFactory.orderSend(OrderProducer.SEND_MAIL,"message","shardingKey");
//
//
    }

开发者ID:onepiecex，项目名称:mq-aliyun，代码行数:26，代码来源:Application.java

示例3: sendMessage

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
@Override
public SendResult sendMessage(SimpleMessage onsMessage, SendMessageErrorHandler<SendResult> errorHandler){
	Message message = onsMessage.toMessage();
	
	String topic = resolvePlaceholders(message.getTopic());
	message.setTopic(topic);
	String tag = resolvePlaceholders(message.getTag());
	message.setTag(tag);
	
	Object body = onsMessage.getBody();
	if(needSerialize(body)){
		message.setBody(this.messageSerializer.serialize(onsMessage.getBody(), new MessageDelegate(message)));
	}else{
		message.setBody((byte[])body);
	}
	
	return sendRawMessage(message, errorHandler);
}

开发者ID:wayshall，项目名称:onetwo，代码行数:19，代码来源:ONSProducerServiceImpl.java

示例4: testSendMessage

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
@Test
	public void testSendMessage(){
		SendResult res = onsProducerService.sendMessage(SimpleMessage.builder()
																	  .topic(TOPIC)
																	  .tags(ORDER_PAY)
																	  .key("1")
																	  .body(OrderTestMessage.builder()
																			  				.orderId(1L)
																			  				.title("支付")
																			  				.build())
																	  .build());
		System.out.println("res: " + res);
		
		res = onsProducerService.sendMessage(SimpleMessage.builder()
				  .topic(TOPIC)
				  .tags(ORDER_CANCEL)
				  .key("1")
				  .body(OrderTestMessage.builder()
			  				.orderId(1L)
			  				.title("取消")
			  				.build())
				  .build());
		System.out.println("res: " + res);
//		LangUtils.CONSOLE.exitIf("test");
	}

开发者ID:wayshall，项目名称:onetwo，代码行数:26，代码来源:RmqONSProducerTest.java

示例5: sendAsync

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
/**
 	 * 发送异步消息，异步Callback形式
 	 * @param message 消息
 	 */
  public void sendAsync(com.yaoa.hibatis.mq.Message message){
  	Message onsMsg = createONSMessage(message);
producer.sendAsync(onsMsg, new SendCallback() {
	
	public void onSuccess(SendResult sendResult) {
		
	}
	
	public void onException(OnExceptionContext context) {
		logger.error("发送消息[" + context.getMessageId() +"] 失败" , context.getException());
	}
});
  }

开发者ID:yaoakeji，项目名称:hibatis，代码行数:18，代码来源:AliMessageProducer.java

示例6: sendByte

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
public SendResult sendByte(String topic, String tags, String keys, byte[] message) throws MQException {
       Message msg = new Message(topic, tags, keys, message);
       try {
		return producer.send(msg);
	} catch (Exception e) {
		throw new MQException(e);
	}
}

开发者ID:xushaomin，项目名称:apple-jms，代码行数:9，代码来源:RocketMessageProducer5.java

示例7: sendObject

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
public SendResult sendObject(String topic, String tags, String keys, Serializable message) throws MQException {		
	Message msg = new Message(topic, tags, ByteUtils.toBytes(message));
	try {
		return producer.send(msg);
	} catch (Exception e) {
		throw new MQException(e);
	}
}

开发者ID:xushaomin，项目名称:apple-jms，代码行数:9，代码来源:RocketMessageProducer5.java

示例8: sendText

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
public SendResult sendText(String topic, String tags, String keys, String message) throws MQException {		
	Message msg = new Message(topic, tags, ByteUtils.toBytes(message));
	try {
		return producer.send(msg);
	} catch (Exception e) {
		throw new MQException(e);
	}
}

开发者ID:xushaomin，项目名称:apple-jms，代码行数:9，代码来源:RocketMessageProducer5.java

示例9: sendByte

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
public void sendByte(byte[] message) throws JmsException {
       Message msg = new Message(topic, tag, key, message);
       try {
		SendResult result = producer.send(msg);
		logger.info("msgId=" + result.getMessageId());
	} catch (Exception e) {
		logger.error(e.getMessage());
		throw new MQException(e);
	}  
}

开发者ID:xushaomin，项目名称:apple-jms，代码行数:11，代码来源:RocketMessageProducer.java

示例10: sendObject

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
@Override
public void sendObject(Serializable message) throws JmsException {		
	Message msg = new Message(topic, tag, key, ByteUtils.toBytes(message));
       try {
		SendResult result = producer.send(msg);
		logger.info("msgId=" + result.getMessageId());
	} catch (Exception e) {
		logger.error(e.getMessage());
		throw new MQException(e);
	}  
}

开发者ID:xushaomin，项目名称:apple-jms，代码行数:12，代码来源:RocketMessageProducer.java

示例11: sendText

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
@Override
public void sendText(String message) throws JmsException {		
	Message msg = new Message(topic, tag, key, ByteUtils.toBytes(message));
       try {
		SendResult result = producer.send(msg);
		logger.info("msgId=" + result.getMessageId());
	} catch (Exception e) {
		logger.error(e.getMessage());
		throw new MQException(e);
	}
}

开发者ID:xushaomin，项目名称:apple-jms，代码行数:12，代码来源:RocketMessageProducer.java

示例12: handleException

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
protected Optional<SendResult> handleException(Throwable e, Message message, SendMessageErrorHandler<SendResult> errorHandler){
	String errorMsg = "send message error. topic:"+message.getTopic()+", tags:"+message.getTag();
	logger.error(errorMsg);
	if(errorHandler!=null){
		return errorHandler.onError(e);
	}else if(e instanceof ONSClientException){
		throw (ONSClientException)e;
	}else{
		throw new ServiceException("发送消息失败", e);
	}
}

开发者ID:wayshall，项目名称:onetwo，代码行数:12，代码来源:ONSProducerServiceImpl.java

示例13: sendMessage

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
@Override
public SendResult sendMessage(SimpleMessage onsMessage, LocalTransactionExecuter executer, Object arg, SendMessageErrorHandler<SendResult> errorHandler){
	Message message = onsMessage.toMessage();
	String topic = SpringUtils.resolvePlaceholders(applicationContext, message.getTopic());
	message.setTopic(topic);
	Object body = onsMessage.getBody();
	if(needSerialize(body)){
		message.setBody(this.messageSerializer.serialize(onsMessage.getBody(), new MessageDelegate(message)));
	}else{
		message.setBody((byte[])body);
	}
	return sendRawMessage(message, executer, arg, errorHandler);
}

开发者ID:wayshall，项目名称:onetwo，代码行数:14，代码来源:ONSTransactionProducerServiceImpl.java

示例14: afterSendMessage

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
@Override
public void afterSendMessage(Message message, SendResult sendResult) {
	if(logger.isInfoEnabled()){
		logger.info("send message success. topic: {}, tags: {}, sendResult: {}", message.getTopic(), message.getTag(), sendResult);
	}
	for(ProducerListener<Message> listener : listeners){
		listener.afterSendMessage(message, sendResult);
	}
}

开发者ID:wayshall，项目名称:onetwo，代码行数:10，代码来源:ONSProducerListenerComposite.java

示例15: execute

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
public void execute(Tuple tuple) {
    // TODO Auto-generated method stub
    OnsTuple msgTuple = (OnsTuple)tuple.getValue(0);
    long before = System.currentTimeMillis();
    SendResult sendResult = null;
    try {
    	Message msg = new Message(
    			producerConfig.getTopic(),
    			producerConfig.getSubExpress(),
    			//Message Body
    			//�κζ�������ʽ�����ݣ�ONS�����κθ�Ԥ����ҪProducer��ConsumerЭ�̺�һ�µ����л��ͷ����л���ʽ
    			msgTuple.getMessage().getBody());
    	
    	// ���ô�����Ϣ��ҵ��ؼ����ԣ��뾡����ȫ��Ψһ��
    	// �Է��������޷������յ���Ϣ����£���ͨ��ONS Console��ѯ��Ϣ��������
    	// ע�⣺������Ҳ����Ӱ����Ϣ�����շ�
    	if (msgTuple.getMessage().getKey() != null) {
    		msg.setKey(msgTuple.getMessage().getKey());
    	}
    	//������Ϣ��ֻҪ�����쳣���ǳɹ�
    	sendResult = producer.send(msg);
    	
        LOG.info("Success send msg of " + msgTuple.getMessage().getMsgID());
    	runCounter.count(System.currentTimeMillis() - before);
    } catch (Exception e) {
    	LOG.error("Failed to send message, SendResult:" + sendResult + "\n", e);
    	runCounter.count(System.currentTimeMillis() - before);
        collector.fail(tuple);
        return ;
        //throw new FailedException(e);
    }
    
    collector.ack(tuple);
}

开发者ID:kkllwww007，项目名称:jstrom，代码行数:35，代码来源:ProducerBolt.java

示例16: execute

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
public void execute(Tuple tuple) {
    // TODO Auto-generated method stub
    OnsTuple msgTuple = (OnsTuple)tuple.getValue(0);
    long before = System.currentTimeMillis();
    SendResult sendResult = null;
    try {
    	Message msg = new Message(
    			producerConfig.getTopic(),
    			producerConfig.getSubExpress(),
    			//Message Body
    			//任何二进制形式的数据，ONS不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式
    			msgTuple.getMessage().getBody());
    	
    	// 设置代表消息的业务关键属性，请尽可能全局唯一。
    	// 以方便您在无法正常收到消息情况下，可通过ONS Console查询消息并补发。
    	// 注意：不设置也不会影响消息正常收发
    	if (msgTuple.getMessage().getKey() != null) {
    		msg.setKey(msgTuple.getMessage().getKey());
    	}
    	//发送消息，只要不抛异常就是成功
    	sendResult = producer.send(msg);
    	
        LOG.info("Success send msg of " + msgTuple.getMessage().getMsgID());
    	runCounter.count(System.currentTimeMillis() - before);
    } catch (Exception e) {
    	LOG.error("Failed to send message, SendResult:" + sendResult + "\n", e);
    	runCounter.count(System.currentTimeMillis() - before);
        collector.fail(tuple);
        return ;
        //throw new FailedException(e);
    }
    
    collector.ack(tuple);
}

开发者ID:alibaba，项目名称:jstorm，代码行数:35，代码来源:ProducerBolt.java

示例17: send

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
public SendResult send(Message message) {
	return producer.send(message);
}

开发者ID:xushaomin，项目名称:apple-jms，代码行数:4，代码来源:RocketMQProducer.java

示例18: sendMessage

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
SendResult sendMessage(SimpleMessage onsMessage,
LocalTransactionExecuter executer, Object arg);

开发者ID:wayshall，项目名称:onetwo，代码行数:3，代码来源:TransactionProducerService.java

示例19: setErrorHandler

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
public void setErrorHandler(SendMessageErrorHandler<SendResult> errorHandler) {
	this.errorHandler = errorHandler;
}

开发者ID:wayshall，项目名称:onetwo，代码行数:4，代码来源:ONSProducerServiceImpl.java

示例20: orderSend

import com.aliyun.openservices.ons.api.SendResult; //导入依赖的package包/类
SendResult orderSend(final Enum address, final Object message, final String shardingKey);

开发者ID:onepiecex，项目名称:mq-aliyun，代码行数:2，代码来源:ProducerFactory.java

注：本文中的com.aliyun.openservices.ons.api.SendResult类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java CClass类代码示例发布时间：2022-05-23

Java CommentByLineCommentAction类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19124|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9971|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8317|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8686|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8626|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9643|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8611|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7991|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8640|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7527|2022-11-06

客服电话

电子邮件

Java SendResult类代码示例

示例1: publish

示例2: run

示例3: sendMessage

示例4: testSendMessage

示例5: sendAsync

示例6: sendByte

示例7: sendObject

示例8: sendText

示例9: sendByte

示例10: sendObject

示例11: sendText

示例12: handleException

示例13: sendMessage

示例14: afterSendMessage

示例15: execute

示例16: execute

示例17: send

示例18: sendMessage

示例19: setErrorHandler

示例20: orderSend

请发表评论

全部评论

上一篇：

下一篇：

delphi验证码识别之如何识别高级验证码

bradtraversy/iweather: Ionic 3 mobile we

edsu/lastweet: Update Twitter &amp; Mast

断牙刷新位置时间（断牙属性及刷新位置介绍

dev-sec/linux-baseline: DevSec Linux Bas

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053

edsu/lastweet: Update Twitter & Mast