BaseOrder.h

Go to the documentation of this file.

/*
 Copyright (2016) Michael Baer, Daniel Bonrath, All rights reserved.

 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
 You may obtain a copy of the License at

 http://www.apache.org/licenses/LICENSE-2.0

 Unless required by applicable law or agreed to in writing, software
 distributed under the License is distributed on an "AS IS" BASIS,
 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 See the License for the specific language governing permissions and
 limitations under the License.
 */

#ifndef __M2ETIS_PUBSUB_ORDER_BASEORDER_H__
#define __M2ETIS_PUBSUB_ORDER_BASEORDER_H__

#include "m2etis/message/info/OrderInfo.h"

#include "m2etis/pubsub/ControlTargets.h"
#include "m2etis/pubsub/MsgProcess.h"

namespace m2etis {
namespace pubsub {
namespace order {

        template<class NetworkType>
        class BaseOrder {
        public:
                BaseOrder(PubSubSystemEnvironment * pssi, bool isRoot) : pssi_(pssi), isRoot_(isRoot), hn(), function_(), sendMsg_() {}
                virtual ~BaseOrder() {}

                void configureCallback(const boost::function<void(uint64_t, msgProcess)> & func) {
                        function_ = func;
                }

                void setHn(const typename NetworkType::Key & self) {
                        hn = self;
                }

                void configureSendCallback(const boost::function<void(message::OrderInfo::Ptr, const typename NetworkType::Key &, ControlTarget)> & func) {
                        sendMsg_ = func;
                }

                void setRoot(bool b) {
                        isRoot_ = b;
                }

                virtual bool hasPending() = 0;

                virtual bool configureOrderInfo(uint64_t id, const message::ActionType mtype, typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key & rec) = 0;

                virtual bool processControlPayload(typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key & sender) = 0;

                virtual void processSubscribePayload(typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key & sender) = 0;

                virtual void processPublishPayload(typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key & sender) = 0;

                virtual void processNotifyPayload(typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key & sender) = 0;

                virtual void receive(uint64_t id, typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key & sender) = 0;

                virtual void notifyRemovedMessage(typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key & receiver) = 0;

        protected:
                PubSubSystemEnvironment * pssi_;

                bool isRoot_;

                typename NetworkType::Key hn;

                boost::function<void(uint64_t, msgProcess)> function_;

                boost::function<void(message::OrderInfo::Ptr, const typename NetworkType::Key &, ControlTarget)> sendMsg_;
        };

} /* namespace order */
} /* namespace pubsub */
} /* namespace m2etis */

#endif /* __M2ETIS_PUBSUB_ORDER_BASEORDER_H__ */