Ai
1 Star 0 Fork 4

物联网平台/cloudmq-go-client
关闭

forked from cloudzone/cloudmq-go-client
关闭
 
加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
message_queue.go 823 Bytes
一键复制 编辑 原始数据 按行查看 历史
Gogs 提交于 2015-12-08 16:37 +08:00 . first commit
package rocketmq
type MessageQueue struct {
topic string
brokerName string
queueId int32
}
func (self *MessageQueue) clone() *MessageQueue {
no := new(MessageQueue)
no.topic = self.topic
no.queueId = self.queueId
no.brokerName = self.brokerName
return no
}
type MessageQueues []*MessageQueue
func (self MessageQueues) Less(i, j int) bool {
imq := self[i]
jmq := self[j]
if imq.topic < jmq.topic {
return true
} else if imq.topic < jmq.topic {
return false
}
if imq.brokerName < jmq.brokerName {
return true
} else if imq.brokerName < jmq.brokerName {
return false
}
if imq.queueId < jmq.queueId {
return true
} else {
return false
}
}
func (self MessageQueues) Swap(i, j int) {
self[i], self[j] = self[j], self[i]
}
func (self MessageQueues) Len() int {
return len(self)
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/anhj_iot_platform/cloudmq-go-client.git
git@gitee.com:anhj_iot_platform/cloudmq-go-client.git
anhj_iot_platform
cloudmq-go-client
cloudmq-go-client
master

搜索帮助