本文整理汇总了Java中org.apache.rocketmq.client.producer.MessageQueueSelector类的典型用法代码示例。如果您正苦于以下问题：Java MessageQueueSelector类的具体用法？Java MessageQueueSelector怎么用？Java MessageQueueSelector使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
MessageQueueSelector类属于org.apache.rocketmq.client.producer包，在下文中一共展示了MessageQueueSelector类的10个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: sendSelectImpl
import org.apache.rocketmq.client.producer.MessageQueueSelector; //导入依赖的package包/类
private SendResult sendSelectImpl(//
Message msg, //
MessageQueueSelector selector, //
Object arg, //
final CommunicationMode communicationMode, //
final SendCallback sendCallback, final long timeout//
) throws MQClientException, RemotingException, MQBrokerException, InterruptedException {
this.makeSureStateOK();
Validators.checkMessage(msg, this.defaultMQProducer);
TopicPublishInfo topicPublishInfo = this.tryToFindTopicPublishInfo(msg.getTopic());
if (topicPublishInfo != null && topicPublishInfo.ok()) {
MessageQueue mq = null;
try {
mq = selector.select(topicPublishInfo.getMessageQueueList(), msg, arg);
} catch (Throwable e) {
throw new MQClientException("select message queue throwed exception.", e);
}
if (mq != null) {
return this.sendKernelImpl(msg, mq, communicationMode, sendCallback, null, timeout);
} else {
throw new MQClientException("select message queue return null.", null);
}
}
throw new MQClientException("No route info for this topic, " + msg.getTopic(), null);
}
开发者ID:lirenzuo，项目名称:rocketmq-rocketmq-all-4.1.0-incubating，代码行数:29，代码来源:DefaultMQProducerImpl.java
示例2: send
import org.apache.rocketmq.client.producer.MessageQueueSelector; //导入依赖的package包/类
public void send(Message msg, MessageQueueSelector selector, Object arg, SendCallback sendCallback, long timeout)
throws MQClientException, RemotingException, InterruptedException {
try {
this.sendSelectImpl(msg, selector, arg, CommunicationMode.ASYNC, sendCallback, timeout);
} catch (MQBrokerException e) {
throw new MQClientException("unknownn exception", e);
}
}
开发者ID:lirenzuo，项目名称:rocketmq-rocketmq-all-4.1.0-incubating，代码行数:9，代码来源:DefaultMQProducerImpl.java
示例3: sendOneway
import org.apache.rocketmq.client.producer.MessageQueueSelector; //导入依赖的package包/类
/**
* SELECT ONEWAY -------------------------------------------------------
*/
public void sendOneway(Message msg, MessageQueueSelector selector, Object arg)
throws MQClientException, RemotingException, InterruptedException {
try {
this.sendSelectImpl(msg, selector, arg, CommunicationMode.ONEWAY, null, this.defaultMQProducer.getSendMsgTimeout());
} catch (MQBrokerException e) {
throw new MQClientException("unknown exception", e);
}
}
开发者ID:lirenzuo，项目名称:rocketmq-rocketmq-all-4.1.0-incubating，代码行数:12，代码来源:DefaultMQProducerImpl.java
示例4: asyncSend
import org.apache.rocketmq.client.producer.MessageQueueSelector; //导入依赖的package包/类
public void asyncSend(Object msg, MessageQueueSelector selector, Object arg) {
Message metaqMsg = (Message) msg;
try {
producer.send(metaqMsg, selector, arg, sendCallback);
msgBodys.addData(new String(metaqMsg.getBody()));
originMsgs.addData(msg);
} catch (Exception e) {
e.printStackTrace();
}
}
开发者ID:lirenzuo，项目名称:rocketmq-rocketmq-all-4.1.0-incubating，代码行数:11，代码来源:RMQAsyncSendProducer.java
示例5: sendOneWay
import org.apache.rocketmq.client.producer.MessageQueueSelector; //导入依赖的package包/类
public void sendOneWay(Object msg, MessageQueueSelector selector, Object arg) {
Message metaqMsg = (Message) msg;
try {
producer.sendOneway(metaqMsg, selector, arg);
msgBodys.addData(new String(metaqMsg.getBody()));
originMsgs.addData(msg);
} catch (Exception e) {
e.printStackTrace();
}
}
开发者ID:lirenzuo，项目名称:rocketmq-rocketmq-all-4.1.0-incubating，代码行数:11，代码来源:RMQAsyncSendProducer.java
示例6: testSendSelectorNull
import org.apache.rocketmq.client.producer.MessageQueueSelector; //导入依赖的package包/类
@Test(expected = org.apache.rocketmq.client.exception.MQClientException.class)
public void testSendSelectorNull() throws Exception {
Message msg = new Message(topic, RandomUtils.getStringByUUID().getBytes());
DefaultMQProducer producer = ProducerFactory.getRMQProducer(nsAddr);
MessageQueueSelector selector = null;
producer.sendOneway(msg, selector, 100);
}
开发者ID:lirenzuo，项目名称:rocketmq-rocketmq-all-4.1.0-incubating，代码行数:8，代码来源:OneWaySendExceptionIT.java
示例7: testSelectorThrowsException
import org.apache.rocketmq.client.producer.MessageQueueSelector; //导入依赖的package包/类
@Test(expected = org.apache.rocketmq.client.exception.MQClientException.class)
public void testSelectorThrowsException() throws Exception {
Message msg = new Message(topic, RandomUtils.getStringByUUID().getBytes());
DefaultMQProducer producer = ProducerFactory.getRMQProducer(nsAddr);
producer.sendOneway(msg, new MessageQueueSelector() {
@Override
public MessageQueue select(List<MessageQueue> list, Message message, Object o) {
String str = null;
return list.get(str.length());
}
}, null);
}
开发者ID:lirenzuo，项目名称:rocketmq-rocketmq-all-4.1.0-incubating，代码行数:13，代码来源:OneWaySendExceptionIT.java
示例8: testSendSelectorNull
import org.apache.rocketmq.client.producer.MessageQueueSelector; //导入依赖的package包/类
@Test(expected = org.apache.rocketmq.client.exception.MQClientException.class)
public void testSendSelectorNull() throws Exception {
Message msg = new Message(topic, RandomUtils.getStringByUUID().getBytes());
DefaultMQProducer producer = ProducerFactory.getRMQProducer(nsAddr);
MessageQueueSelector selector = null;
producer.send(msg, selector, 100, SendCallBackFactory.getSendCallBack());
}
开发者ID:lirenzuo，项目名称:rocketmq-rocketmq-all-4.1.0-incubating，代码行数:8，代码来源:AsyncSendExceptionIT.java
示例9: testSelectorThrowsException
import org.apache.rocketmq.client.producer.MessageQueueSelector; //导入依赖的package包/类
@Test(expected = org.apache.rocketmq.client.exception.MQClientException.class)
public void testSelectorThrowsException() throws Exception {
Message msg = new Message(topic, RandomUtils.getStringByUUID().getBytes());
DefaultMQProducer producer = ProducerFactory.getRMQProducer(nsAddr);
producer.send(msg, new MessageQueueSelector() {
@Override
public MessageQueue select(List<MessageQueue> list, Message message, Object o) {
String str = null;
return list.get(str.length());
}
}, null, SendCallBackFactory.getSendCallBack());
}
开发者ID:lirenzuo，项目名称:rocketmq-rocketmq-all-4.1.0-incubating，代码行数:13，代码来源:AsyncSendExceptionIT.java
示例10: sendSelectImpl
import org.apache.rocketmq.client.producer.MessageQueueSelector; //导入依赖的package包/类
private SendResult sendSelectImpl(
Message msg,
MessageQueueSelector selector,
Object arg,
final CommunicationMode communicationMode,
final SendCallback sendCallback, final long timeout
) throws MQClientException, RemotingException, MQBrokerException, InterruptedException {
this.makeSureStateOK();
Validators.checkMessage(msg, this.defaultMQProducer);
TopicPublishInfo topicPublishInfo = this.tryToFindTopicPublishInfo(msg.getTopic());
if (topicPublishInfo != null && topicPublishInfo.ok()) {
MessageQueue mq = null;
try {
mq = selector.select(topicPublishInfo.getMessageQueueList(), msg, arg);
} catch (Throwable e) {
throw new MQClientException("select message queue throwed exception.", e);
}
if (mq != null) {
return this.sendKernelImpl(msg, mq, communicationMode, sendCallback, null, timeout);
} else {
throw new MQClientException("select message queue return null.", null);
}
}
throw new MQClientException("No route info for this topic, " + msg.getTopic(), null);
}
开发者ID:apache，项目名称:rocketmq，代码行数:29，代码来源:DefaultMQProducerImpl.java
注：本文中的org.apache.rocketmq.client.producer.MessageQueueSelector类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论