Package org.red5.server.net.rtmp

Class ReceivedMessageTaskQueue

java.lang.Object

org.red5.server.net.rtmp.ReceivedMessageTaskQueue

public class ReceivedMessageTaskQueue
extends Object

Contains queue of tasks for processing messages in the specified channel. Ensures that all messages which has got in channel will be processed sequentially.

Author:

Maria Chabanets (m.e.platova@gmail.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	ReceivedMessageTaskQueue.DeadlockGuard	Prevents deadlocked message handling.

Field Summary

Fields

Modifier and Type	Field	Description
private final IReceivedMessageTaskQueueListener	listener	Listener which tries to process message from queue if queue has been changed.
private static final org.slf4j.Logger	log
private final int	streamId	Stream id.
private final Queue<ReceivedMessageTask>	tasks	Task queue.

Constructor Summary

Constructors

Constructor	Description
ReceivedMessageTaskQueue(int streamId, IReceivedMessageTaskQueueListener listener)

Method Summary

Modifier and Type	Method	Description
void	addTask(ReceivedMessageTask task)	Adds new task to the end of the queue.
int	getStreamId()
ReceivedMessageTask	getTaskToProcess()	Gets first task from queue if it can be processed.
void	removeAllTasks()	Removes all tasks from the queue.
void	removeTask(ReceivedMessageTask task)	Removes the specified task from the queue.

Methods inherited from class java.lang.Object

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

Field Details

log

private static final org.slf4j.Logger log

streamId

private final int streamId

Stream id.

tasks

private final Queue<ReceivedMessageTask> tasks

Task queue.

listener

private final IReceivedMessageTaskQueueListener listener

Listener which tries to process message from queue if queue has been changed.

Constructor Details

ReceivedMessageTaskQueue

public ReceivedMessageTaskQueue(int streamId,
 IReceivedMessageTaskQueueListener listener)

Method Details

addTask

public void addTask(ReceivedMessageTask task)

Adds new task to the end of the queue.

Parameters:

task - received message task

removeTask

public void removeTask(ReceivedMessageTask task)

Removes the specified task from the queue.

Parameters:

task - received message task

getTaskToProcess

public ReceivedMessageTask getTaskToProcess()

Gets first task from queue if it can be processed. If first task is already in process it returns null.

Returns:

task that can be processed or null otherwise

removeAllTasks

public void removeAllTasks()

Removes all tasks from the queue.

getStreamId

public int getStreamId()