public class DBTCPConnector extends java.lang.Object implements DBConnector
Constructor and Description |
---|
DBTCPConnector(Mongo m,
java.util.List<ServerAddress> all) |
DBTCPConnector(Mongo m,
ServerAddress... all) |
DBTCPConnector(Mongo m,
ServerAddress addr) |
Modifier and Type | Method and Description |
---|---|
com.mongodb.Response |
call(DB db,
DBCollection coll,
com.mongodb.OutMessage m)
does a read operation on the database
|
com.mongodb.Response |
call(DB db,
DBCollection coll,
com.mongodb.OutMessage m,
ServerAddress hostNeeded)
does a read operation on the database
|
com.mongodb.Response |
call(DB db,
DBCollection coll,
com.mongodb.OutMessage m,
ServerAddress hostNeeded,
int retries)
does a read operation on the database
|
void |
close() |
java.lang.String |
debugString() |
ServerAddress |
getAddress() |
java.util.List<ServerAddress> |
getAllAddress()
Gets the list of seed server addresses
|
java.lang.String |
getConnectPoint() |
DBPortPool |
getDBPortPool(ServerAddress addr)
Gets the DBPortPool associated with a ServerAddress.
|
int |
getMaxBsonObjectSize()
Gets the maximum size for a BSON object supported by the current master server.
|
ReplicaSetStatus |
getReplicaSetStatus() |
java.util.List<ServerAddress> |
getServerAddressList()
Gets the list of server addresses currently seen by the connector.
|
boolean |
isOpen()
returns true if the connector is in a usable state
|
void |
requestDone()
End the current "request", if this thread is in one.
|
void |
requestEnsureConnection()
Ensures that a connection exists for the "consistent request"
|
void |
requestStart()
Start a "request".
|
WriteResult |
say(DB db,
com.mongodb.OutMessage m,
WriteConcern concern)
does a write operation
|
WriteResult |
say(DB db,
com.mongodb.OutMessage m,
WriteConcern concern,
ServerAddress hostNeeded)
does a write operation
|
void |
start() |
void |
updatePortPool(ServerAddress addr)
Assigns a new DBPortPool for a given ServerAddress.
|
public DBTCPConnector(Mongo m, ServerAddress addr) throws MongoException
MongoException
public DBTCPConnector(Mongo m, ServerAddress... all) throws MongoException
MongoException
public DBTCPConnector(Mongo m, java.util.List<ServerAddress> all) throws MongoException
MongoException
public void start()
public void requestStart()
requestStart
in interface DBConnector
public void requestDone()
requestDone
in interface DBConnector
public void requestEnsureConnection()
DBConnector
requestEnsureConnection
in interface DBConnector
public WriteResult say(DB db, com.mongodb.OutMessage m, WriteConcern concern) throws MongoException
DBConnector
say
in interface DBConnector
db
- the databasem
- the request messageconcern
- the write concernMongoException
public WriteResult say(DB db, com.mongodb.OutMessage m, WriteConcern concern, ServerAddress hostNeeded) throws MongoException
DBConnector
say
in interface DBConnector
db
- the databasem
- the request messageconcern
- the write concernhostNeeded
- specific server to connect toMongoException
public com.mongodb.Response call(DB db, DBCollection coll, com.mongodb.OutMessage m) throws MongoException
DBConnector
call
in interface DBConnector
db
- the databasecoll
- the collectionm
- the request messageMongoException
public com.mongodb.Response call(DB db, DBCollection coll, com.mongodb.OutMessage m, ServerAddress hostNeeded) throws MongoException
DBConnector
call
in interface DBConnector
db
- the databasecoll
- the collectionm
- the request messagehostNeeded
- specific server to connect toMongoException
public com.mongodb.Response call(DB db, DBCollection coll, com.mongodb.OutMessage m, ServerAddress hostNeeded, int retries) throws MongoException
DBConnector
call
in interface DBConnector
db
- the databasecoll
- the collectionm
- the request messagehostNeeded
- specific server to connect toretries
- number of retries in case of errorMongoException
public ServerAddress getAddress()
public java.util.List<ServerAddress> getAllAddress()
public java.util.List<ServerAddress> getServerAddressList()
public ReplicaSetStatus getReplicaSetStatus()
public java.lang.String getConnectPoint()
public java.lang.String debugString()
public void close()
public void updatePortPool(ServerAddress addr)
addr
- public DBPortPool getDBPortPool(ServerAddress addr)
addr
- public boolean isOpen()
DBConnector
isOpen
in interface DBConnector
public int getMaxBsonObjectSize()