diff options
author | wsliwka <wojciech.sliwka@nokia.com> | 2019-11-20 13:20:08 +0100 |
---|---|---|
committer | Morgan Richomme <morgan.richomme@orange.com> | 2020-01-27 15:04:55 +0000 |
commit | 86e0740ff36b97ba98f1ed02f34bfb23d1b96262 (patch) | |
tree | 9e579fd898dff23f8ebba24cae2e4b50340cf758 /test/mocks/pnfsimulator/netconfsimulator/netopeer-change-saver-native/KafkaWrapper.h | |
parent | 6f2913b0129ea48becccfd55eeb93cbcb991f651 (diff) |
Latest changes to pnf simulator
- replace cpp bindings by python
- remove docker spotify plugin (no longer supported)
- create own image for netopeer (with all packages installed upfront)
Issue-ID: INT-1372
Signed-off-by: wsliwka <wojciech.sliwka@nokia.com>
Change-Id: I983c0eddf12fa589fbf3ad1ffbab2b36929c9ef0
Diffstat (limited to 'test/mocks/pnfsimulator/netconfsimulator/netopeer-change-saver-native/KafkaWrapper.h')
-rw-r--r-- | test/mocks/pnfsimulator/netconfsimulator/netopeer-change-saver-native/KafkaWrapper.h | 44 |
1 files changed, 0 insertions, 44 deletions
diff --git a/test/mocks/pnfsimulator/netconfsimulator/netopeer-change-saver-native/KafkaWrapper.h b/test/mocks/pnfsimulator/netconfsimulator/netopeer-change-saver-native/KafkaWrapper.h deleted file mode 100644 index 804afa758..000000000 --- a/test/mocks/pnfsimulator/netconfsimulator/netopeer-change-saver-native/KafkaWrapper.h +++ /dev/null @@ -1,44 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Simulator - * ================================================================================ - * Copyright (C) 2019 Nokia. 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. - * ============LICENSE_END========================================================= - */ - -#ifndef NETOPEER_CHANGE_SAVER_CPP_KAFKAWRAPPER_H -#define NETOPEER_CHANGE_SAVER_CPP_KAFKAWRAPPER_H -#include "librdkafka/rdkafka.h" -#include <string> - -class KafkaWrapper { -private: - char errstr[512]; - const char *brokers; - const char *topic_name; - rd_kafka_t *rk; - rd_kafka_topic_t *rkt; - rd_kafka_conf_t *conf; - - void init(); - -public: - KafkaWrapper(const char *brokers, const char *topic_name); - ~KafkaWrapper(); - void kafka_send_message(std::string message); -}; - - -#endif //NETOPEER_CHANGE_SAVER_CPP_KAFKAWRAPPER_H |