Class NetMQMessageCodec
Implements
Inherited Members
Namespace: Libplanet.Net.Messages
Assembly: Libplanet.Net.dll
Syntax
public class NetMQMessageCodec : IMessageCodec<NetMQMessage>
Constructors
| Improve this Doc View SourceNetMQMessageCodec()
Creates a NetMQMessageCodec instance.
Declaration
public NetMQMessageCodec()
Fields
| Improve this Doc View SourceCommonFrames
Declaration
public static readonly int CommonFrames
Field Value
Type | Description |
---|---|
Int32 |
Methods
| Improve this Doc View SourceDecode(NetMQMessage, Boolean)
Decodes given encoded
into
Message and checks its validity.
Encode(MessageContent, PrivateKey, AppProtocolVersion, BoundPeer, DateTimeOffset, Byte[])
Declaration
public Message Decode(NetMQMessage encoded, bool reply)
Parameters
Type | Name | Description |
---|---|---|
NetMQ.NetMQMessage | encoded | |
Boolean | reply | A flag to express whether the target is a reply of other message. |
Returns
Type | Description |
---|---|
Message | A Message parsed from |
Exceptions
Type | Condition |
---|---|
ArgumentException | Thrown when empty |
InvalidMessageSignatureException | Thrown when the signer of
|
Encode(MessageContent, PrivateKey, AppProtocolVersion, BoundPeer, DateTimeOffset, Byte[])
Encodes the message to privateKey
and peer
.
Declaration
public NetMQMessage Encode(MessageContent content, PrivateKey privateKey, AppProtocolVersion appProtocolVersion, BoundPeer peer, DateTimeOffset timestamp, byte[] identity = null)
Parameters
Type | Name | Description |
---|---|---|
MessageContent | content | The message body to encode. |
PrivateKey | privateKey | The PrivateKey to sign the encoded message. |
AppProtocolVersion | appProtocolVersion | The AppProtocolVersion of the transport layer. |
BoundPeer | peer | The BoundPeer-typed representation of the transport layer. AsPeer |
DateTimeOffset | timestamp | The DateTimeOffset of the time
|
Byte[] | identity | The byte array identifies the message to match between message and its respond used in NetMQ. |
Returns
Type | Description |
---|---|
NetMQ.NetMQMessage | A |
Exceptions
Type | Condition |
---|---|
InvalidCredentialException | Thrown when |
ParseMessageType(NetMQMessage, Boolean)
Parses a MessageContent.MessageType from given NetMQ.NetMQMessage.
Declaration
public MessageContent.MessageType ParseMessageType(NetMQMessage encoded, bool reply)
Parameters
Type | Name | Description |
---|---|---|
NetMQ.NetMQMessage | encoded | A encoded NetMQ.NetMQMessage. |
Boolean | reply | A flag to express whether the target is a reply of other message. |
Returns
Type | Description |
---|---|
MessageContent.MessageType | Returns a MessageContent.MessageType of given
|
Exceptions
Type | Condition |
---|---|
IndexOutOfRangeException | Thrown if given NetMQ.NetMQMessage has not enough NetMQ.NetMQFrame for parsing a message type. |