File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed
Original file line numberDiff line numberDiff line change
@@ -1795,7 +1795,7 @@ private boolean canCreateSession() {
17951795
}
17961796
}
17971797

1798-
private void createSessions(final int sessionCount, boolean initialization) {
1798+
private void createSessions(final int sessionCount, boolean distributeOverChannels) {
17991799
logger.log(Level.FINE, String.format("Creating %d sessions", sessionCount));
18001800
synchronized (lock) {
18011801
numSessionsBeingCreated += sessionCount;
@@ -1804,7 +1804,8 @@ private void createSessions(final int sessionCount, boolean initialization) {
18041804
// calls and the session consumer consumes the returned sessions as they become available.
18051805
// The batchCreateSessions method automatically spreads the sessions evenly over all
18061806
// available channels.
1807-
sessionClient.asyncBatchCreateSessions(sessionCount, initialization, sessionConsumer);
1807+
sessionClient.asyncBatchCreateSessions(
1808+
sessionCount, distributeOverChannels, sessionConsumer);
18081809
} catch (Throwable t) {
18091810
// Expose this to customer via a metric.
18101811
numSessionsBeingCreated -= sessionCount;

0 commit comments

Comments
 (0)