Package | Description |
---|---|
com.allanbank.mongodb.connection |
Provides interfaces for managing connections to different MongoDB server configurations.
|
com.allanbank.mongodb.connection.message |
Low level messages to be sent to the MongoDB server.
|
com.allanbank.mongodb.connection.proxy |
Support for connection that delegate to a lower level connection.
|
com.allanbank.mongodb.connection.socket |
Low level socket connection to a single MongoDB server.
|
Modifier and Type | Method and Description |
---|---|
void |
Connection.addPending(List<PendingMessage> pending)
Adds the pending messages from the specified list.
|
void |
Connection.drainPending(List<PendingMessage> pending)
Removes any to be sent pending messages into the specified list.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractProxyConnection.addPending(List<PendingMessage> pending)
Adds the pending messages from the specified list.
|
void |
AbstractProxyConnection.drainPending(List<PendingMessage> pending)
Removes any to be sent pending messages into the specified list.
|
Modifier and Type | Method and Description |
---|---|
void |
SocketConnection.addPending(List<PendingMessage> pending)
Adds the pending messages from the specified list.
|
void |
SocketConnection.drainPending(List<PendingMessage> pending)
Removes any to be sent pending messages into the specified list.
|
Copyright © 2011-2013 Allanbank Consulting, Inc.. All Rights Reserved.