parent
3bda88267b
commit
b7bb3df7c9
|
@ -68,14 +68,21 @@ public class Manager
|
|||
this.watcher = new Watcher(this, socket);
|
||||
}
|
||||
|
||||
// TODO: comment
|
||||
// Starts the watcher
|
||||
/**
|
||||
* Starts the management of the socket,
|
||||
* resulting in queues being updated upon
|
||||
* reciving messages tagged for them
|
||||
*/
|
||||
public void start()
|
||||
{
|
||||
watcher.startWatcher();
|
||||
}
|
||||
|
||||
// Stops the watcher
|
||||
/**
|
||||
* Stops the management of the socket, resulting
|
||||
* in ending the updating of queues and closing
|
||||
* the underlying connection
|
||||
*/
|
||||
public void stop()
|
||||
{
|
||||
watcher.shutdown();
|
||||
|
@ -286,7 +293,6 @@ public class Manager
|
|||
return potentialDefaultQueue;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Returns the default queue
|
||||
*
|
||||
|
|
Loading…
Reference in New Issue