Details
Description
CouchbaseConnectionFactoryBuilder cfb = new CouchbaseConnectionFactoryBuilder();
cfb.setOpTimeout(10000); // wait up to 10 seconds for an operation to succeed
cfb.setOpQueueMaxBlockTime(5000); // wait up to 5 seconds when trying to enqueue an operation
For example, will fill up the funnel (the blocking queue) to the rim, but not overflow (immediately timeout). Once it's at the rim, it'll have to wait to wait until at least one operation flows out to add another operation. This *will* slow down the callers (their async calls will actually block on this internal queue), but that's okay in a bulk loader.
However, there are no unit tests in couchbase-client to test this.
cfb.setOpTimeout(10000); // wait up to 10 seconds for an operation to succeed
cfb.setOpQueueMaxBlockTime(5000); // wait up to 5 seconds when trying to enqueue an operation
For example, will fill up the funnel (the blocking queue) to the rim, but not overflow (immediately timeout). Once it's at the rim, it'll have to wait to wait until at least one operation flows out to add another operation. This *will* slow down the callers (their async calls will actually block on this internal queue), but that's okay in a bulk loader.
However, there are no unit tests in couchbase-client to test this.
Activity
Raghavan Srinivas
made changes -
| Field | Original Value | New Value |
|---|---|---|
| Status | Open [ 1 ] | Resolved [ 5 ] |
| Fix Version/s | 1.1 [ 10274 ] | |
| Resolution | Fixed [ 1 ] |
Raghavan Srinivas
made changes -
| Resolution | Fixed [ 1 ] | |
| Status | Resolved [ 5 ] | Reopened [ 4 ] |
Michael Nitschinger
made changes -
| Fix Version/s | 1.1beta [ 10370 ] | |
| Fix Version/s | 1.1 [ 10274 ] |
Matt Ingenthron
made changes -
| Assignee | Raghavan Srinivas [ rags ] | Michael Nitschinger [ daschl ] |
Matt Ingenthron
made changes -
| Fix Version/s | 1.1.0 [ 10274 ] | |
| Fix Version/s | 1.1-beta [ 10370 ] |
Michael Nitschinger
made changes -
| Fix Version/s | 1.1.1 [ 10430 ] | |
| Fix Version/s | 1.1.0 [ 10274 ] |
Michael Nitschinger
made changes -
| Fix Version/s | 1.1.2 [ 10480 ] | |
| Fix Version/s | 1.1.1 [ 10430 ] |
Michael Nitschinger
made changes -
| Fix Version/s | 1.1.3 [ 10496 ] | |
| Fix Version/s | 1.1.2 [ 10480 ] |
Michael Nitschinger
made changes -
| Fix Version/s | 1.1.4 [ 10514 ] | |
| Fix Version/s | 1.1.3 [ 10496 ] |
Michael Nitschinger
made changes -
| Planned Start | (set to new fixed version's start date) | |
| Planned End | (set to new fixed version's start date) |
Michael Nitschinger
made changes -
| Fix Version/s | 1.1.5 [ 10515 ] | |
| Fix Version/s | 1.1.4 [ 10514 ] |
Michael Nitschinger
made changes -
| Planned Start | (set to new fixed version's start date) | |
| Planned End | (set to new fixed version's start date) |
Michael Nitschinger
made changes -
| Fix Version/s | 1.1.6 [ 10531 ] | |
| Fix Version/s | 1.1.5 [ 10515 ] |