mirror of
https://gitee.com/milvus-io/milvus.git
synced 2026-01-07 19:31:51 +08:00
26 lines
449 B
Go
26 lines
449 B
Go
package mqclient
|
|
|
|
import (
|
|
"github.com/zilliztech/milvus-distributed/internal/util/rocksmq/client/rocksmq"
|
|
)
|
|
|
|
type rmqMessage struct {
|
|
msg rocksmq.ConsumerMessage
|
|
}
|
|
|
|
func (rm *rmqMessage) Topic() string {
|
|
return rm.msg.Topic
|
|
}
|
|
|
|
func (rm *rmqMessage) Properties() map[string]string {
|
|
return nil
|
|
}
|
|
|
|
func (rm *rmqMessage) Payload() []byte {
|
|
return rm.msg.Payload
|
|
}
|
|
|
|
func (rm *rmqMessage) ID() MessageID {
|
|
return &rmqID{messageID: rm.msg.MsgID}
|
|
}
|