public class Worker extends Thread $\{$

private Queue queue;

private ClosedCaptioningListener listener;

public Worker$($Queue queue, ClosedCaptioningListener listener$)\{$

this.queue $=$ queue;

this.listener $=$ listener;

$\}$

@Override

public void run$()\{$

while $($true$)\{$

$//$ Get a recording from the queue

Recording recording $=$ queue.poll$()$;

$//$ If there is no recording in the queue, break

if $($recording $==$ null$)\{$

break;

$\}$

$//$ Process the recording

$//...$

$//$ Set the closed captioning for the recording

recording.setClosedCaptioning$("$Closed captioning for recording $"+$ recording.getId$())$;

$//$ Call the listener to update the recording with the closed captioning

listener.onClosedCaptioning$($recording$)$;

$\}$

$\}$

$\}$

public interface ClosedCaptioningListener $\{$

void onClosedCaptioning$($Recording recording$)$;

$\}$

To use the callback actions, we can create a listener and pass it to the closed captioning controller:

ClosedCaptioningListener listener $=$ new ClosedCaptioningListener$()\{$

@Override

public void onClosedCaptioning$($Recording recording$)\{$

$//$ Update the recording with the closed captioning

$//...$

$\}$

$\}$;

ClosedCaptioningController controller $=$ new ClosedCaptioningController$($queue$,$ listener$)$; give me code with class name