Skip to content

Commit

Permalink
correct type error from messageQueueLingth to messageQueueLength in s…
Browse files Browse the repository at this point in the history
…erver/common/server-shared/src/main/java/org/kaaproject/kaa/server/thrift/NeighborConnection.java
  • Loading branch information
dou-root committed Mar 22, 2017
1 parent 1cf96fe commit 8ff1b87
Showing 1 changed file with 2 additions and 2 deletions.
Expand Up @@ -92,7 +92,7 @@ public final class NeighborConnection<T extends NeighborTemplate<V>, V> {
/**
* Real maximum number of event messages queue.
*/
private final int messageQueueLingth = DEFAULT_EVENT_MESSAGE_QUEUE_LENGTH;
private final int messageQueueLength = DEFAULT_EVENT_MESSAGE_QUEUE_LENGTH;


private ThriftFactory<OperationsThriftService.Iface> clientFactory;
Expand Down Expand Up @@ -164,7 +164,7 @@ public OperationsThriftService.Iface getClient() {
public synchronized void start() {
if (!started) {
executor = Executors.newFixedThreadPool(maxNumberConnection);
messageQueue = new LinkedBlockingQueue<>(messageQueueLingth);
messageQueue = new LinkedBlockingQueue<>(messageQueueLength);
workers = new LinkedList<>();
clientFactory = ThriftFactory.create(OperationsThriftService.Iface.class);
InetSocketAddress address = new InetSocketAddress(
Expand Down

0 comments on commit 8ff1b87

Please sign in to comment.