BaseDeliver.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_DELIVER_BASEDELIVER_H__
#define __M2ETIS_PUBSUB_DELIVER_BASEDELIVER_H__

#include <string>

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

namespace m2etis {
namespace pubsub {
namespace deliver {

        enum class Amount {
                EXACTLY_ONCE,
                AT_MOST_ONCE,
                AT_LEAST_ONCE
        };
        
        template<class NetworkType>
        class BaseDeliver {
        public:
                explicit BaseDeliver(PubSubSystemEnvironment * pssi) : pssi_(pssi), process_(), sendCtrlMsg_() {}

                virtual ~BaseDeliver() {}

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

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

                virtual void configureDeliverInfo(uint64_t id, const message::ActionType mtype, typename message::DeliverInfo::Ptr ptr, const typename NetworkType::Key & receiver, message::ControlType ct) = 0;

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

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

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

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

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

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

        protected:
                PubSubSystemEnvironment * pssi_;

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

                boost::function<void(message::DeliverInfo::Ptr, typename NetworkType::Key, ControlTarget)> sendCtrlMsg_;
        };

} /* namespace deliver */
} /* namespace pubsub */
} /* namespace m2etis */

#endif /* __M2ETIS_PUBSUB_DELIVER_BASEDELIVER_H__ */