org.ice4j.stack

Class MessageProcessingTask

java.lang.Object

org.ice4j.stack.MessageProcessingTask

All Implemented Interfaces:

Runnable

class MessageProcessingTask
extends Object
implements Runnable

The class is used to parse and dispatch incoming messages by being executed by concurrent ExecutorService. To reduce memory allocation this class is designed to be suitable for usage with pooling, the instance of this type is mutable such that RawMessage can be updated and instance can be reused and scheduled with new RawMessage

Author:

Emil Ivov, Yura Yaroshevich

Field Summary

Fields

Modifier and Type	Field and Description
private AtomicBoolean	cancelled Indicates that MessageProcessingTask is cancelled and should not process RawMessage anymore.
private ErrorHandler	errorHandler The listener that will be collecting error notifications.
private static Logger	logger Our class logger.
private MessageEventHandler	messageEventHandler The listener that will be retrieving MessageEvents
private NetAccessManager	netAccessManager The NetAccessManager which has created this instance and which is its owner.
private RawMessage	rawMessage Raw message which is being processed
private Consumer<MessageProcessingTask>	rawMessageProcessedHandler Callback which is invoked when this MessageProcessingTask processed it's rawMessage

Constructor Summary

Constructors

Constructor and Description
MessageProcessingTask(NetAccessManager netAccessManager) Creates a Message processor.

Method Summary

Modifier and Type	Method and Description
void	cancel() Attempts to cancel processing of rawMessage
(package private) void	resetState() Performs proper reset of internal state of pooled instance.
void	run() Does the message parsing.
(package private) void	setMessage(RawMessage message, Consumer<MessageProcessingTask> onProcessed) Assigns the RawMessage that will be processed by this MessageProcessingTask on executor's thread.

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final Logger logger

Our class logger.

cancelled

private final AtomicBoolean cancelled

Indicates that MessageProcessingTask is cancelled and should not process RawMessage anymore.

netAccessManager

private final NetAccessManager netAccessManager

The NetAccessManager which has created this instance and which is its owner.

errorHandler

private final ErrorHandler errorHandler

The listener that will be collecting error notifications.

messageEventHandler

private final MessageEventHandler messageEventHandler

The listener that will be retrieving MessageEvents

rawMessage

private RawMessage rawMessage

Raw message which is being processed

rawMessageProcessedHandler

private Consumer<MessageProcessingTask> rawMessageProcessedHandler

Callback which is invoked when this MessageProcessingTask processed it's rawMessage

Constructor Detail

MessageProcessingTask

MessageProcessingTask(NetAccessManager netAccessManager)
               throws IllegalArgumentException

Creates a Message processor.

Parameters:

netAccessManager - the NetAccessManager which is creating the new instance, is going to be its owner, specifies the MessageEventHandler and represents the ErrorHandler to handle exceptions in the new instance

Throws:

IllegalArgumentException - if any of the mentioned properties of netAccessManager are null

Method Detail

setMessage

void setMessage(RawMessage message,
                Consumer<MessageProcessingTask> onProcessed)

Assigns the RawMessage that will be processed by this MessageProcessingTask on executor's thread.

Parameters:

message - RawMessage to be processed

onProcessed - callback which will be invoked when processing of rawMessage is completed

resetState

void resetState()

Performs proper reset of internal state of pooled instance.

cancel

public void cancel()

Attempts to cancel processing of rawMessage

run

public void run()

Does the message parsing.

Specified by:

run in interface Runnable