Package org.red5.server.net.rtmp

Class ReceivedMessageTask

java.lang.Object

org.red5.server.net.rtmp.ReceivedMessageTask

All Implemented Interfaces:

Callable<Packet>

public final class ReceivedMessageTask
extends Object
implements Callable<Packet>

Wraps processing of incoming messages.

Author:

Paul Gregoire (mondain@gmail.com)

Field Summary

Fields

Modifier and Type	Field	Description
private final RTMPConnection	conn
private ScheduledFuture<Runnable>	deadlockFuture
private final IRTMPHandler	handler
private static final org.slf4j.Logger	log
private Packet	packet
private long	packetNumber
private final AtomicBoolean	processing
private final String	sessionId
private Thread	taskThread

Constructor Summary

Constructors

Constructor	Description
ReceivedMessageTask(String sessionId, Packet packet, IRTMPHandler handler, RTMPConnection conn)

Method Summary

Modifier and Type	Method	Description
Packet	call()
void	cancelDeadlockFuture()	Cancels deadlock future if it was created
boolean	equals(Object obj)
Packet	getPacket()
long	getPacketNumber()
Thread	getTaskThread()
int	hashCode()
void	runDeadlockFuture(Runnable deadlockGuardTask)	Runs deadlock guard task
void	setPacketNumber(long packetNumber)
boolean	setProcessing()	Marks task as processing if it is not processing yet.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

log

private static final org.slf4j.Logger log

conn

private final RTMPConnection conn

handler

private final IRTMPHandler handler

sessionId

private final String sessionId

packet

private Packet packet

packetNumber

private long packetNumber

processing

private final AtomicBoolean processing

taskThread

private Thread taskThread

deadlockFuture

private ScheduledFuture<Runnable> deadlockFuture

Constructor Details

ReceivedMessageTask

public ReceivedMessageTask(String sessionId,
 Packet packet,
 IRTMPHandler handler,
 RTMPConnection conn)

Method Details

call

public Packet call()
            throws Exception

Specified by:

call in interface Callable<Packet>

Throws:

Exception

runDeadlockFuture

public void runDeadlockFuture(Runnable deadlockGuardTask)

Runs deadlock guard task

Parameters:

deadlockGuardTask - deadlock guard task

cancelDeadlockFuture

public void cancelDeadlockFuture()

Cancels deadlock future if it was created

setProcessing

public boolean setProcessing()

Marks task as processing if it is not processing yet.

Returns:

true if successful, or false otherwise

getPacketNumber

public long getPacketNumber()

setPacketNumber

public void setPacketNumber(long packetNumber)

getPacket

public Packet getPacket()

getTaskThread

public Thread getTaskThread()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object