Enum Message 

pub enum Message {
    ReqPing(ReqMsgPing),
    RespPing(RespMsgPing),
    ReqAuthorizer(ReqMsgAuthorizer),
    RespAuthorizer(RespMsgAuthorizer),
    ReqSubscribeTopic(ReqMsgSubscriber),
    RespSubscribeTopic(RespMsgSubscriber),
    ReqUnsubscribeTopic(ReqMsgUnsubscriber),
    RespUnsubscribeTopic(RespMsgUnsubscriber),
    ReqPublish(ReqMsgPublish),
    RespPublish(RespMsgPublish),
    ReqSubscribe(ReqMsgSubscribe),
    RespSubscribe(RespMsgSubscribe),
    ReqConsumerTopic(ReqMsgConsumerTopic),
    RespConsumerTopic(RespMsgConsumerTopic),
    ReqUnconsumerTopic(ReqMsgUnconsumerTopic),
    RespUnconsumerTopic(RespMsgUnconsumerTopic),
    ReqPullMessage(ReqPullMessage),
    RespPullMessage(RespPullMessage),
    ReqProduceNormal(ReqMsgProduceNormal),
    ReqProduceOrdered(ReqMsgProduceOrdered),
    ReqProduceDelay(ReqMsgProduceDelay),
    RespProduceNormal(RespMsgProduceNormal),
    RespProduceOrdered(RespMsgProduceOrdered),
    RespProduceDelay(RespMsgProduceDelay),
    ReqConsume(ReqMsgConsume),
    RespConsume(RespMsgConsume),
    ReqConsumeAck(ReqMsgConsumeAck),
    RespConsumeAck(RespMsgConsumeAck),
    ReqConsumeAckMulti(ReqMsgConsumeAckMulti),
    RespConsumeAckMulti(RespMsgConsumeAckMulti),
    ReqReconsumeLater(ReqReconsumeLater),
    RespReconsumeLater(RespReconsumeLater),
    Error(String),
    ReqMessageList(ReqMsgList),
    RespMessageList(RespMsgList),
}

Message for Amq.

Variants

• ReqPing: Request ping.
• RespPing: Response ping.
• ReqAuthorizer: Request authorizer.
• RespAuthorizer: Response authorizer.
• ReqSubscribeTopic: Request subscribe topic.
• RespSubscribeTopic: Response subscribe topic.
• ReqUnsubscribeTopic: Request unsubscribe topic.
• RespUnsubscribeTopic: Response unsubscribe topic.
• ReqPublish: Request publish message.
• RespPublish: Response publish message.
• ReqSubscribe: Request subscribe message.
• RespSubscribe: Response subscribe message.
• ReqConsumerTopic: Request consumer topic.
• RespConsumerTopic: Response consumer topic.
• ReqUnconsumerTopic: Request unconsumer topic.
• RespUnconsumerTopic: Response unconsumer topic.
• ReqPullMessage: Request pull message.
• RespPullMessage: Response pull message.
• ReqProduceNormal: Request produce normal message.
• ReqProduceOrdered: Request produce ordered message.
• ReqProduceDelay: Request produce delay message.
• RespProduceNormal: Response produce normal message.
• RespProduceOrdered: Response produce ordered message.
• RespProduceDelay: Response produce delay message.
• ReqConsume: Request consume message.
• RespConsume: Response consume message.
• ReqConsumeAck: Request consume ack message.
• RespConsumeAck: Response consume ack message.
• ReqConsumeAckMulti: Request consume ack multi message.
• RespConsumeAckMulti: Response consume ack multi message.
• ReqReconsumeLater: Request reconsume later message.
• RespReconsumeLater: Response reconsume later message.
• Error: Error message.
• ReqMessageList: Request message list.
• RespMessageList: Response message list.

Variants

ReqPing(ReqMsgPing)

RespPing(RespMsgPing)

ReqAuthorizer(ReqMsgAuthorizer)

RespAuthorizer(RespMsgAuthorizer)

ReqSubscribeTopic(ReqMsgSubscriber)

RespSubscribeTopic(RespMsgSubscriber)

ReqUnsubscribeTopic(ReqMsgUnsubscriber)

RespUnsubscribeTopic(RespMsgUnsubscriber)

ReqPublish(ReqMsgPublish)

RespPublish(RespMsgPublish)

ReqSubscribe(ReqMsgSubscribe)

RespSubscribe(RespMsgSubscribe)

ReqConsumerTopic(ReqMsgConsumerTopic)

RespConsumerTopic(RespMsgConsumerTopic)

ReqUnconsumerTopic(ReqMsgUnconsumerTopic)

RespUnconsumerTopic(RespMsgUnconsumerTopic)

ReqPullMessage(ReqPullMessage)

RespPullMessage(RespPullMessage)

ReqProduceNormal(ReqMsgProduceNormal)

ReqProduceOrdered(ReqMsgProduceOrdered)

ReqProduceDelay(ReqMsgProduceDelay)

RespProduceNormal(RespMsgProduceNormal)

RespProduceOrdered(RespMsgProduceOrdered)

RespProduceDelay(RespMsgProduceDelay)

ReqConsume(ReqMsgConsume)

RespConsume(RespMsgConsume)

ReqConsumeAck(ReqMsgConsumeAck)

RespConsumeAck(RespMsgConsumeAck)

ReqConsumeAckMulti(ReqMsgConsumeAckMulti)

RespConsumeAckMulti(RespMsgConsumeAckMulti)

ReqReconsumeLater(ReqReconsumeLater)

RespReconsumeLater(RespReconsumeLater)

Error(String)

ReqMessageList(ReqMsgList)

RespMessageList(RespMsgList)

Implementations

impl Message

pub fn serialize(&self) -> Result<Vec<u8>, Box<dyn Error>>

pub fn deserialize(bytes: &[u8]) -> Result<Self, Box<dyn Error>>

Trait Implementations

impl<'__de, __Context> BorrowDecode<'__de, __Context> for Message

fn borrow_decode<__D: BorrowDecoder<'__de, Context = __Context>>( decoder: &mut __D, ) -> Result<Self, DecodeError>

Attempt to decode this type with the given BorrowDecode.

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Message

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<__Context> Decode<__Context> for Message

fn decode<__D: Decoder<Context = __Context>>( decoder: &mut __D, ) -> Result<Self, DecodeError>

Attempt to decode this type with the given Decode.

impl<'de> Deserialize<'de> for Message

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Encode for Message

fn encode<__E: Encoder>(&self, encoder: &mut __E) -> Result<(), EncodeError>

Encode a given type.

impl PartialEq for Message

fn eq(&self, _other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Message

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for Message