org.sdnplatform.sync.internal.rpc
Class RPCService.SyncMessageWorker

java.lang.Object
  org.sdnplatform.sync.internal.rpc.RPCService.SyncMessageWorker

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

RPCService

protected class RPCService.SyncMessageWorker
extends java.lang.Object
implements java.lang.Runnable

A worker thread responsible for reading sync messages off the queue and writing them to the appropriate node's channel. Because calls RPCService.writeToNode(Short, SyncMessage) can block while waiting for available slots in the message window, we do this in a separate thread.

Author:

readams

Constructor Summary

protected

RPCService.SyncMessageWorker()

Method Summary

void

run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RPCService.SyncMessageWorker

protected RPCService.SyncMessageWorker()

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable