Package | Description |
---|---|
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 |
---|---|
protected void |
AbstractSocketConnection.reply(Reply reply,
PendingMessage pendingMessage)
Updates to set the reply for the callback, if any.
|
protected void |
AbstractSocketConnection.send(PendingMessage pendingMessage,
RandomAccessOutputStream message)
Sends a single message.
|
Modifier and Type | Method and Description |
---|---|
boolean |
PendingMessageQueue.offer(PendingMessage pendingMessage)
Puts a message onto the queue.
|
boolean |
PendingMessageQueue.poll(PendingMessage copyOut)
Returns the next message from the queue without blocking.
|
void |
PendingMessageQueue.put(PendingMessage pendingMessage)
Puts a message onto the queue.
|
void |
PendingMessage.set(PendingMessage other)
Sets the state of the pending message.
|
void |
PendingMessageQueue.take(PendingMessage copyOut)
Returns the next message from the queue and will block waiting for a
message.
|
Modifier and Type | Method and Description |
---|---|
void |
PendingMessageQueue.drainTo(List<PendingMessage> pending)
Drains the list of pending messages into the provided list.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.