Package | Description |
---|---|
com.allanbank.mongodb.connection |
Provides interfaces for managing connections to different MongoDB server configurations.
|
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 |
---|---|
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 | Field and Description |
---|---|
protected BlockingQueue<PendingMessage> |
SocketConnection.myPendingQueue
The queue of messages sent but waiting for a reply.
|
protected BlockingQueue<PendingMessage> |
SocketConnection.myToSendQueue
The queue of messages to be sent.
|
Modifier and Type | Method and Description |
---|---|
protected void |
SocketConnection.doSend(PendingMessage message)
Sends a single message to the connection.
|
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-2012 Allanbank Consulting, Inc.. All Rights Reserved.