|
|
@ -38,11 +38,11 @@ public class OrderlyMessageQueueSelector implements MessageQueueSelector {
|
|
|
|
.getLogger(OrderlyMessageQueueSelector.class);
|
|
|
|
.getLogger(OrderlyMessageQueueSelector.class);
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* to select a fixed queue by id
|
|
|
|
* to select a fixed queue by id.
|
|
|
|
* @param mqs
|
|
|
|
* @param mqs all message queues of this topic.
|
|
|
|
* @param msg
|
|
|
|
* @param msg mq message.
|
|
|
|
* @param arg
|
|
|
|
* @param arg mq arguments.
|
|
|
|
* @return
|
|
|
|
* @return message queue selected.
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {
|
|
|
|
public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {
|
|
|
|