This is an automated email from the ASF dual-hosted git repository.
xuzhenbao pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/celix.git
from db148071b Merge pull request #777 from apache/hotfix/mac-upgrade
add 70f69fad8 Add remote event admin based on mqtt
add f586be616 Improve remote event admin provider
add fd380732f Use discovery to announce mqtt broker info
add ed4ca51fd Rename some function name
add 55a365dbe Add some unit test
add 9ffc91591 Improve the interface of celix_earpm_client
add 56172a08f Add unit test for remote_event_admin_mqtt
add b17188eab Add event_admin_spi
add 0cfd805de Get service configuration type from endpoint listener
service socpe property
add d435fabfe Integrate remote provider to event admin
add 7c6f11e0b Improve code and add some comments
add 9f3afbd14 Add README document for the event admin remote provider
based on MQTT
add 7e5be93c4 Add conan testing for the event admin remote provider based
on MQTT
add dd88ad1c7 Revert the code that was submitted by mistake
add 95cdde5a8 Merge branch 'master' of https://github.com/xuzhenbao/celix
into remote_event_admin
add 9df591d69 Merge master into remote_event_admin
add 368045be6 Try to trigger online workflows
add 16402f092 Resolve testing failure of conan_test_package_v2
add 6a8f50054 Add message version verification for remote_provider_mqtt
add 97e161826 Enable verbose output for macos tests
add 54aa33454 Resolve unit test failures in macos
add 39e8ee589 Revert "Enable verbose output for macos tests"
add 8d490bc32 Add debug command for event admin remote provider based on
MQTT
add 65fead377 Resolve issues raised in code reviews
add 295f71afe Merge branch 'apache:master' into remote_event_admin
new 553e2f6a6 Merge pull request #773 from xuzhenbao/remote_event_admin
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
bundles/event_admin/CMakeLists.txt | 2 +
bundles/event_admin/README.md | 3 +-
bundles/event_admin/event_admin/CMakeLists.txt | 1 +
bundles/event_admin/event_admin/README.md | 18 +-
.../diagrams/remote_event_delivery_seq.png | Bin 0 -> 30137 bytes
...ery_seq.puml => remote_event_delivery_seq.puml} | 26 +-
...ixEventAdminActivatorErrorInjectionTestSuite.cc | 30 +-
.../src/CelixEventAdminErrorInjectionTestSuite.cc | 151 ++
.../gtest/src/CelixEventAdminTestSuite.cc | 295 +++-
.../gtest/src/CelixEventAdminTestSuiteBaseClass.h | 19 +-
.../event_admin/src/celix_event_admin.c | 212 ++-
.../event_admin/src/celix_event_admin.h | 3 +
.../event_admin/src/celix_event_admin_activator.c | 22 +
.../include/celix_event_admin_service.h | 2 +-
.../include/celix_event_constants.h | 46 +
.../include/celix_event_handler_service.h | 2 +-
.../CMakeLists.txt | 10 +-
.../include/celix_event_remote_provider_service.h} | 28 +-
bundles/event_admin/examples/CMakeLists.txt | 31 +
.../src/celix_example_event_publisher_activator.c | 17 +
.../event_admin/examples/res/mosquitto.conf | 7 +-
.../event_admin/remote_provider/CMakeLists.txt | 2 +-
bundles/event_admin/remote_provider/README.md | 39 +
.../event_admin_remote_provider_component.png | Bin 0 -> 28352 bytes
.../event_admin_remote_provider_component.puml | 49 +
.../remote_provider_mqtt/CMakeLists.txt | 72 +
.../remote_provider/remote_provider_mqtt/README.md | 127 ++
.../diagrams/mqtt_broker_discovery.png | Bin 0 -> 42879 bytes
.../diagrams/mqtt_broker_discovery.puml | 49 +
.../diagrams/publish_event_seq.png | Bin 0 -> 72618 bytes
.../diagrams/publish_event_seq.puml | 60 +
.../diagrams/reconnect_seq.png | Bin 0 -> 24048 bytes
.../diagrams/reconnect_seq.puml} | 25 +-
.../diagrams/remote_provider_mqtt_component.png | Bin 0 -> 39926 bytes
.../diagrams/remote_provider_mqtt_component.puml | 64 +
.../diagrams/subscribe_event_seq.png | Bin 0 -> 18204 bytes
.../diagrams/subscribe_event_seq.puml} | 17 +-
.../remote_provider_mqtt/gtest/CMakeLists.txt | 104 ++
.../remote_provider_mqtt/gtest/res/mosquitto.conf | 5 +-
.../gtest/res/mosquitto_bind_all_if.conf | 5 +-
.../gtest/res/mosquitto_bind_host.conf | 5 +-
.../gtest/res/mosquitto_bind_host_and_if.conf | 6 +-
.../gtest/res/mosquitto_bind_if.conf | 6 +-
.../gtest/res/mosquitto_bind_if_val_lost.conf | 6 +-
.../gtest/res/mosquitto_bind_unix_socket.conf | 5 +-
.../gtest/res/mosquitto_invalid_listener.conf | 21 +-
.../gtest/res/mosquitto_ipv4.conf | 7 +-
.../gtest/res/mosquitto_ipv6.conf | 7 +-
.../gtest/res/mosquitto_multi_listener.conf | 14 +-
.../res/mosquitto_socket_domain_val_lost.conf | 7 +-
.../gtest/res/mosquitto_start_with_space.conf | 4 +-
.../CelixEarpmActivatorErrorInjectionTestSuite.cc | 252 ++++
.../gtest/src/CelixEarpmActivatorTestSuite.cc} | 33 +-
...xEarpmBrokerDiscoveryErrorInjectionTestSuite.cc | 282 ++++
.../src/CelixEarpmBrokerDiscoveryTestSuite.cc | 317 +++++
.../src/CelixEarpmClientErrorInjectionTestSuite.cc | 749 ++++++++++
.../gtest/src/CelixEarpmClientTestSuite.cc | 915 ++++++++++++
.../gtest/src/CelixEarpmClientTestSuiteBaseClass.h | 228 +++
...ixEarpmEventDelivererErrorInjectionTestSuite.cc | 123 ++
.../gtest/src/CelixEarpmEventDelivererTestSuite.cc | 303 ++++
.../src/CelixEarpmImplErrorInjectionTestSuite.cc | 1080 ++++++++++++++
.../gtest/src/CelixEarpmImplTestSuite.cc | 1031 ++++++++++++++
.../gtest/src/CelixEarpmImplTestSuiteBaseClass.h | 280 ++++
.../gtest/src/CelixEarpmIntegrationTestSuite.cc | 158 +++
.../gtest/src/CelixEarpmTestSuiteBaseClass.h | 100 ++
.../src/celix_earpm_activator.c | 203 +++
.../src/celix_earpm_broker_discovery.c | 461 ++++++
.../src/celix_earpm_broker_discovery.h | 51 +
.../remote_provider_mqtt/src/celix_earpm_client.c | 1249 +++++++++++++++++
.../remote_provider_mqtt/src/celix_earpm_client.h | 104 ++
.../src/celix_earpm_constants.h | 105 ++
.../src/celix_earpm_event_deliverer.c | 265 ++++
.../src/celix_earpm_event_deliverer.h | 53 +
.../remote_provider_mqtt/src/celix_earpm_impl.c | 1477 ++++++++++++++++++++
.../remote_provider_mqtt/src/celix_earpm_impl.h | 60 +
.../src/celix_earpm_mosquitto_cleanup.h | 30 +-
.../gtest/src/DiscoveryZeroconfWatcherTestSuite.cc | 111 ++
.../src/discovery_zeroconf_watcher.c | 169 ++-
cmake/CelixDeps.cmake.in | 2 +
conanfile.py | 32 +-
examples/conan_test_package/CMakeLists.txt | 12 +
examples/conan_test_package/conanfile.py | 5 +
.../test_event_admin_spi.c} | 13 +-
examples/conan_test_package_v2/conanfile.py | 5 +
libs/error_injector/CMakeLists.txt | 5 +
libs/error_injector/jansson/CMakeLists.txt | 1 +
libs/error_injector/jansson/include/jansson_ei.h | 1 +
libs/error_injector/jansson/src/jansson_ei.cc | 11 +
libs/error_injector/mosquitto/CMakeLists.txt | 41 +
.../mosquitto/include/mosquitto_ei.h | 23 +-
libs/error_injector/mosquitto/src/mosquitto_ei.cc | 121 ++
.../src/celix_dm_component_ei.cc | 3 +-
libs/utils/error_injector/CMakeLists.txt | 1 +
.../error_injector/celix_array_list/CMakeLists.txt | 1 +
.../celix_array_list/include/celix_array_list_ei.h | 2 +
.../celix_array_list/src/celix_array_list_ei.cc | 7 +
.../error_injector/celix_filter}/CMakeLists.txt | 13 +-
.../celix_filter/include/celix_filter_ei.h} | 11 +-
.../celix_filter/src/celix_filter_ei.cc | 20 +-
.../error_injector/celix_properties/CMakeLists.txt | 4 +
.../celix_properties/include/celix_properties_ei.h | 5 +-
.../celix_properties/src/celix_properties_ei.cc | 28 +
.../error_injector/celix_threads/CMakeLists.txt | 1 +
.../celix_threads/include/celix_threads_ei.h | 1 +
.../celix_threads/src/celix_threads_ei.cc | 7 +
105 files changed, 11939 insertions(+), 257 deletions(-)
create mode 100644
bundles/event_admin/event_admin/diagrams/remote_event_delivery_seq.png
copy bundles/event_admin/event_admin/diagrams/{sync_delivery_seq.puml =>
remote_event_delivery_seq.puml} (53%)
copy bundles/event_admin/{event_admin_api => event_admin_spi}/CMakeLists.txt
(80%)
copy bundles/event_admin/{event_admin_api/include/celix_event_admin_service.h
=> event_admin_spi/include/celix_event_remote_provider_service.h} (76%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/examples/res/mosquitto.conf (93%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/CMakeLists.txt (95%)
create mode 100644 bundles/event_admin/remote_provider/README.md
create mode 100644
bundles/event_admin/remote_provider/diagrams/event_admin_remote_provider_component.png
create mode 100644
bundles/event_admin/remote_provider/diagrams/event_admin_remote_provider_component.puml
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/CMakeLists.txt
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/README.md
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/diagrams/mqtt_broker_discovery.png
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/diagrams/mqtt_broker_discovery.puml
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/diagrams/publish_event_seq.png
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/diagrams/publish_event_seq.puml
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/diagrams/reconnect_seq.png
copy bundles/event_admin/{event_admin/diagrams/sync_delivery_seq.puml =>
remote_provider/remote_provider_mqtt/diagrams/reconnect_seq.puml} (54%)
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/diagrams/remote_provider_mqtt_component.png
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/diagrams/remote_provider_mqtt_component.puml
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/diagrams/subscribe_event_seq.png
copy bundles/event_admin/{event_admin/diagrams/sync_delivery_seq.puml =>
remote_provider/remote_provider_mqtt/diagrams/subscribe_event_seq.puml} (65%)
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/CMakeLists.txt
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto.conf
(95%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_bind_all_if.conf
(97%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_bind_host.conf
(96%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_bind_host_and_if.conf
(94%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_bind_if.conf
(95%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_bind_if_val_lost.conf
(96%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_bind_unix_socket.conf
(95%)
copy misc/experimental/rust/celix_bindings/Cargo.toml =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_invalid_listener.conf
(78%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_ipv4.conf
(93%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_ipv6.conf
(93%)
copy libs/dfi/error_injector/CMakeLists.txt =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_multi_listener.conf
(84%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_socket_domain_val_lost.conf
(94%)
copy misc/experimental/rust/.gitignore =>
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/res/mosquitto_start_with_space.conf
(96%)
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmActivatorErrorInjectionTestSuite.cc
copy
bundles/event_admin/{event_admin/gtest/src/CelixEventAdminActivatorTestSuite.cc
=>
remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmActivatorTestSuite.cc}
(58%)
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmBrokerDiscoveryErrorInjectionTestSuite.cc
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmBrokerDiscoveryTestSuite.cc
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmClientErrorInjectionTestSuite.cc
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmClientTestSuite.cc
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmClientTestSuiteBaseClass.h
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmEventDelivererErrorInjectionTestSuite.cc
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmEventDelivererTestSuite.cc
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmImplErrorInjectionTestSuite.cc
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmImplTestSuite.cc
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmImplTestSuiteBaseClass.h
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmIntegrationTestSuite.cc
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/gtest/src/CelixEarpmTestSuiteBaseClass.h
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/src/celix_earpm_activator.c
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/src/celix_earpm_broker_discovery.c
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/src/celix_earpm_broker_discovery.h
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/src/celix_earpm_client.c
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/src/celix_earpm_client.h
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/src/celix_earpm_constants.h
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/src/celix_earpm_event_deliverer.c
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/src/celix_earpm_event_deliverer.h
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/src/celix_earpm_impl.c
create mode 100644
bundles/event_admin/remote_provider/remote_provider_mqtt/src/celix_earpm_impl.h
copy libs/framework/include/celix_service_listener.h =>
bundles/event_admin/remote_provider/remote_provider_mqtt/src/celix_earpm_mosquitto_cleanup.h
(62%)
copy examples/{celix-examples/bundle_with_private_lib/tlib/src/test.c =>
conan_test_package/test_event_admin_spi.c} (81%)
create mode 100644 libs/error_injector/mosquitto/CMakeLists.txt
copy bundles/logging/log_helper/error_injector/include/celix_log_helper_ei.h
=> libs/error_injector/mosquitto/include/mosquitto_ei.h (50%)
create mode 100644 libs/error_injector/mosquitto/src/mosquitto_ei.cc
copy libs/{dfi/error_injector/dfi =>
utils/error_injector/celix_filter}/CMakeLists.txt (71%)
copy libs/{error_injector/sys_shm/include/sys_shm_ei.h =>
utils/error_injector/celix_filter/include/celix_filter_ei.h} (85%)
copy
bundles/remote_services/remote_service_admin_shm_v2/rsa_shm/gtest/src/thpool_ei.h
=> libs/utils/error_injector/celix_filter/src/celix_filter_ei.cc (72%)
