Package | Description |
---|---|
com.allanbank.mongodb.client |
Provides implementations of the main client interfaces and classes to translate the
Reply (s) from the server. |
com.allanbank.mongodb.client.connection.socket |
Low level socket connection to a single MongoDB server.
|
com.allanbank.mongodb.client.message |
Low level messages to be sent to the MongoDB server.
|
Modifier and Type | Method and Description |
---|---|
void |
Message.write(int messageId,
BufferingBsonOutputStream out)
Writes the message from the stream.
|
Modifier and Type | Field and Description |
---|---|
protected BufferingBsonOutputStream |
TwoThreadSocketConnection.myBsonOut
The writer for BSON documents.
|
Constructor and Description |
---|
SocketConnection(Server server,
MongoClientConfiguration config,
StringEncoderCache encoderCache,
StringDecoderCache decoderCache,
ThreadLocal<Reference<BufferingBsonOutputStream>> buffers)
Creates a new SocketConnection to a MongoDB server.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMessage.finishHeader(BufferingBsonOutputStream stream,
long start)
Writes the MsgHeader messageLengthField in the header stream.
|
void |
Delete.write(int messageId,
BufferingBsonOutputStream out)
Writes the message from the stream.
|
void |
Query.write(int messageId,
BufferingBsonOutputStream out)
Writes the message from the stream.
|
void |
GetMore.write(int messageId,
BufferingBsonOutputStream out)
Writes the message from the stream.
|
void |
Reply.write(int messageId,
BufferingBsonOutputStream out)
Writes the message from the stream.
|
void |
KillCursors.write(int messageId,
BufferingBsonOutputStream out)
Writes the message from the stream.
|
void |
Command.write(int messageId,
BufferingBsonOutputStream out)
Writes the message from the stream.
|
void |
Insert.write(int messageId,
BufferingBsonOutputStream out)
Writes the message from the stream.
|
void |
Update.write(int messageId,
BufferingBsonOutputStream out)
Writes the message from the stream.
|
protected long |
AbstractMessage.writeHeader(BufferingBsonOutputStream stream,
int requestId,
int responseTo,
Operation op)
Writes the MsgHeader to the stream.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.