// Code generated by protoc-gen-go. DO NOT EDIT.
// source: bhome_msg_api.proto

package bhome_msg

import (
	fmt "fmt"
	proto "github.com/golang/protobuf/proto"
	math "math"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package

type BHAddress struct {
	MqId                 uint64   `protobuf:"varint,1,opt,name=mq_id,json=mqId,proto3" json:"mq_id,omitempty"`
	AbsAddr              int64    `protobuf:"varint,2,opt,name=abs_addr,json=absAddr,proto3" json:"abs_addr,omitempty"`
	Ip                   []byte   `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	Port                 int32    `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *BHAddress) Reset()         { *m = BHAddress{} }
func (m *BHAddress) String() string { return proto.CompactTextString(m) }
func (*BHAddress) ProtoMessage()    {}
func (*BHAddress) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{0}
}

func (m *BHAddress) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_BHAddress.Unmarshal(m, b)
}
func (m *BHAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_BHAddress.Marshal(b, m, deterministic)
}
func (m *BHAddress) XXX_Merge(src proto.Message) {
	xxx_messageInfo_BHAddress.Merge(m, src)
}
func (m *BHAddress) XXX_Size() int {
	return xxx_messageInfo_BHAddress.Size(m)
}
func (m *BHAddress) XXX_DiscardUnknown() {
	xxx_messageInfo_BHAddress.DiscardUnknown(m)
}

var xxx_messageInfo_BHAddress proto.InternalMessageInfo

func (m *BHAddress) GetMqId() uint64 {
	if m != nil {
		return m.MqId
	}
	return 0
}

func (m *BHAddress) GetAbsAddr() int64 {
	if m != nil {
		return m.AbsAddr
	}
	return 0
}

func (m *BHAddress) GetIp() []byte {
	if m != nil {
		return m.Ip
	}
	return nil
}

func (m *BHAddress) GetPort() int32 {
	if m != nil {
		return m.Port
	}
	return 0
}

type ProcInfo struct {
	ProcId               []byte   `protobuf:"bytes,1,opt,name=proc_id,json=procId,proto3" json:"proc_id,omitempty"`
	Name                 []byte   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	PublicInfo           []byte   `protobuf:"bytes,3,opt,name=public_info,json=publicInfo,proto3" json:"public_info,omitempty"`
	PrivateInfo          []byte   `protobuf:"bytes,4,opt,name=private_info,json=privateInfo,proto3" json:"private_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ProcInfo) Reset()         { *m = ProcInfo{} }
func (m *ProcInfo) String() string { return proto.CompactTextString(m) }
func (*ProcInfo) ProtoMessage()    {}
func (*ProcInfo) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{1}
}

func (m *ProcInfo) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ProcInfo.Unmarshal(m, b)
}
func (m *ProcInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ProcInfo.Marshal(b, m, deterministic)
}
func (m *ProcInfo) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ProcInfo.Merge(m, src)
}
func (m *ProcInfo) XXX_Size() int {
	return xxx_messageInfo_ProcInfo.Size(m)
}
func (m *ProcInfo) XXX_DiscardUnknown() {
	xxx_messageInfo_ProcInfo.DiscardUnknown(m)
}

var xxx_messageInfo_ProcInfo proto.InternalMessageInfo

func (m *ProcInfo) GetProcId() []byte {
	if m != nil {
		return m.ProcId
	}
	return nil
}

func (m *ProcInfo) GetName() []byte {
	if m != nil {
		return m.Name
	}
	return nil
}

func (m *ProcInfo) GetPublicInfo() []byte {
	if m != nil {
		return m.PublicInfo
	}
	return nil
}

func (m *ProcInfo) GetPrivateInfo() []byte {
	if m != nil {
		return m.PrivateInfo
	}
	return nil
}

type MsgTopicList struct {
	TopicList            [][]byte `protobuf:"bytes,1,rep,name=topic_list,json=topicList,proto3" json:"topic_list,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *MsgTopicList) Reset()         { *m = MsgTopicList{} }
func (m *MsgTopicList) String() string { return proto.CompactTextString(m) }
func (*MsgTopicList) ProtoMessage()    {}
func (*MsgTopicList) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{2}
}

func (m *MsgTopicList) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgTopicList.Unmarshal(m, b)
}
func (m *MsgTopicList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgTopicList.Marshal(b, m, deterministic)
}
func (m *MsgTopicList) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgTopicList.Merge(m, src)
}
func (m *MsgTopicList) XXX_Size() int {
	return xxx_messageInfo_MsgTopicList.Size(m)
}
func (m *MsgTopicList) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgTopicList.DiscardUnknown(m)
}

var xxx_messageInfo_MsgTopicList proto.InternalMessageInfo

func (m *MsgTopicList) GetTopicList() [][]byte {
	if m != nil {
		return m.TopicList
	}
	return nil
}

type MsgPublish struct {
	Topic                []byte   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *MsgPublish) Reset()         { *m = MsgPublish{} }
func (m *MsgPublish) String() string { return proto.CompactTextString(m) }
func (*MsgPublish) ProtoMessage()    {}
func (*MsgPublish) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{3}
}

func (m *MsgPublish) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgPublish.Unmarshal(m, b)
}
func (m *MsgPublish) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgPublish.Marshal(b, m, deterministic)
}
func (m *MsgPublish) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgPublish.Merge(m, src)
}
func (m *MsgPublish) XXX_Size() int {
	return xxx_messageInfo_MsgPublish.Size(m)
}
func (m *MsgPublish) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgPublish.DiscardUnknown(m)
}

var xxx_messageInfo_MsgPublish proto.InternalMessageInfo

func (m *MsgPublish) GetTopic() []byte {
	if m != nil {
		return m.Topic
	}
	return nil
}

func (m *MsgPublish) GetData() []byte {
	if m != nil {
		return m.Data
	}
	return nil
}

type MsgCommonReply struct {
	Errmsg               *ErrorMsg `protobuf:"bytes,1,opt,name=errmsg,proto3" json:"errmsg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *MsgCommonReply) Reset()         { *m = MsgCommonReply{} }
func (m *MsgCommonReply) String() string { return proto.CompactTextString(m) }
func (*MsgCommonReply) ProtoMessage()    {}
func (*MsgCommonReply) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{4}
}

func (m *MsgCommonReply) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgCommonReply.Unmarshal(m, b)
}
func (m *MsgCommonReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgCommonReply.Marshal(b, m, deterministic)
}
func (m *MsgCommonReply) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgCommonReply.Merge(m, src)
}
func (m *MsgCommonReply) XXX_Size() int {
	return xxx_messageInfo_MsgCommonReply.Size(m)
}
func (m *MsgCommonReply) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgCommonReply.DiscardUnknown(m)
}

var xxx_messageInfo_MsgCommonReply proto.InternalMessageInfo

func (m *MsgCommonReply) GetErrmsg() *ErrorMsg {
	if m != nil {
		return m.Errmsg
	}
	return nil
}

type MsgRequestTopic struct {
	Topic                []byte   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *MsgRequestTopic) Reset()         { *m = MsgRequestTopic{} }
func (m *MsgRequestTopic) String() string { return proto.CompactTextString(m) }
func (*MsgRequestTopic) ProtoMessage()    {}
func (*MsgRequestTopic) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{5}
}

func (m *MsgRequestTopic) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgRequestTopic.Unmarshal(m, b)
}
func (m *MsgRequestTopic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgRequestTopic.Marshal(b, m, deterministic)
}
func (m *MsgRequestTopic) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgRequestTopic.Merge(m, src)
}
func (m *MsgRequestTopic) XXX_Size() int {
	return xxx_messageInfo_MsgRequestTopic.Size(m)
}
func (m *MsgRequestTopic) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgRequestTopic.DiscardUnknown(m)
}

var xxx_messageInfo_MsgRequestTopic proto.InternalMessageInfo

func (m *MsgRequestTopic) GetTopic() []byte {
	if m != nil {
		return m.Topic
	}
	return nil
}

func (m *MsgRequestTopic) GetData() []byte {
	if m != nil {
		return m.Data
	}
	return nil
}

type MsgRequestTopicReply struct {
	Errmsg               *ErrorMsg `protobuf:"bytes,1,opt,name=errmsg,proto3" json:"errmsg,omitempty"`
	Data                 []byte    `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *MsgRequestTopicReply) Reset()         { *m = MsgRequestTopicReply{} }
func (m *MsgRequestTopicReply) String() string { return proto.CompactTextString(m) }
func (*MsgRequestTopicReply) ProtoMessage()    {}
func (*MsgRequestTopicReply) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{6}
}

func (m *MsgRequestTopicReply) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgRequestTopicReply.Unmarshal(m, b)
}
func (m *MsgRequestTopicReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgRequestTopicReply.Marshal(b, m, deterministic)
}
func (m *MsgRequestTopicReply) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgRequestTopicReply.Merge(m, src)
}
func (m *MsgRequestTopicReply) XXX_Size() int {
	return xxx_messageInfo_MsgRequestTopicReply.Size(m)
}
func (m *MsgRequestTopicReply) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgRequestTopicReply.DiscardUnknown(m)
}

var xxx_messageInfo_MsgRequestTopicReply proto.InternalMessageInfo

func (m *MsgRequestTopicReply) GetErrmsg() *ErrorMsg {
	if m != nil {
		return m.Errmsg
	}
	return nil
}

func (m *MsgRequestTopicReply) GetData() []byte {
	if m != nil {
		return m.Data
	}
	return nil
}

type MsgRegister struct {
	Proc                 *ProcInfo `protobuf:"bytes,1,opt,name=proc,proto3" json:"proc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *MsgRegister) Reset()         { *m = MsgRegister{} }
func (m *MsgRegister) String() string { return proto.CompactTextString(m) }
func (*MsgRegister) ProtoMessage()    {}
func (*MsgRegister) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{7}
}

func (m *MsgRegister) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgRegister.Unmarshal(m, b)
}
func (m *MsgRegister) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgRegister.Marshal(b, m, deterministic)
}
func (m *MsgRegister) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgRegister.Merge(m, src)
}
func (m *MsgRegister) XXX_Size() int {
	return xxx_messageInfo_MsgRegister.Size(m)
}
func (m *MsgRegister) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgRegister.DiscardUnknown(m)
}

var xxx_messageInfo_MsgRegister proto.InternalMessageInfo

func (m *MsgRegister) GetProc() *ProcInfo {
	if m != nil {
		return m.Proc
	}
	return nil
}

type MsgUnregister struct {
	Proc                 *ProcInfo `protobuf:"bytes,1,opt,name=proc,proto3" json:"proc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *MsgUnregister) Reset()         { *m = MsgUnregister{} }
func (m *MsgUnregister) String() string { return proto.CompactTextString(m) }
func (*MsgUnregister) ProtoMessage()    {}
func (*MsgUnregister) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{8}
}

func (m *MsgUnregister) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgUnregister.Unmarshal(m, b)
}
func (m *MsgUnregister) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgUnregister.Marshal(b, m, deterministic)
}
func (m *MsgUnregister) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgUnregister.Merge(m, src)
}
func (m *MsgUnregister) XXX_Size() int {
	return xxx_messageInfo_MsgUnregister.Size(m)
}
func (m *MsgUnregister) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgUnregister.DiscardUnknown(m)
}

var xxx_messageInfo_MsgUnregister proto.InternalMessageInfo

func (m *MsgUnregister) GetProc() *ProcInfo {
	if m != nil {
		return m.Proc
	}
	return nil
}

type MsgHeartbeat struct {
	Proc                 *ProcInfo `protobuf:"bytes,1,opt,name=proc,proto3" json:"proc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *MsgHeartbeat) Reset()         { *m = MsgHeartbeat{} }
func (m *MsgHeartbeat) String() string { return proto.CompactTextString(m) }
func (*MsgHeartbeat) ProtoMessage()    {}
func (*MsgHeartbeat) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{9}
}

func (m *MsgHeartbeat) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgHeartbeat.Unmarshal(m, b)
}
func (m *MsgHeartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgHeartbeat.Marshal(b, m, deterministic)
}
func (m *MsgHeartbeat) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgHeartbeat.Merge(m, src)
}
func (m *MsgHeartbeat) XXX_Size() int {
	return xxx_messageInfo_MsgHeartbeat.Size(m)
}
func (m *MsgHeartbeat) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgHeartbeat.DiscardUnknown(m)
}

var xxx_messageInfo_MsgHeartbeat proto.InternalMessageInfo

func (m *MsgHeartbeat) GetProc() *ProcInfo {
	if m != nil {
		return m.Proc
	}
	return nil
}

type MsgQueryTopic struct {
	Topic                []byte   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *MsgQueryTopic) Reset()         { *m = MsgQueryTopic{} }
func (m *MsgQueryTopic) String() string { return proto.CompactTextString(m) }
func (*MsgQueryTopic) ProtoMessage()    {}
func (*MsgQueryTopic) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{10}
}

func (m *MsgQueryTopic) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgQueryTopic.Unmarshal(m, b)
}
func (m *MsgQueryTopic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgQueryTopic.Marshal(b, m, deterministic)
}
func (m *MsgQueryTopic) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgQueryTopic.Merge(m, src)
}
func (m *MsgQueryTopic) XXX_Size() int {
	return xxx_messageInfo_MsgQueryTopic.Size(m)
}
func (m *MsgQueryTopic) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgQueryTopic.DiscardUnknown(m)
}

var xxx_messageInfo_MsgQueryTopic proto.InternalMessageInfo

func (m *MsgQueryTopic) GetTopic() []byte {
	if m != nil {
		return m.Topic
	}
	return nil
}

type MsgQueryTopicReply struct {
	Errmsg               *ErrorMsg                           `protobuf:"bytes,1,opt,name=errmsg,proto3" json:"errmsg,omitempty"`
	NodeAddress          []*MsgQueryTopicReply_BHNodeAddress `protobuf:"bytes,2,rep,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (m *MsgQueryTopicReply) Reset()         { *m = MsgQueryTopicReply{} }
func (m *MsgQueryTopicReply) String() string { return proto.CompactTextString(m) }
func (*MsgQueryTopicReply) ProtoMessage()    {}
func (*MsgQueryTopicReply) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{11}
}

func (m *MsgQueryTopicReply) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgQueryTopicReply.Unmarshal(m, b)
}
func (m *MsgQueryTopicReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgQueryTopicReply.Marshal(b, m, deterministic)
}
func (m *MsgQueryTopicReply) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgQueryTopicReply.Merge(m, src)
}
func (m *MsgQueryTopicReply) XXX_Size() int {
	return xxx_messageInfo_MsgQueryTopicReply.Size(m)
}
func (m *MsgQueryTopicReply) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgQueryTopicReply.DiscardUnknown(m)
}

var xxx_messageInfo_MsgQueryTopicReply proto.InternalMessageInfo

func (m *MsgQueryTopicReply) GetErrmsg() *ErrorMsg {
	if m != nil {
		return m.Errmsg
	}
	return nil
}

func (m *MsgQueryTopicReply) GetNodeAddress() []*MsgQueryTopicReply_BHNodeAddress {
	if m != nil {
		return m.NodeAddress
	}
	return nil
}

type MsgQueryTopicReply_BHNodeAddress struct {
	ProcId               []byte     `protobuf:"bytes,1,opt,name=proc_id,json=procId,proto3" json:"proc_id,omitempty"`
	Addr                 *BHAddress `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (m *MsgQueryTopicReply_BHNodeAddress) Reset()         { *m = MsgQueryTopicReply_BHNodeAddress{} }
func (m *MsgQueryTopicReply_BHNodeAddress) String() string { return proto.CompactTextString(m) }
func (*MsgQueryTopicReply_BHNodeAddress) ProtoMessage()    {}
func (*MsgQueryTopicReply_BHNodeAddress) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{11, 0}
}

func (m *MsgQueryTopicReply_BHNodeAddress) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgQueryTopicReply_BHNodeAddress.Unmarshal(m, b)
}
func (m *MsgQueryTopicReply_BHNodeAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgQueryTopicReply_BHNodeAddress.Marshal(b, m, deterministic)
}
func (m *MsgQueryTopicReply_BHNodeAddress) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgQueryTopicReply_BHNodeAddress.Merge(m, src)
}
func (m *MsgQueryTopicReply_BHNodeAddress) XXX_Size() int {
	return xxx_messageInfo_MsgQueryTopicReply_BHNodeAddress.Size(m)
}
func (m *MsgQueryTopicReply_BHNodeAddress) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgQueryTopicReply_BHNodeAddress.DiscardUnknown(m)
}

var xxx_messageInfo_MsgQueryTopicReply_BHNodeAddress proto.InternalMessageInfo

func (m *MsgQueryTopicReply_BHNodeAddress) GetProcId() []byte {
	if m != nil {
		return m.ProcId
	}
	return nil
}

func (m *MsgQueryTopicReply_BHNodeAddress) GetAddr() *BHAddress {
	if m != nil {
		return m.Addr
	}
	return nil
}

type MsgQueryProc struct {
	ProcId               []byte   `protobuf:"bytes,1,opt,name=proc_id,json=procId,proto3" json:"proc_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *MsgQueryProc) Reset()         { *m = MsgQueryProc{} }
func (m *MsgQueryProc) String() string { return proto.CompactTextString(m) }
func (*MsgQueryProc) ProtoMessage()    {}
func (*MsgQueryProc) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{12}
}

func (m *MsgQueryProc) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgQueryProc.Unmarshal(m, b)
}
func (m *MsgQueryProc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgQueryProc.Marshal(b, m, deterministic)
}
func (m *MsgQueryProc) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgQueryProc.Merge(m, src)
}
func (m *MsgQueryProc) XXX_Size() int {
	return xxx_messageInfo_MsgQueryProc.Size(m)
}
func (m *MsgQueryProc) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgQueryProc.DiscardUnknown(m)
}

var xxx_messageInfo_MsgQueryProc proto.InternalMessageInfo

func (m *MsgQueryProc) GetProcId() []byte {
	if m != nil {
		return m.ProcId
	}
	return nil
}

type MsgQueryProcReply struct {
	Errmsg               *ErrorMsg                 `protobuf:"bytes,1,opt,name=errmsg,proto3" json:"errmsg,omitempty"`
	ProcList             []*MsgQueryProcReply_Info `protobuf:"bytes,2,rep,name=proc_list,json=procList,proto3" json:"proc_list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (m *MsgQueryProcReply) Reset()         { *m = MsgQueryProcReply{} }
func (m *MsgQueryProcReply) String() string { return proto.CompactTextString(m) }
func (*MsgQueryProcReply) ProtoMessage()    {}
func (*MsgQueryProcReply) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{13}
}

func (m *MsgQueryProcReply) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgQueryProcReply.Unmarshal(m, b)
}
func (m *MsgQueryProcReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgQueryProcReply.Marshal(b, m, deterministic)
}
func (m *MsgQueryProcReply) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgQueryProcReply.Merge(m, src)
}
func (m *MsgQueryProcReply) XXX_Size() int {
	return xxx_messageInfo_MsgQueryProcReply.Size(m)
}
func (m *MsgQueryProcReply) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgQueryProcReply.DiscardUnknown(m)
}

var xxx_messageInfo_MsgQueryProcReply proto.InternalMessageInfo

func (m *MsgQueryProcReply) GetErrmsg() *ErrorMsg {
	if m != nil {
		return m.Errmsg
	}
	return nil
}

func (m *MsgQueryProcReply) GetProcList() []*MsgQueryProcReply_Info {
	if m != nil {
		return m.ProcList
	}
	return nil
}

type MsgQueryProcReply_Info struct {
	Proc                 *ProcInfo     `protobuf:"bytes,1,opt,name=proc,proto3" json:"proc,omitempty"`
	Online               bool          `protobuf:"varint,2,opt,name=online,proto3" json:"online,omitempty"`
	Topics               *MsgTopicList `protobuf:"bytes,3,opt,name=topics,proto3" json:"topics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (m *MsgQueryProcReply_Info) Reset()         { *m = MsgQueryProcReply_Info{} }
func (m *MsgQueryProcReply_Info) String() string { return proto.CompactTextString(m) }
func (*MsgQueryProcReply_Info) ProtoMessage()    {}
func (*MsgQueryProcReply_Info) Descriptor() ([]byte, []int) {
	return fileDescriptor_a49c9c1f511a168c, []int{13, 0}
}

func (m *MsgQueryProcReply_Info) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MsgQueryProcReply_Info.Unmarshal(m, b)
}
func (m *MsgQueryProcReply_Info) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MsgQueryProcReply_Info.Marshal(b, m, deterministic)
}
func (m *MsgQueryProcReply_Info) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MsgQueryProcReply_Info.Merge(m, src)
}
func (m *MsgQueryProcReply_Info) XXX_Size() int {
	return xxx_messageInfo_MsgQueryProcReply_Info.Size(m)
}
func (m *MsgQueryProcReply_Info) XXX_DiscardUnknown() {
	xxx_messageInfo_MsgQueryProcReply_Info.DiscardUnknown(m)
}

var xxx_messageInfo_MsgQueryProcReply_Info proto.InternalMessageInfo

func (m *MsgQueryProcReply_Info) GetProc() *ProcInfo {
	if m != nil {
		return m.Proc
	}
	return nil
}

func (m *MsgQueryProcReply_Info) GetOnline() bool {
	if m != nil {
		return m.Online
	}
	return false
}

func (m *MsgQueryProcReply_Info) GetTopics() *MsgTopicList {
	if m != nil {
		return m.Topics
	}
	return nil
}

func init() {
	proto.RegisterType((*BHAddress)(nil), "bhome_msg.BHAddress")
	proto.RegisterType((*ProcInfo)(nil), "bhome_msg.ProcInfo")
	proto.RegisterType((*MsgTopicList)(nil), "bhome_msg.MsgTopicList")
	proto.RegisterType((*MsgPublish)(nil), "bhome_msg.MsgPublish")
	proto.RegisterType((*MsgCommonReply)(nil), "bhome_msg.MsgCommonReply")
	proto.RegisterType((*MsgRequestTopic)(nil), "bhome_msg.MsgRequestTopic")
	proto.RegisterType((*MsgRequestTopicReply)(nil), "bhome_msg.MsgRequestTopicReply")
	proto.RegisterType((*MsgRegister)(nil), "bhome_msg.MsgRegister")
	proto.RegisterType((*MsgUnregister)(nil), "bhome_msg.MsgUnregister")
	proto.RegisterType((*MsgHeartbeat)(nil), "bhome_msg.MsgHeartbeat")
	proto.RegisterType((*MsgQueryTopic)(nil), "bhome_msg.MsgQueryTopic")
	proto.RegisterType((*MsgQueryTopicReply)(nil), "bhome_msg.MsgQueryTopicReply")
	proto.RegisterType((*MsgQueryTopicReply_BHNodeAddress)(nil), "bhome_msg.MsgQueryTopicReply.BHNodeAddress")
	proto.RegisterType((*MsgQueryProc)(nil), "bhome_msg.MsgQueryProc")
	proto.RegisterType((*MsgQueryProcReply)(nil), "bhome_msg.MsgQueryProcReply")
	proto.RegisterType((*MsgQueryProcReply_Info)(nil), "bhome_msg.MsgQueryProcReply.Info")
}

func init() { proto.RegisterFile("bhome_msg_api.proto", fileDescriptor_a49c9c1f511a168c) }

var fileDescriptor_a49c9c1f511a168c = []byte{
	// 567 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x54, 0xf1, 0x6b, 0xd3, 0x40,
	0x14, 0x26, 0x6d, 0xd6, 0xb5, 0x2f, 0xd9, 0x8a, 0xd7, 0xe2, 0x62, 0x41, 0xcc, 0x02, 0xb2, 0xc0,
	0x30, 0x83, 0x0a, 0x53, 0x10, 0x05, 0x2b, 0x42, 0x0b, 0x76, 0xcc, 0x43, 0x11, 0xfc, 0x25, 0x24,
	0xcd, 0x2d, 0x3b, 0x68, 0x72, 0xe9, 0xdd, 0x55, 0x1c, 0xfe, 0xbd, 0xfe, 0x13, 0xfe, 0x24, 0x77,
	0x49, 0x63, 0xab, 0x9d, 0xac, 0xfb, 0xed, 0xde, 0xdd, 0xf7, 0x7d, 0xef, 0xf1, 0x3e, 0xbe, 0x83,
	0x5e, 0x7c, 0xcd, 0x32, 0x12, 0x66, 0x22, 0x0d, 0xa3, 0x82, 0x06, 0x05, 0x67, 0x92, 0xa1, 0x4e,
	0x7d, 0x39, 0xe8, 0x12, 0xce, 0x19, 0x57, 0xc7, 0xf2, 0xcd, 0x0b, 0xa1, 0x33, 0x1a, 0xbf, 0x4d,
	0x12, 0x4e, 0x84, 0x40, 0x3d, 0xd8, 0xcb, 0x16, 0x21, 0x4d, 0x1c, 0xc3, 0x35, 0x7c, 0x13, 0x9b,
	0xd9, 0x62, 0x92, 0xa0, 0x47, 0xd0, 0x8e, 0x62, 0x11, 0x46, 0x49, 0xc2, 0x9d, 0x86, 0x6b, 0xf8,
	0x4d, 0xbc, 0x1f, 0xc5, 0x42, 0x51, 0xd0, 0x21, 0x34, 0x68, 0xe1, 0x34, 0x5d, 0xc3, 0xb7, 0x71,
	0x83, 0x16, 0x08, 0x81, 0x59, 0x30, 0x2e, 0x1d, 0xd3, 0x35, 0xfc, 0x3d, 0xac, 0xcf, 0xde, 0x0f,
	0x68, 0x5f, 0x72, 0x36, 0x9b, 0xe4, 0x57, 0x0c, 0x1d, 0xc1, 0x7e, 0xc1, 0xd9, 0x6c, 0xd5, 0xc1,
	0xc6, 0x2d, 0x55, 0x4e, 0x12, 0x45, 0xcc, 0xa3, 0x8c, 0x68, 0x7d, 0x1b, 0xeb, 0x33, 0x7a, 0x02,
	0x56, 0xb1, 0x8c, 0xe7, 0x74, 0x16, 0xd2, 0xfc, 0x8a, 0x55, 0x5d, 0xa0, 0xbc, 0xd2, 0x6a, 0xc7,
	0x60, 0x17, 0x9c, 0x7e, 0x8b, 0x24, 0x29, 0x11, 0xa6, 0x46, 0x58, 0xd5, 0x9d, 0x82, 0x78, 0xcf,
	0xc0, 0x9e, 0x8a, 0xf4, 0x13, 0x2b, 0xe8, 0xec, 0x03, 0x15, 0x12, 0x3d, 0x06, 0x90, 0xaa, 0x08,
	0xe7, 0x54, 0x48, 0xc7, 0x70, 0x9b, 0xbe, 0x8d, 0x3b, 0x72, 0xf5, 0xec, 0x9d, 0x03, 0x4c, 0x45,
	0x7a, 0xa9, 0x5a, 0x88, 0x6b, 0xd4, 0x87, 0x3d, 0xfd, 0x54, 0xcd, 0x5a, 0x16, 0x6a, 0xd4, 0x24,
	0x92, 0xd1, 0x6a, 0x54, 0x75, 0xf6, 0x5e, 0xc3, 0xe1, 0x54, 0xa4, 0xef, 0x58, 0x96, 0xb1, 0x1c,
	0x93, 0x62, 0x7e, 0x83, 0x4e, 0xa1, 0x45, 0x38, 0xcf, 0x44, 0xaa, 0xc9, 0xd6, 0xb0, 0x17, 0xd4,
	0x1e, 0x04, 0xef, 0x95, 0x05, 0x53, 0x91, 0xe2, 0x0a, 0xe2, 0xbd, 0x82, 0xae, 0x2a, 0xc9, 0x62,
	0x49, 0x84, 0xd4, 0xc3, 0xee, 0xd0, 0xfb, 0x0b, 0xf4, 0xff, 0x22, 0xef, 0x3e, 0xc1, 0x56, 0xe1,
	0x73, 0xb0, 0xb4, 0x70, 0x4a, 0x85, 0x24, 0x1c, 0x9d, 0x80, 0xa9, 0xcc, 0xda, 0xa2, 0xb6, 0xb2,
	0x17, 0x6b, 0x80, 0xf7, 0x12, 0x0e, 0xa6, 0x22, 0xfd, 0x9c, 0xf3, 0x9d, 0x99, 0x2f, 0xb4, 0x5b,
	0x63, 0x12, 0x71, 0x19, 0x93, 0x48, 0xde, 0x9d, 0xf8, 0x54, 0xb7, 0xfc, 0xb8, 0x24, 0xfc, 0xe6,
	0x3f, 0xeb, 0xf3, 0x7e, 0x1a, 0x80, 0x36, 0x70, 0xf7, 0xd8, 0xd4, 0x05, 0xd8, 0x39, 0x4b, 0x88,
	0x8e, 0x03, 0x11, 0xc2, 0x69, 0xb8, 0x4d, 0xdf, 0x1a, 0x9e, 0xae, 0x51, 0xfe, 0xed, 0x10, 0x8c,
	0xc6, 0x17, 0x2c, 0x21, 0x55, 0xca, 0xb0, 0x95, 0xff, 0x29, 0x06, 0x18, 0x0e, 0x36, 0x5e, 0x6f,
	0xcf, 0x88, 0x0f, 0x66, 0x9d, 0x41, 0x6b, 0xd8, 0x5f, 0xeb, 0x58, 0x07, 0x18, 0x6b, 0x84, 0x77,
	0xa2, 0xf7, 0xa8, 0x87, 0x50, 0x8b, 0xba, 0x55, 0xd2, 0xfb, 0x65, 0xc0, 0x83, 0x75, 0xe4, 0x3d,
	0xf6, 0xf1, 0x06, 0x3a, 0x5a, 0x5b, 0x07, 0xaa, 0x5c, 0xc6, 0xf1, 0x96, 0x65, 0xd4, 0xea, 0x81,
	0xb6, 0xad, 0xad, 0x38, 0x2a, 0x72, 0x83, 0xef, 0x60, 0xea, 0x30, 0xdf, 0xd5, 0x6b, 0xf4, 0x10,
	0x5a, 0x2c, 0x9f, 0xd3, 0xbc, 0xfc, 0x2c, 0xda, 0xb8, 0xaa, 0xd0, 0x19, 0xb4, 0xb4, 0xcb, 0x42,
	0xff, 0x14, 0xd6, 0xf0, 0x68, 0x73, 0x8a, 0xfa, 0x0f, 0xc0, 0x15, 0x6c, 0xd4, 0x1d, 0x37, 0xbf,
	0x5a, 0xc1, 0x59, 0x8d, 0x8a, 0x5b, 0xfa, 0x47, 0x7c, 0xfe, 0x3b, 0x00, 0x00, 0xff, 0xff, 0xa4,
	0x7b, 0x44, 0x8e, 0x44, 0x05, 0x00, 0x00,
}