Deveel.Data.Protocol.EmbeddedMessageEnvelope Class Reference

Inheritance diagram for Deveel.Data.Protocol.EmbeddedMessageEnvelope:

Public Member Functions
void	SetError (Exception error)

Static Public Member Functions
static EmbeddedMessageEnvelope	Create (int dispatchId, IMessage message)
static EmbeddedMessageEnvelope	Create (IDictionary< string, object > metadata, IMessage message)

Properties
IDictionary< string, object >	Metadata [get, private set]
int	DispatchId [get, private set]
IMessage	Message [get, private set]
ServerError	Error [get, private set]
Properties inherited from Deveel.Data.Protocol.IMessageEnvelope
IDictionary< string, object >	Metadata [get]
IMessage	Message [get]
ServerError	Error [get]

Private Member Functions
	EmbeddedMessageEnvelope (IDictionary< string, object > metadata, IMessage message)

Static Private Attributes
static int	dispatchCounter = -1

Detailed Description

Definition at line 21 of file EmbeddedMessageEnvelope.cs.

Constructor & Destructor Documentation

Deveel.Data.Protocol.EmbeddedMessageEnvelope.EmbeddedMessageEnvelope ( IDictionary< string, object >  metadata, IMessage  message  )

inlineprivate

Definition at line 24 of file EmbeddedMessageEnvelope.cs.

                                                                                                {
            Message = message;
            Metadata = metadata;

            object dispatchId;
            if (!metadata.TryGetValue("DispatchID", out dispatchId))
                throw new ArgumentException("Metadata must specify a Dispatch ID");

            DispatchId = (int) dispatchId;
        }

Member Function Documentation

static EmbeddedMessageEnvelope Deveel.Data.Protocol.EmbeddedMessageEnvelope.Create ( int  dispatchId, IMessage  message  )

inlinestatic

Definition at line 48 of file EmbeddedMessageEnvelope.cs.

                                                                                       {
            var metadata = new Dictionary<string, object>();
            metadata["DispatchID"] = dispatchId;
            return new EmbeddedMessageEnvelope(metadata, message);
        }

static EmbeddedMessageEnvelope Deveel.Data.Protocol.EmbeddedMessageEnvelope.Create ( IDictionary< string, object >  metadata, IMessage  message  )

inlinestatic

Definition at line 54 of file EmbeddedMessageEnvelope.cs.

                                                                                                             {
            if (metadata == null)
                metadata = new Dictionary<string, object>();

            object dispatchId;
            if (!metadata.TryGetValue("DispatchID", out dispatchId))
                dispatchId = dispatchCounter++;

            metadata["DispatchID"] = dispatchId;
            return new EmbeddedMessageEnvelope(metadata, message);
        }

void Deveel.Data.Protocol.EmbeddedMessageEnvelope.SetError ( Exception  error )

inline

Implements Deveel.Data.Protocol.IServerMessageEnvelope.

Definition at line 43 of file EmbeddedMessageEnvelope.cs.

                                              {
            // TODO: in another version there will be support for Class and Code of error
            Error = new ServerError(-1, -1, error.Message);
        }

Member Data Documentation

int Deveel.Data.Protocol.EmbeddedMessageEnvelope.dispatchCounter = -1

staticprivate

Definition at line 22 of file EmbeddedMessageEnvelope.cs.

Property Documentation

int Deveel.Data.Protocol.EmbeddedMessageEnvelope.DispatchId

getprivate set

Definition at line 37 of file EmbeddedMessageEnvelope.cs.

ServerError Deveel.Data.Protocol.EmbeddedMessageEnvelope.Error

getprivate set

Definition at line 41 of file EmbeddedMessageEnvelope.cs.

IMessage Deveel.Data.Protocol.EmbeddedMessageEnvelope.Message

getprivate set

Definition at line 39 of file EmbeddedMessageEnvelope.cs.

IDictionary<string, object> Deveel.Data.Protocol.EmbeddedMessageEnvelope.Metadata

getprivate set

Definition at line 35 of file EmbeddedMessageEnvelope.cs.

---

The documentation for this class was generated from the following file:

• /var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Protocol/EmbeddedMessageEnvelope.cs