Attachment 20851 Details for Bug 58204 – MQTTClient_publish.c

MQTTClient_publish.c

MQTTClient_publish.c (text/x-csrc), 2.59 KB, created by Новиков Арсений Сергеевич on 2026-03-11 19:20:59 MSK

(hide)

Description:

Filename:

MIME Type:

Creator: Новиков Арсений Сергеевич

Created: 2026-03-11 19:20:59 MSK

Size: 2.59 KB

patch

obsolete

>/*******************************************************************************
> * Copyright (c) 2012, 2025 IBM Corp., Ian Craggs
> *
> * All rights reserved. This program and the accompanying materials
> * are made available under the terms of the Eclipse Public License v2.0
> * and Eclipse Distribution License v1.0 which accompany this distribution. 
> *
> * The Eclipse Public License is available at 
> *   https://www.eclipse.org/legal/epl-2.0/
> * and the Eclipse Distribution License is available at 
> *   http://www.eclipse.org/org/documents/edl-v10.php.
> *
> * Contributors:
> *    Ian Craggs - initial contribution
> *******************************************************************************/
>
>#include <stdio.h>
>#include <stdlib.h>
>#include <string.h>
>#include "MQTTClient.h"
>
>#define ADDRESS     "tcp://test.mosquitto.org:1883"
>#define CLIENTID    "ExampleClientPub"
>#define TOPIC       "MQTT Examples"
>#define PAYLOAD     "Hello World!"
>#define QOS         1
>#define TIMEOUT     10000L
>
>int main(int argc, char* argv[])
>{
>    MQTTClient client;
>    MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
>    MQTTClient_message pubmsg = MQTTClient_message_initializer;
>    MQTTClient_deliveryToken token;
>    int rc;
>
>    const char* uri = (argc > 1) ? argv[1] : ADDRESS;
>    printf("Using server at %s\n", uri);
>
>    if ((rc = MQTTClient_create(&client, uri, CLIENTID,
>        MQTTCLIENT_PERSISTENCE_NONE, NULL)) != MQTTCLIENT_SUCCESS)
>    {
>         printf("Failed to create client, return code %d\n", rc);
>         exit(EXIT_FAILURE);
>    }
>
>    conn_opts.keepAliveInterval = 20;
>    conn_opts.cleansession = 1;
>    if ((rc = MQTTClient_connect(client, &conn_opts)) != MQTTCLIENT_SUCCESS)
>    {
>        printf("Failed to connect, return code %d\n", rc);
>        exit(EXIT_FAILURE);
>    }
>
>    pubmsg.payload = PAYLOAD;
>    pubmsg.payloadlen = (int)strlen(PAYLOAD);
>    pubmsg.qos = QOS;
>    pubmsg.retained = 0;
>    if ((rc = MQTTClient_publishMessage(client, TOPIC, &pubmsg, &token)) != MQTTCLIENT_SUCCESS)
>    {
>         printf("Failed to publish message, return code %d\n", rc);
>         exit(EXIT_FAILURE);
>    }
>
>    printf("Waiting for up to %d seconds for publication of %s\n"
>            "on topic %s for client with ClientID: %s\n",
>            (int)(TIMEOUT/1000), PAYLOAD, TOPIC, CLIENTID);
>    rc = MQTTClient_waitForCompletion(client, token, TIMEOUT);
>    printf("Message with delivery token %d delivered\n", token);
>
>    if ((rc = MQTTClient_disconnect(client, 10000)) != MQTTCLIENT_SUCCESS)
>    	printf("Failed to disconnect, return code %d\n", rc);
>    MQTTClient_destroy(&client);
>    return rc;
>}

Actions: View

Attachments on bug 58204: 20850 | 20851