Dart Documentation › mongo_dart › MongoMessage

MongoMessage class 

class MongoMessage{
 static final Reply = 1;
 static final Message = 1000;
 static final Update = 2001;
 static final Insert = 2002;
 static final Query = 2004;
 static final GetMore = 2005;
 static final Delete = 2006;
 static final KillCursors = 2007;
 int _messageLength;
 int _requestId;
 int get requestId{
   if (_requestId == null){
     _requestId = _Statics.nextRequestId;
   }
   return _requestId;
 }
 int responseTo;
 int opcode = MongoMessage.Reply;
 int get messageLength{
   throw new MongoDartError('Must be implemented');
 }
 BsonBinary serialize(){
   throw new MongoDartError('Must be implemented');
 }
 MongoMessage deserialize(BsonBinary buffer){
   throw new MongoDartError('Must be implemented');
 }
 readMessageHeaderFrom(BsonBinary buffer)
 {
     _messageLength = buffer.readInt32();
     _requestId = buffer.readInt32();
     responseTo = buffer.readInt32();
     int opcodeFromWire = buffer.readInt32();
     if (opcodeFromWire != opcode)
     {
         throw new MongoDartError('Expected $opcode in Message header. Got $opcodeFromWire');
     }
 }

 writeMessageHeaderTo(BsonBinary buffer)
 {
     buffer.writeInt(messageLength); // messageLength will be backpatched later
     buffer.writeInt(requestId);
     buffer.writeInt(0); // responseTo not used in requests sent by client
     buffer.writeInt(opcode);
     if (messageLength < 0){
       throw new MongoDartError('Error in message length');
     }
 }
 String toString(){
   throw new MongoDartError('must be implemented');
 }

}

Subclasses

MongoGetMoreMessage, MongoInsertMessage, MongoKillCursorsMessage, MongoQueryMessage, MongoRemoveMessage, MongoReplyMessage, MongoUpdateMessage

Static Properties

final Delete # 

static final Delete = 2006

final GetMore # 

static final GetMore = 2005

final Insert # 

static final Insert = 2002

final KillCursors # 

static final KillCursors = 2007

final Message # 

static final Message = 1000

final Query # 

static final Query = 2004

final Reply # 

static final Reply = 1

final Update # 

static final Update = 2001

Properties

final int messageLength # 

int get messageLength{
 throw new MongoDartError('Must be implemented');
}

int opcode # 

int opcode = MongoMessage.Reply

final int requestId # 

int get requestId{
 if (_requestId == null){
   _requestId = _Statics.nextRequestId;
 }
 return _requestId;
}

int responseTo # 

int responseTo

Methods

MongoMessage deserialize(BsonBinary buffer) #

MongoMessage deserialize(BsonBinary buffer){
 throw new MongoDartError('Must be implemented');
}

dynamic readMessageHeaderFrom(BsonBinary buffer) #

readMessageHeaderFrom(BsonBinary buffer)
{
   _messageLength = buffer.readInt32();
   _requestId = buffer.readInt32();
   responseTo = buffer.readInt32();
   int opcodeFromWire = buffer.readInt32();
   if (opcodeFromWire != opcode)
   {
       throw new MongoDartError('Expected $opcode in Message header. Got $opcodeFromWire');
   }
}

BsonBinary serialize() #

BsonBinary serialize(){
 throw new MongoDartError('Must be implemented');
}

String toString() #

Returns a string representation of this object.

docs inherited from Object 
String toString(){
 throw new MongoDartError('must be implemented');
}

dynamic writeMessageHeaderTo(BsonBinary buffer) #

writeMessageHeaderTo(BsonBinary buffer)
{
   buffer.writeInt(messageLength); // messageLength will be backpatched later
   buffer.writeInt(requestId);
   buffer.writeInt(0); // responseTo not used in requests sent by client
   buffer.writeInt(opcode);
   if (messageLength < 0){
     throw new MongoDartError('Error in message length');
   }
}