package Ġcom . ten k iv . tek da qc . communication . command . queue Ċ Ċ import Ġcom . ten k iv . tek da qc . communication . command . queue . values . AB ase Queue Val Ċ import Ġcom . ten k iv . tek da qc . hardware . AT ek da qc Ċ import Ġcom . ten k iv . tek da qc . utility . T ek da qc Critical Error Ċ import Ġjava . io . Buffered OutputStream Ċ import Ġjava . io . IOException ĊĊ Ċ private Ġval ĠCOMMAND _ WR ITER _ THREAD _ NAME Ġ= Ġ" COMMAND _ WR ITER _ THREAD _ NAME " Ċ Ċ /** Ċ Ġ* ĠClass Ġwhich Ġis Ġexecuted Ġby Ġ[ Command Queue Manager . m Executor ]. ĠWrites Ġout Ġgenerated Ġ[ Byte ] Ġof Ġ[ AB ase Queue Val ] Ċ Ġ* Ġto Ġthe Ġ[ AT ek da qc . get OutputStream ] Ċ Ġ*/ Ċ internal Ġclass ĠCommand Writer Thread ( val Ġtek da qc : ĠAT ek da qc , Ġval Ġm Value : ĠA Base Queue Val ) Ġ: ĊĠĠĠĠĠĠĠ ĠThread ( COMMAND _ WR ITER _ THREAD _ NAME ) Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġrun () Ġ{ ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠwriteTo Stream ( m Value ) ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠIOException ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġtek da qc . critical Error Notification ( T ek da qc Critical Error . TERMIN AL _ CONNECTION _ DIS R UP TION ) ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* ĠMethod Ġto Ġget Ġand Ġwrite Ġout Ġcommand Ġbytes Ġto ĠT el net . ĊĊĠĠĠĠ Ġ* Ġ@ param Ġcommand ĠThe Ġcommand Ġto Ġbe Ġexecuted ĊĠĠĠĠ Ġ* Ġ* ĊĠĠĠĠ Ġ* Ġ@ throws ĠIOException ĠGeneric Ġexception Ġto Ġcatch Ġissues Ġin ĠT el net . ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġ@ Throws ( IOException :: class ) ĊĠĠĠ Ġprivate Ġfun ĠwriteTo Stream ( command : ĠA Base Queue Val ) Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġout Ġ= ĠBuffered OutputStream ( tek da qc . output Stream ) ĊĠĠĠĠĠĠĠ Ġout . write ( command . generate Command Bytes ()) ĊĠĠĠĠĠĠĠ Ġout . flush () ĊĠĠĠ Ġ} Ċ }