I have a sample code of mqtt publisher and
subscriber in paho c. it was working fine. but suddenly
publisher stop to work. it is not publishing data to server.
please have a look into code and help me to resolve
problem.
Thank You.
/*******************************************************************************
* Copyright (c) 2012, 2013 IBM Corp.
*
* All rights reserved. This program and the accompanying
materials
* are made available under the terms of the Eclipse
Public License v1.0
* and Eclipse Distribution License v1.0 which accompany
this distribution.
*
* The Eclipse Public License is available at
* and the Eclipse Distribution License is available at
*
* Contributors:
* Ian Craggs - initial contribution
*******************************************************************************/
#include "stdio.h"
#include "stdlib.h"
#include "string.h"
#include "MQTTAsync.h"
#include "Mqtt_AsyncSample.h"
#if !defined(WIN32)
#include <unistd.h>
#else
#include <windows.h>
#endif
#define CLIENTID "ExampleClientPub"
#define TOPIC "MQTT Examples"
#define PAYLOAD "Hello World!"
#define QOS 1
#define TIMEOUT 10000L
//struct Sample_data *data;
volatile MQTTAsync_token deliveredtoken;
int finished = 0;
void connlost(void *context, char *cause)
{
MQTTAsync
client = (MQTTAsync)context;
MQTTAsync_connectOptions
conn_opts = MQTTAsync_connectOptions_initializer;
int
rc;
printf("\nConnection
lost\n");
printf("
cause: %s\n", cause);
printf("Reconnecting\n");
conn_opts.keepAliveInterval
= 20;
conn_opts.cleansession
= 1;
if
((rc = MQTTAsync_connect(client, &conn_opts)) !=
MQTTASYNC_SUCCESS)
{
printf("Failed
to start connect, return code %d\n", rc);
finished
= 1;
}
}
void onDisconnect(void* context, MQTTAsync_successData*
response)
{
printf("Successful
disconnection\n");
finished
= 1;
}
void onSend(void* context, MQTTAsync_successData*
response)
{
MQTTAsync
client = (MQTTAsync)context;
MQTTAsync_disconnectOptions
opts = MQTTAsync_disconnectOptions_initializer;
int
rc;
printf("Message
with token value %d delivery confirmed\n",
response->token);
opts._onSuccess_
= onDisconnect;
opts.context
= client;
if
((rc = MQTTAsync_disconnect(client, &opts)) !=
MQTTASYNC_SUCCESS)
{
printf("Failed
to start sendMessage, return code %d\n", rc);
exit(EXIT_FAILURE);
}
}
void onConnectFailure(void* context,
MQTTAsync_failureData* response)
{
printf("Connect
failed, rc %d\n", response ? response->code : 0);
finished
= 1;
}
void onConnect(void* context, MQTTAsync_successData*
response)
{
MQTTAsync
client = (MQTTAsync)context;
MQTTAsync_responseOptions
opts = MQTTAsync_responseOptions_initializer;
MQTTAsync_message
pubmsg = MQTTAsync_message_initializer;
int
rc;
printf("Successful
connection\n");
int
ch;
int
EmpId;
char
name[20];
float
Val;
char
Msg[50];
int
len;
// data=""
Sample_data*)malloc(sizeof(struct Sample_data));
opts._onSuccess_
= onSend;
opts.context
= client;
printf("Please
enter your employeeId \n");
scanf("%d",&EmpId);
ch=getchar();
printf("Please
enter your name \n");
fgets(name,sizeof(name),stdin);
len=strlen(name)-1;
if(name[len]=='\n')
name[len]='\0';
// scanf("%s",name);
printf("please
enter the value \n");
scanf("%f",&Val);
sprintf(Msg,"%d
%s %f",EmpId,name,Val);
printf("message
is.... \n");
puts(Msg);
/*data->Empid=10;
data->val=20;
strcpy(data->str,"Hello");*/
// printf("data_name is %s",data->name);
pubmsg.payload
= (void *)Msg;
pubmsg.payloadlen
= sizeof(Msg);
pubmsg.qos
= QOS;
pubmsg.retained
= 0;
deliveredtoken
= 0;
// data1=(struct
Sample_data *)pubmsg.payload;
// printf("2222 \n");
// printf("data_emp is %d",data1->Empid);
// printf("data_val is %d",data1->val);
// printf("data_str is %s",data1->str);
if
((rc = MQTTAsync_sendMessage(client, TOPIC, &pubmsg,
&opts)) != MQTTASYNC_SUCCESS)
{
printf("Failed
to start sendMessage, return code %d\n", rc);
exit(EXIT_FAILURE);
}
else
printf("return
value is %d",rc);
}
int main(int argc, char* argv[])
{
MQTTAsync
client;
MQTTAsync_connectOptions
conn_opts = MQTTAsync_connectOptions_initializer;
MQTTAsync_message
pubmsg = MQTTAsync_message_initializer;
MQTTAsync_token
token;
int
rc;
MQTTAsync_create(&client,
ADDRESS, CLIENTID, MQTTCLIENT_PERSISTENCE_NONE, NULL);
MQTTAsync_setCallbacks(client,
NULL, connlost, NULL, NULL);
conn_opts.keepAliveInterval
= 20;
conn_opts.cleansession
= 1;
conn_opts._onSuccess_
= onConnect;
conn_opts._onFailure_
= onConnectFailure;
conn_opts.context
= client;
if
((rc = MQTTAsync_connect(client, &conn_opts)) !=
MQTTASYNC_SUCCESS)
{
printf("Failed
to start connect, return code %d\n", rc);
exit(EXIT_FAILURE);
}
printf("Waiting
for publication of %s\n"
"on topic %s for client with ClientID: %s\n",
PAYLOAD, TOPIC, CLIENTID);
while
(!finished)
#if
defined(WIN32)
Sleep(100);
#else
usleep(10000L);
#endif
MQTTAsync_destroy(&client);
return
rc;
}