blob: f9111a6b4dc210bbfbd5f2dd60f63ebe8b26f244 [file] [log] [blame]
#ifndef _PRAGMA_COPYRIGHT_
#define _PRAGMA_COPYRIGHT_
#pragma comment(copyright, "%Z% %I% %W% %D% %T%\0")
#endif /* _PRAGMA_COPYRIGHT_ */
/****************************************************************************
* Copyright (c) 2008, 2010 IBM Corporation.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0s
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
Classes: RouterProcessor
Description: Properties of class 'RouterProcessor':
input: a. a stream
b. a message queue
output: a set of message queues
action: route the message to the designated destination
Author: Nicole Nie
History:
Date Who ID Description
-------- --- --- -----------
02/10/09 nieyy Initial code (D153875)
****************************************************************************/
#ifndef _ROUTERPROC_HPP
#define _ROUTERPROC_HPP
#include "sci.h"
#include "processor.hpp"
class MessageQueue;
class RouterProcessor : public Processor
{
private:
MessageQueue *inQueue;
int curFilterID;
sci_group_t curGroup;
public:
RouterProcessor(int hndl = -1);
virtual Message * read();
virtual void process(Message *msg);
virtual void write(Message *msg);
virtual void seize();
virtual void clean();
virtual bool isActive();
int getCurFilterID();
sci_group_t getCurGroup();
void setInQueue(MessageQueue *queue);
};
#endif