org.rifidi.edge.sensors.sessions

Class QueueingMessageProcessingStrategy

java.lang.Object

org.rifidi.edge.sensors.sessions.QueueingMessageProcessingStrategy

All Implemented Interfaces:

MessageProcessingStrategy

public class QueueingMessageProcessingStrategy
extends java.lang.Object
implements MessageProcessingStrategy

An implementation of MessageProcessingStrategy that puts incoming messages on a queue

Author:

Jochen Mader - jochen@pramari.com, Kyle Neumeier - kyle@pramri.com

Constructor Summary

Constructors

Constructor and Description
QueueingMessageProcessingStrategy(java.util.Queue<ByteMessage> messageQueue) Constructor.

Method Summary

Modifier and Type	Method and Description
void	processMessage(byte[] message) A hook to allow implementations to do do something with the message when it has been completely received from the socket

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueingMessageProcessingStrategy

public QueueingMessageProcessingStrategy(java.util.Queue<ByteMessage> messageQueue)

Constructor.

Parameters:

socket -

messageQueue -

Method Detail

processMessage

public void processMessage(byte[] message)

Description copied from interface: MessageProcessingStrategy

A hook to allow implementations to do do something with the message when it has been completely received from the socket

Specified by:

processMessage in interface MessageProcessingStrategy

Parameters:

message - The complete message