mirror of
https://github.com/espressif/esp-protocols.git
synced 2025-10-05 02:51:09 +02:00
54 lines
1.2 KiB
C
54 lines
1.2 KiB
C
/*
|
|
* SPDX-FileCopyrightText: 2024 Roger Light <roger@atchoo.org>
|
|
*
|
|
* SPDX-License-Identifier: EPL-2.0
|
|
*
|
|
* SPDX-FileContributor: 2024 Espressif Systems (Shanghai) CO LTD
|
|
*/
|
|
#include "mosquitto_internal.h"
|
|
#include "mosquitto_broker.h"
|
|
#include "memory_mosq.h"
|
|
#include "mqtt_protocol.h"
|
|
#include "send_mosq.h"
|
|
#include "util_mosq.h"
|
|
#include "utlist.h"
|
|
#include "lib_load.h"
|
|
#include "mosq_broker.h"
|
|
|
|
mosq_message_cb_t g_mosq_message_callback = NULL;
|
|
|
|
int mosquitto_callback_register(
|
|
mosquitto_plugin_id_t *identifier,
|
|
int event,
|
|
MOSQ_FUNC_generic_callback cb_func,
|
|
const void *event_data,
|
|
void *userdata)
|
|
{
|
|
return MOSQ_ERR_INVAL;
|
|
}
|
|
|
|
int mosquitto_callback_unregister(
|
|
mosquitto_plugin_id_t *identifier,
|
|
int event,
|
|
MOSQ_FUNC_generic_callback cb_func,
|
|
const void *event_data)
|
|
{
|
|
return MOSQ_ERR_INVAL;
|
|
}
|
|
|
|
void plugin__handle_tick(void)
|
|
{
|
|
}
|
|
|
|
void plugin__handle_disconnect(struct mosquitto *context, int reason)
|
|
{
|
|
}
|
|
|
|
int plugin__handle_message(struct mosquitto *context, struct mosquitto_msg_store *stored)
|
|
{
|
|
if (g_mosq_message_callback) {
|
|
g_mosq_message_callback(context->id, stored->topic, stored->payload, stored->payloadlen, stored->qos, stored->retain);
|
|
}
|
|
return MOSQ_ERR_SUCCESS;
|
|
}
|