manyi/script/pulsar/mqtt_message.py

# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: mqtt.proto
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)

_sym_db = _symbol_database.Default()




DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\nmqtt.proto\x12\x05proto\"F\n\nRawMessage\x12\x18\n\rSchemaVersion\x18\x01 \x02(\x05:\x01\x31\x12\r\n\x05topic\x18\x02 \x01(\t\x12\x0f\n\x07payload\x18\x03 \x01(\x0c\x42\'\n\x1f\x63om.vivestone.common.mqtt.protoB\x04Mqtt')



_RAWMESSAGE = DESCRIPTOR.message_types_by_name['RawMessage']
RawMessage = _reflection.GeneratedProtocolMessageType('RawMessage', (_message.Message,), {
  'DESCRIPTOR' : _RAWMESSAGE,
  '__module__' : 'mqtt_message'
  # @@protoc_insertion_point(class_scope:proto.RawMessage)
  })
_sym_db.RegisterMessage(RawMessage)

if _descriptor._USE_C_DESCRIPTORS == False:

  DESCRIPTOR._options = None
  DESCRIPTOR._serialized_options = b'\n\037com.vivestone.common.mqtt.protoB\004Mqtt'
  _RAWMESSAGE._serialized_start=21
  _RAWMESSAGE._serialized_end=91
# @@protoc_insertion_point(module_scope)