\hypertarget{mqttsink_8c}{}\doxysection{mqtt/mqttsink.c File Reference}
\label{mqttsink_8c}\index{mqtt/mqttsink.c@{mqtt/mqttsink.c}}


Register sub-\/plugins included in libgstmqtt.  


{\ttfamily \#include $<$stdlib.\+h$>$}\newline
{\ttfamily \#include $<$string.\+h$>$}\newline
{\ttfamily \#include $<$sys/types.\+h$>$}\newline
{\ttfamily \#include $<$unistd.\+h$>$}\newline
{\ttfamily \#include $<$gst/base/gstbasesink.\+h$>$}\newline
{\ttfamily \#include $<$M\+Q\+T\+T\+Async.\+h$>$}\newline
{\ttfamily \#include $<$nnstreamer\+\_\+util.\+h$>$}\newline
{\ttfamily \#include \char`\"{}mqttsink.\+h\char`\"{}}\newline
{\ttfamily \#include \char`\"{}ntputil.\+h\char`\"{}}\newline
Include dependency graph for mqttsink.\+c\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c__incl}
\end{center}
\end{figure}
\doxysubsection*{Macros}
\begin{DoxyCompactItemize}
\item 
\#define \mbox{\hyperlink{mqttsink_8c_a85522ec02c598cc1fcabc4271240cbd5}{gst\+\_\+mqtt\+\_\+sink\+\_\+parent\+\_\+class}}~parent\+\_\+class
\item 
\#define \mbox{\hyperlink{mqttsink_8c_adef911caed7c65a1643062817f4a59d7}{G\+S\+T\+\_\+\+C\+A\+T\+\_\+\+D\+E\+F\+A\+U\+LT}}~gst\+\_\+mqtt\+\_\+sink\+\_\+debug
\end{DoxyCompactItemize}
\doxysubsection*{Enumerations}
\begin{DoxyCompactItemize}
\item 
enum \{ \newline
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57ac37dda0da1a44e10c0504afeeb863f3c}{P\+R\+O\+P\+\_\+0}}, 
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a5002941e2dd078f20b37d827b6f793c5}{P\+R\+O\+P\+\_\+\+D\+E\+B\+UG}}, 
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57aa8e9e69695017e869edb6df2ef4bcd1f}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+ID}}, 
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a625d763cbc971fa25899a863ef9e9c47}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+A\+D\+D\+R\+E\+SS}}, 
\newline
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a857e4c603b9584e3db0189e347d6a410}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+P\+O\+RT}}, 
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57acc5d1b151b4982a3f104b6905596791a}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+P\+U\+B\+\_\+\+T\+O\+P\+IC}}, 
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a561243e4b34e48cc0dbdf3e47abe19a8}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+P\+U\+B\+\_\+\+W\+A\+I\+T\+\_\+\+T\+I\+M\+E\+O\+UT}}, 
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a12529ca940e7dcad8643b160d4a08c25}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+C\+L\+E\+A\+N\+S\+E\+S\+S\+I\+ON}}, 
\newline
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a97c565ca6729233c9894f55dee329fea}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+K\+E\+E\+P\+\_\+\+A\+L\+I\+V\+E\+\_\+\+I\+N\+T\+E\+R\+V\+AL}}, 
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a1562d31897a6e203b40dc4a8d4d81782}{P\+R\+O\+P\+\_\+\+N\+U\+M\+\_\+\+B\+U\+F\+F\+E\+RS}}, 
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57ae76ef078f4c31e13b6427052fe6e0e5a}{P\+R\+O\+P\+\_\+\+M\+A\+X\+\_\+\+M\+S\+G\+\_\+\+B\+U\+F\+\_\+\+S\+I\+ZE}}, 
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57abc82f1000422a4e81e189931a80c5c23}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+Q\+OS}}, 
\newline
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a6b685390543919a7560e30f2107971f9}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+N\+T\+P\+\_\+\+S\+Y\+NC}}, 
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57aba7948f9127c7a9641844a507545aaed}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+N\+T\+P\+\_\+\+S\+R\+VS}}, 
\mbox{\hyperlink{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57ab2ccf2ce99ca729409339bda94f10e60}{P\+R\+O\+P\+\_\+\+L\+A\+ST}}
 \}
\item 
enum \{ \newline
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a26d9a3b79d5290964e5a2feafd5b821b}{D\+E\+F\+A\+U\+L\+T\+\_\+\+D\+E\+B\+UG}} = F\+A\+L\+SE, 
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a02454355ba471b073dee97918ed96987}{D\+E\+F\+A\+U\+L\+T\+\_\+\+N\+U\+M\+\_\+\+B\+U\+F\+F\+E\+RS}} = -\/1, 
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a55649f40e44b6802363a640c4cfcfad8}{D\+E\+F\+A\+U\+L\+T\+\_\+\+Q\+OS}} = T\+R\+UE, 
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a07c34b7ce302a3fbb73160e0da5b243a}{D\+E\+F\+A\+U\+L\+T\+\_\+\+S\+Y\+NC}} = F\+A\+L\+SE, 
\newline
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a0621f95d211878b36cfaf3ee9464e0ac}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+C\+L\+E\+A\+N\+S\+E\+S\+S\+I\+ON}} = T\+R\+UE, 
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388afec8cffee1de75f1242ad67be046c4df}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+K\+E\+E\+P\+\_\+\+A\+L\+I\+V\+E\+\_\+\+I\+N\+T\+E\+R\+V\+AL}} = 60, 
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388aa6103fe39d82b1b21b2731a3fdfac505}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+D\+I\+S\+C\+O\+N\+N\+E\+C\+T\+\_\+\+T\+I\+M\+E\+O\+UT}} = G\+\_\+\+T\+I\+M\+E\+\_\+\+S\+P\+A\+N\+\_\+\+S\+E\+C\+O\+ND $\ast$ 3, 
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388acf3ac03bb65a34186e053e6a3a321584}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+P\+U\+B\+\_\+\+W\+A\+I\+T\+\_\+\+T\+I\+M\+E\+O\+UT}} = 1, 
\newline
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388af640e78856c8c0053dd9b7cc98b8c2b8}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+A\+X\+\_\+\+M\+S\+G\+\_\+\+B\+U\+F\+\_\+\+S\+I\+ZE}} = 0, 
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a812aa2f48beeea9c889bb3e323fef846}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+Q\+OS}} = 0, 
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a0887c77be6cd1b1ca0cfc45f105cbd6c}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+N\+T\+P\+\_\+\+S\+Y\+NC}} = F\+A\+L\+SE, 
\mbox{\hyperlink{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a5cecbd929357b9f3df201c28abcd9dd5}{M\+A\+X\+\_\+\+L\+E\+N\+\_\+\+P\+R\+O\+P\+\_\+\+N\+T\+P\+\_\+\+S\+R\+VS}} = 4096
 \}
\end{DoxyCompactItemize}
\doxysubsection*{Functions}
\begin{DoxyCompactItemize}
\item 
\mbox{\hyperlink{mqttsink_8c_a446884c3b6e4a0899846ec05be47ce81}{G\+\_\+\+D\+E\+F\+I\+N\+E\+\_\+\+T\+Y\+PE}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}}, gst\+\_\+mqtt\+\_\+sink, G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+B\+A\+S\+E\+\_\+\+S\+I\+NK)
\item 
\mbox{\hyperlink{mqttsink_8c_ad2e9db03440272783fb3a753417eedc4}{G\+S\+T\+\_\+\+D\+E\+B\+U\+G\+\_\+\+C\+A\+T\+E\+G\+O\+R\+Y\+\_\+\+S\+T\+A\+T\+IC}} (gst\+\_\+mqtt\+\_\+sink\+\_\+debug)
\item 
static void \mbox{\hyperlink{mqttsink_8c_a512a632468de7eb9c8be567653ac1a50}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+property}} (G\+Object $\ast$object, guint prop\+\_\+id, const G\+Value $\ast$value, G\+Param\+Spec $\ast$pspec)
\begin{DoxyCompactList}\small\item\em The setter for the mqttsink\textquotesingle{}s properties. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_adda4e8ece8bf03f2a180eb4e8379b0f9}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+property}} (G\+Object $\ast$object, guint prop\+\_\+id, G\+Value $\ast$value, G\+Param\+Spec $\ast$pspec)
\begin{DoxyCompactList}\small\item\em The getter for the mqttsink\textquotesingle{}s properties. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a212e9187279b4ae469b3128f24d05ac1}{gst\+\_\+mqtt\+\_\+sink\+\_\+class\+\_\+finalize}} (G\+Object $\ast$object)
\begin{DoxyCompactList}\small\item\em Finalize Gst\+Mqtt\+Sink\+Class object. \end{DoxyCompactList}\item 
static Gst\+State\+Change\+Return \mbox{\hyperlink{mqttsink_8c_a45e3f1a4ca996bfb319218a5a9768ace}{gst\+\_\+mqtt\+\_\+sink\+\_\+change\+\_\+state}} (Gst\+Element $\ast$element, Gst\+State\+Change transition)
\begin{DoxyCompactList}\small\item\em Handle mqttsink\textquotesingle{}s state change. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsink_8c_a7094cca07819556c382d454fcd9e2c76}{gst\+\_\+mqtt\+\_\+sink\+\_\+start}} (Gst\+Base\+Sink $\ast$basesink)
\begin{DoxyCompactList}\small\item\em Start mqttsink, called when state changed null to ready. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsink_8c_a0153e8f1598015ef892e2e072db97ea5}{gst\+\_\+mqtt\+\_\+sink\+\_\+stop}} (Gst\+Base\+Sink $\ast$basesink)
\begin{DoxyCompactList}\small\item\em Stop mqttsink, called when state changed ready to null. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsink_8c_a2836c285ad0197c865f6b78b72f935ed}{gst\+\_\+mqtt\+\_\+sink\+\_\+query}} (Gst\+Base\+Sink $\ast$basesink, Gst\+Query $\ast$query)
\begin{DoxyCompactList}\small\item\em Perform queries on the element. \end{DoxyCompactList}\item 
static Gst\+Flow\+Return \mbox{\hyperlink{mqttsink_8c_a6b4f078dca25799d9268ab8131f62135}{gst\+\_\+mqtt\+\_\+sink\+\_\+render}} (Gst\+Base\+Sink $\ast$basesink, Gst\+Buffer $\ast$in\+\_\+buf)
\begin{DoxyCompactList}\small\item\em The callback to process each buffer receiving on the sink pad. \end{DoxyCompactList}\item 
static Gst\+Flow\+Return \mbox{\hyperlink{mqttsink_8c_a9c8d34e33ab06a590efee97dd59c55c6}{gst\+\_\+mqtt\+\_\+sink\+\_\+render\+\_\+list}} (Gst\+Base\+Sink $\ast$basesink, Gst\+Buffer\+List $\ast$list)
\begin{DoxyCompactList}\small\item\em The callback to process Gst\+Buffer\+List (instead of a single buffer) on the sink pad. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsink_8c_a3080bc2ba662a5ebf37a34190db4da13}{gst\+\_\+mqtt\+\_\+sink\+\_\+event}} (Gst\+Base\+Sink $\ast$basesink, Gst\+Event $\ast$event)
\begin{DoxyCompactList}\small\item\em Handle events arriving on the sink pad. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsink_8c_a7f5f4f9bd130074a34ccace77e57466b}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+caps}} (Gst\+Base\+Sink $\ast$basesink, Gst\+Caps $\ast$caps)
\begin{DoxyCompactList}\small\item\em An implementation of the set\+\_\+caps vmethod in Gst\+Base\+Sink\+Class. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsink_8c_a8b34f3079a834aa0ace6f2c4a0995a1f}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+debug}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}debug\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_af02f1d4a1d6204f8a10e6543c8554c61}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+debug}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gboolean flag)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}debug\textquotesingle{} property. \end{DoxyCompactList}\item 
static gchar $\ast$ \mbox{\hyperlink{mqttsink_8c_a14f3f1987b65bdeb438373ee24bf1770}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+client\+\_\+id}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}client-\/id\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_af8da02029fabce70bccc38e90705de44}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+client\+\_\+id}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gchar $\ast$id)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}client-\/id\textquotesingle{} property. \end{DoxyCompactList}\item 
static gchar $\ast$ \mbox{\hyperlink{mqttsink_8c_a8630ec547c7e101ea10641b0994137ba}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+host\+\_\+address}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}host\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a7b378bb6e2e458ed9cf97fd37c0b4e48}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+host\+\_\+address}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gchar $\ast$addr)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}host\textquotesingle{} property. \end{DoxyCompactList}\item 
static gchar $\ast$ \mbox{\hyperlink{mqttsink_8c_a848bd59298c2af36ccbaf46e3a39d1ce}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+host\+\_\+port}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}port\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_ac225e69c01dad0b85df1838322f59ddb}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+host\+\_\+port}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gchar $\ast$port)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}port\textquotesingle{} property. \end{DoxyCompactList}\item 
static gchar $\ast$ \mbox{\hyperlink{mqttsink_8c_a13ca7457ccd4555f29490a802ef7859f}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+pub\+\_\+topic}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}pub-\/topic\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a849521ce7de32553b2a1c464ed7fefe9}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+pub\+\_\+topic}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gchar $\ast$topic)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}pub-\/topic\textquotesingle{} property. \end{DoxyCompactList}\item 
static gulong \mbox{\hyperlink{mqttsink_8c_a19417a2cfad2bd8e87fe9f5f2d968f94}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+pub\+\_\+wait\+\_\+timeout}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}pub-\/wait-\/timeout\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_adc88a227f9366dd080f76f0906d9b5e1}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+pub\+\_\+wait\+\_\+timeout}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gulong to)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}pub-\/wait-\/timeout\textquotesingle{} property. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsink_8c_a0ebee221306a8610d720141bc34d7d96}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+opt\+\_\+cleansession}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}cleansession\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a4b8ba78d41a91612cb00ad0485280725}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+opt\+\_\+cleansession}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gboolean val)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}cleansession\textquotesingle{} property. \end{DoxyCompactList}\item 
static gint \mbox{\hyperlink{mqttsink_8c_a3ac8d0f930067295dfcdceef969f500a}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+opt\+\_\+keep\+\_\+alive\+\_\+interval}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}keep-\/alive-\/interval\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a86a86b830fb8ca6aa60e2ad39093e5c7}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+opt\+\_\+keep\+\_\+alive\+\_\+interval}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gint num)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}keep-\/alive-\/interval\textquotesingle{} property. \end{DoxyCompactList}\item 
static gsize \mbox{\hyperlink{mqttsink_8c_ae2591fbaee7aea1f59a7f14621daaaf7}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+max\+\_\+msg\+\_\+buf\+\_\+size}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}max-\/buffer-\/size\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_aa07d26953b9749db2c4131df0c662de7}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+max\+\_\+msg\+\_\+buf\+\_\+size}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gsize size)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}max-\/buffer-\/size\textquotesingle{} property. \end{DoxyCompactList}\item 
static gint \mbox{\hyperlink{mqttsink_8c_a17a7395b0868f8cf4070fcb761a4dde4}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+num\+\_\+buffers}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}num-\/buffers\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_af67a8f119649f1bc4531aa874cc4e2bf}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+num\+\_\+buffers}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gint num)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}num-\/buffers\textquotesingle{} property. \end{DoxyCompactList}\item 
static gint \mbox{\hyperlink{mqttsink_8c_a52f797e11bf9b1b0db40fbb657c88295}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+mqtt\+\_\+qos}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}mqtt-\/qos\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_abc37bb8fe4c3c8a2a65f94bd28f0e187}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+mqtt\+\_\+qos}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gint qos)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}mqtt-\/qos\textquotesingle{} property. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsink_8c_a1203251ce25e17dd2f911821d1ea2d70}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+mqtt\+\_\+ntp\+\_\+sync}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}ntp-\/sync\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_ad73ceb171ab90d9de8ae0878e58c4470}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+mqtt\+\_\+ntp\+\_\+sync}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gboolean flag)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}ntp-\/sync\textquotesingle{} property. \end{DoxyCompactList}\item 
static gchar $\ast$ \mbox{\hyperlink{mqttsink_8c_ae6d3ba1d312db2ede64042d3b3aadd7f}{gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+mqtt\+\_\+ntp\+\_\+srvs}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}ntp-\/srvs\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_aff65b6f2e29ee4f8886207c2ead6354c}{gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+mqtt\+\_\+ntp\+\_\+srvs}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, const gchar $\ast$pairs)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}ntp-\/srvs\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a61a1d8fe3eae6fe768ecd6cd5dab78d7}{cb\+\_\+mqtt\+\_\+on\+\_\+connect}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+connect\+Options\textquotesingle{}s on\+Success. This callback is invoked when the connection between this element and the broker is properly established. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a0c22b06eae9165e52844885f7c48404c}{cb\+\_\+mqtt\+\_\+on\+\_\+connect\+\_\+failure}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+connect\+Options\textquotesingle{}s on\+Failure. This callback is invoked when it is failed to connect to the broker. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a0a13f8bdaa1198220b583ab012a8d8a3}{cb\+\_\+mqtt\+\_\+on\+\_\+disconnect}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+disconnect\+Options\textquotesingle{}s on\+Success. Regardless of the M\+Q\+T\+T\+Async\+\_\+disconnect function\textquotesingle{}s result, the pipeline should be stopped after this callback. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a8ceece44216de84303b55f04ef859a86}{cb\+\_\+mqtt\+\_\+on\+\_\+disconnect\+\_\+failure}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+disconnect\+Options\textquotesingle{}s on\+Failure. Regardless of the M\+Q\+T\+T\+Async\+\_\+disconnect function\textquotesingle{}s result, the pipeline should be stopped after this callback. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a07089dfec60112e4bff3327ad3d8b60c}{cb\+\_\+mqtt\+\_\+on\+\_\+delivery\+\_\+complete}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+token token)
\begin{DoxyCompactList}\small\item\em A callback function to be given to the M\+Q\+T\+T\+Async\+\_\+set\+Callbacks function. This callback is activated when {\ttfamily mqtt-\/qos} is higher then 0. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a9d1641daa30b926d359514e56da29323}{cb\+\_\+mqtt\+\_\+on\+\_\+connection\+\_\+lost}} (void $\ast$context, char $\ast$cause)
\begin{DoxyCompactList}\small\item\em A callback function to be given to the M\+Q\+T\+T\+Async\+\_\+set\+Callbacks function. When the connection between this element and the broker is broken, this callback will be invoked. \end{DoxyCompactList}\item 
static int \mbox{\hyperlink{mqttsink_8c_a0d9251e9e546ca5dbcb0e3ca51110d15}{cb\+\_\+mqtt\+\_\+on\+\_\+message\+\_\+arrived}} (void $\ast$context, char $\ast$topic\+Name, int topic\+Len, M\+Q\+T\+T\+Async\+\_\+message $\ast$message)
\begin{DoxyCompactList}\small\item\em A callback function to be given to the M\+Q\+T\+T\+Async\+\_\+set\+Callbacks function. In the case of the publisher, this callback is not used. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a8d41ca19f03ded61f4cd2709d6fc23db}{cb\+\_\+mqtt\+\_\+on\+\_\+send\+\_\+success}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Success. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a81620d2cfcb2094cb044b80cb15fb835}{cb\+\_\+mqtt\+\_\+on\+\_\+send\+\_\+failure}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Failure. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_a84d9d3bfe28b20306516a5be8705f693}{gst\+\_\+mqtt\+\_\+sink\+\_\+init}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Initialize Gst\+Mqtt\+Sink object. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_ad99a4da0c22898b0d677d0ccca352e37}{gst\+\_\+mqtt\+\_\+sink\+\_\+class\+\_\+init}} (\mbox{\hyperlink{mqttsink_8h_a8e42ae78b176c0877fcb932446611cb8}{Gst\+Mqtt\+Sink\+Class}} $\ast$klass)
\begin{DoxyCompactList}\small\item\em Initialize Gst\+Mqtt\+Sink\+Class object. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsink_8c_adc7a1f9f31690e0edadf4fdee8a5232d}{\+\_\+put\+\_\+timestamp\+\_\+to\+\_\+msg\+\_\+buf\+\_\+hdr}} (\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$self, Gst\+Buffer $\ast$gst\+\_\+buf, \mbox{\hyperlink{mqttcommon_8h_aebbdc549dc7aa1431f3b2b9a0b5e8f2c}{Gst\+M\+Q\+T\+T\+Message\+Hdr}} $\ast$hdr)
\begin{DoxyCompactList}\small\item\em A utility function to set the timestamp information onto the given buffer. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsink_8c_a5ac0965fa2c75890da7e64aca889a4aa}{\+\_\+mqtt\+\_\+set\+\_\+msg\+\_\+buf\+\_\+hdr}} (Gst\+Buffer $\ast$gst\+\_\+buf, \mbox{\hyperlink{mqttcommon_8h_aebbdc549dc7aa1431f3b2b9a0b5e8f2c}{Gst\+M\+Q\+T\+T\+Message\+Hdr}} $\ast$hdr)
\begin{DoxyCompactList}\small\item\em A utility function to set the message header. \end{DoxyCompactList}\end{DoxyCompactItemize}
\doxysubsection*{Variables}
\begin{DoxyCompactItemize}
\item 
static Gst\+Static\+Pad\+Template \mbox{\hyperlink{mqttsink_8c_a0be0d54e5dfda4b5ee0fe40c0002d47e}{sink\+\_\+pad\+\_\+template}}
\item 
static guint8 \mbox{\hyperlink{mqttsink_8c_a012d33d4cc636f79991b60a45766d1f4}{sink\+\_\+client\+\_\+id}} = 0
\item 
static const gchar \mbox{\hyperlink{mqttsink_8c_adb7c1d7abe7c50e461f495f2b6b9adbc}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+A\+D\+D\+R\+E\+SS}} \mbox{[}$\,$\mbox{]} = \char`\"{}127.\+0.\+0.\+1\char`\"{}
\item 
static const gchar \mbox{\hyperlink{mqttsink_8c_a782553475a8ab1e231242a2ab4fcd43f}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+P\+O\+RT}} \mbox{[}$\,$\mbox{]} = \char`\"{}1883\char`\"{}
\item 
static const gchar \mbox{\hyperlink{mqttsink_8c_a70bd54d26129acad3ade3d7200f3e771}{T\+A\+G\+\_\+\+E\+R\+R\+\_\+\+M\+Q\+T\+T\+S\+I\+NK}} \mbox{[}$\,$\mbox{]} = \char`\"{}E\+R\+R\+O\+R\+: M\+Q\+T\+T\+Sink\char`\"{}
\item 
static const gchar \mbox{\hyperlink{mqttsink_8c_ad7802f55a92df9e9b9d3cfd5e2fb11bf}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+ID}} \mbox{[}$\,$\mbox{]} = \char`\"{}\$H\+O\+S\+T\+\_\+\$\+P\+I\+D\+\_\+$^\wedge$\mbox{[}0-\/9\mbox{]}\mbox{[}0-\/9\mbox{]}?\$$\vert$$^\wedge$255\$\char`\"{}
\item 
static const gchar \mbox{\hyperlink{mqttsink_8c_acf4f9062c5331fe5613e31c923468e30}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+I\+D\+\_\+\+F\+O\+R\+M\+AT}} \mbox{[}$\,$\mbox{]} = \char`\"{}\%s\+\_\+\%u\+\_\+sink\%u\char`\"{}
\item 
static const gchar \mbox{\hyperlink{mqttsink_8c_a8fe55f82926f7d81e8ca99903b89e944}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+P\+U\+B\+\_\+\+T\+O\+P\+IC}} \mbox{[}$\,$\mbox{]} = \char`\"{}\$client-\/id/topic\char`\"{}
\item 
static const gchar \mbox{\hyperlink{mqttsink_8c_a79081b9c55a5af6166b02d133af346e0}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+P\+U\+B\+\_\+\+T\+O\+P\+I\+C\+\_\+\+F\+O\+R\+M\+AT}} \mbox{[}$\,$\mbox{]} = \char`\"{}\%s/topic\char`\"{}
\item 
static const gchar \mbox{\hyperlink{mqttsink_8c_a18bad0d631a1a2e27fe43a9f1600d862}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+N\+T\+P\+\_\+\+S\+E\+R\+V\+E\+RS}} \mbox{[}$\,$\mbox{]} = \char`\"{}pool.\+ntp.\+org\+:123\char`\"{}
\end{DoxyCompactItemize}


\doxysubsection{Detailed Description}
Register sub-\/plugins included in libgstmqtt. 

Publish incoming data streams as a M\+Q\+TT topic.

Copyright (C) 2021 Wook Song \href{mailto:wook16.song@samsung.com}{\texttt{ wook16.\+song@samsung.\+com}}

\begin{DoxyDate}{Date}
09 Mar 2021 
\end{DoxyDate}
\begin{DoxySeeAlso}{See also}
\href{https://github.com/nnstreamer/nnstreamer}{\texttt{ https\+://github.\+com/nnstreamer/nnstreamer}} 
\end{DoxySeeAlso}
\begin{DoxyAuthor}{Author}
Wook Song \href{mailto:wook16.song@samsung.com}{\texttt{ wook16.\+song@samsung.\+com}} 
\end{DoxyAuthor}
\begin{DoxyRefDesc}{Bug}
\item[\mbox{\hyperlink{bug__bug000017}{Bug}}]No known bugs except for N\+YI items \end{DoxyRefDesc}


Copyright (C) 2021 Wook Song \href{mailto:wook16.song@samsung.com}{\texttt{ wook16.\+song@samsung.\+com}}

\begin{DoxyDate}{Date}
01 Apr 2021 
\end{DoxyDate}
\begin{DoxySeeAlso}{See also}
\href{https://github.com/nnstreamer/nnstreamer}{\texttt{ https\+://github.\+com/nnstreamer/nnstreamer}} 
\end{DoxySeeAlso}
\begin{DoxyAuthor}{Author}
Wook Song \href{mailto:wook16.song@samsung.com}{\texttt{ wook16.\+song@samsung.\+com}} 
\end{DoxyAuthor}
\begin{DoxyRefDesc}{Bug}
\item[\mbox{\hyperlink{bug__bug000018}{Bug}}]No known bugs except for N\+YI items \end{DoxyRefDesc}


\doxysubsection{Macro Definition Documentation}
\mbox{\Hypertarget{mqttsink_8c_adef911caed7c65a1643062817f4a59d7}\label{mqttsink_8c_adef911caed7c65a1643062817f4a59d7}} 
\index{mqttsink.c@{mqttsink.c}!GST\_CAT\_DEFAULT@{GST\_CAT\_DEFAULT}}
\index{GST\_CAT\_DEFAULT@{GST\_CAT\_DEFAULT}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{GST\_CAT\_DEFAULT}{GST\_CAT\_DEFAULT}}
{\footnotesize\ttfamily \#define G\+S\+T\+\_\+\+C\+A\+T\+\_\+\+D\+E\+F\+A\+U\+LT~gst\+\_\+mqtt\+\_\+sink\+\_\+debug}



Definition at line 42 of file mqttsink.\+c.

\mbox{\Hypertarget{mqttsink_8c_a85522ec02c598cc1fcabc4271240cbd5}\label{mqttsink_8c_a85522ec02c598cc1fcabc4271240cbd5}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_parent\_class@{gst\_mqtt\_sink\_parent\_class}}
\index{gst\_mqtt\_sink\_parent\_class@{gst\_mqtt\_sink\_parent\_class}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_parent\_class}{gst\_mqtt\_sink\_parent\_class}}
{\footnotesize\ttfamily \#define gst\+\_\+mqtt\+\_\+sink\+\_\+parent\+\_\+class~parent\+\_\+class}



Definition at line 38 of file mqttsink.\+c.



\doxysubsection{Enumeration Type Documentation}
\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388}} 
\doxysubsubsection{\texorpdfstring{anonymous enum}{anonymous enum}}
{\footnotesize\ttfamily anonymous enum}

\begin{DoxyEnumFields}{Enumerator}
\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_DEBUG@{DEFAULT\_DEBUG}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!DEFAULT\_DEBUG@{DEFAULT\_DEBUG}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a26d9a3b79d5290964e5a2feafd5b821b}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a26d9a3b79d5290964e5a2feafd5b821b}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+D\+E\+B\+UG&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_NUM\_BUFFERS@{DEFAULT\_NUM\_BUFFERS}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!DEFAULT\_NUM\_BUFFERS@{DEFAULT\_NUM\_BUFFERS}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a02454355ba471b073dee97918ed96987}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a02454355ba471b073dee97918ed96987}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+N\+U\+M\+\_\+\+B\+U\+F\+F\+E\+RS&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_QOS@{DEFAULT\_QOS}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!DEFAULT\_QOS@{DEFAULT\_QOS}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a55649f40e44b6802363a640c4cfcfad8}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a55649f40e44b6802363a640c4cfcfad8}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+Q\+OS&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_SYNC@{DEFAULT\_SYNC}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!DEFAULT\_SYNC@{DEFAULT\_SYNC}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a07c34b7ce302a3fbb73160e0da5b243a}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a07c34b7ce302a3fbb73160e0da5b243a}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+S\+Y\+NC&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MQTT\_OPT\_CLEANSESSION@{DEFAULT\_MQTT\_OPT\_CLEANSESSION}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_OPT\_CLEANSESSION@{DEFAULT\_MQTT\_OPT\_CLEANSESSION}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a0621f95d211878b36cfaf3ee9464e0ac}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a0621f95d211878b36cfaf3ee9464e0ac}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+C\+L\+E\+A\+N\+S\+E\+S\+S\+I\+ON&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL@{DEFAULT\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL@{DEFAULT\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388afec8cffee1de75f1242ad67be046c4df}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388afec8cffee1de75f1242ad67be046c4df}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+K\+E\+E\+P\+\_\+\+A\+L\+I\+V\+E\+\_\+\+I\+N\+T\+E\+R\+V\+AL&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MQTT\_DISCONNECT\_TIMEOUT@{DEFAULT\_MQTT\_DISCONNECT\_TIMEOUT}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_DISCONNECT\_TIMEOUT@{DEFAULT\_MQTT\_DISCONNECT\_TIMEOUT}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388aa6103fe39d82b1b21b2731a3fdfac505}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388aa6103fe39d82b1b21b2731a3fdfac505}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+D\+I\+S\+C\+O\+N\+N\+E\+C\+T\+\_\+\+T\+I\+M\+E\+O\+UT&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MQTT\_PUB\_WAIT\_TIMEOUT@{DEFAULT\_MQTT\_PUB\_WAIT\_TIMEOUT}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_PUB\_WAIT\_TIMEOUT@{DEFAULT\_MQTT\_PUB\_WAIT\_TIMEOUT}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388acf3ac03bb65a34186e053e6a3a321584}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388acf3ac03bb65a34186e053e6a3a321584}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+P\+U\+B\+\_\+\+W\+A\+I\+T\+\_\+\+T\+I\+M\+E\+O\+UT&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MAX\_MSG\_BUF\_SIZE@{DEFAULT\_MAX\_MSG\_BUF\_SIZE}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MAX\_MSG\_BUF\_SIZE@{DEFAULT\_MAX\_MSG\_BUF\_SIZE}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388af640e78856c8c0053dd9b7cc98b8c2b8}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388af640e78856c8c0053dd9b7cc98b8c2b8}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+A\+X\+\_\+\+M\+S\+G\+\_\+\+B\+U\+F\+\_\+\+S\+I\+ZE&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MQTT\_QOS@{DEFAULT\_MQTT\_QOS}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_QOS@{DEFAULT\_MQTT\_QOS}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a812aa2f48beeea9c889bb3e323fef846}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a812aa2f48beeea9c889bb3e323fef846}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+Q\+OS&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MQTT\_NTP\_SYNC@{DEFAULT\_MQTT\_NTP\_SYNC}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_NTP\_SYNC@{DEFAULT\_MQTT\_NTP\_SYNC}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a0887c77be6cd1b1ca0cfc45f105cbd6c}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a0887c77be6cd1b1ca0cfc45f105cbd6c}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+N\+T\+P\+\_\+\+S\+Y\+NC&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{MAX\_LEN\_PROP\_NTP\_SRVS@{MAX\_LEN\_PROP\_NTP\_SRVS}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!MAX\_LEN\_PROP\_NTP\_SRVS@{MAX\_LEN\_PROP\_NTP\_SRVS}}}\mbox{\Hypertarget{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a5cecbd929357b9f3df201c28abcd9dd5}\label{mqttsink_8c_a385c44f6fb256e5716a2302a5b940388a5cecbd929357b9f3df201c28abcd9dd5}} 
M\+A\+X\+\_\+\+L\+E\+N\+\_\+\+P\+R\+O\+P\+\_\+\+N\+T\+P\+\_\+\+S\+R\+VS&\\
\hline

\end{DoxyEnumFields}


Definition at line 65 of file mqttsink.\+c.

\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57}} 
\doxysubsubsection{\texorpdfstring{anonymous enum}{anonymous enum}}
{\footnotesize\ttfamily anonymous enum}

\begin{DoxyEnumFields}{Enumerator}
\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_0@{PROP\_0}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_0@{PROP\_0}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57ac37dda0da1a44e10c0504afeeb863f3c}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57ac37dda0da1a44e10c0504afeeb863f3c}} 
P\+R\+O\+P\+\_\+0&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_DEBUG@{PROP\_DEBUG}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_DEBUG@{PROP\_DEBUG}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a5002941e2dd078f20b37d827b6f793c5}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a5002941e2dd078f20b37d827b6f793c5}} 
P\+R\+O\+P\+\_\+\+D\+E\+B\+UG&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_CLIENT\_ID@{PROP\_MQTT\_CLIENT\_ID}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_MQTT\_CLIENT\_ID@{PROP\_MQTT\_CLIENT\_ID}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57aa8e9e69695017e869edb6df2ef4bcd1f}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57aa8e9e69695017e869edb6df2ef4bcd1f}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+ID&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_HOST\_ADDRESS@{PROP\_MQTT\_HOST\_ADDRESS}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_MQTT\_HOST\_ADDRESS@{PROP\_MQTT\_HOST\_ADDRESS}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a625d763cbc971fa25899a863ef9e9c47}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a625d763cbc971fa25899a863ef9e9c47}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+A\+D\+D\+R\+E\+SS&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_HOST\_PORT@{PROP\_MQTT\_HOST\_PORT}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_MQTT\_HOST\_PORT@{PROP\_MQTT\_HOST\_PORT}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a857e4c603b9584e3db0189e347d6a410}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a857e4c603b9584e3db0189e347d6a410}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+P\+O\+RT&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_PUB\_TOPIC@{PROP\_MQTT\_PUB\_TOPIC}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_MQTT\_PUB\_TOPIC@{PROP\_MQTT\_PUB\_TOPIC}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57acc5d1b151b4982a3f104b6905596791a}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57acc5d1b151b4982a3f104b6905596791a}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+P\+U\+B\+\_\+\+T\+O\+P\+IC&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_PUB\_WAIT\_TIMEOUT@{PROP\_MQTT\_PUB\_WAIT\_TIMEOUT}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_MQTT\_PUB\_WAIT\_TIMEOUT@{PROP\_MQTT\_PUB\_WAIT\_TIMEOUT}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a561243e4b34e48cc0dbdf3e47abe19a8}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a561243e4b34e48cc0dbdf3e47abe19a8}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+P\+U\+B\+\_\+\+W\+A\+I\+T\+\_\+\+T\+I\+M\+E\+O\+UT&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_OPT\_CLEANSESSION@{PROP\_MQTT\_OPT\_CLEANSESSION}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_MQTT\_OPT\_CLEANSESSION@{PROP\_MQTT\_OPT\_CLEANSESSION}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a12529ca940e7dcad8643b160d4a08c25}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a12529ca940e7dcad8643b160d4a08c25}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+C\+L\+E\+A\+N\+S\+E\+S\+S\+I\+ON&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL@{PROP\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL@{PROP\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a97c565ca6729233c9894f55dee329fea}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a97c565ca6729233c9894f55dee329fea}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+K\+E\+E\+P\+\_\+\+A\+L\+I\+V\+E\+\_\+\+I\+N\+T\+E\+R\+V\+AL&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_NUM\_BUFFERS@{PROP\_NUM\_BUFFERS}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_NUM\_BUFFERS@{PROP\_NUM\_BUFFERS}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a1562d31897a6e203b40dc4a8d4d81782}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a1562d31897a6e203b40dc4a8d4d81782}} 
P\+R\+O\+P\+\_\+\+N\+U\+M\+\_\+\+B\+U\+F\+F\+E\+RS&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MAX\_MSG\_BUF\_SIZE@{PROP\_MAX\_MSG\_BUF\_SIZE}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_MAX\_MSG\_BUF\_SIZE@{PROP\_MAX\_MSG\_BUF\_SIZE}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57ae76ef078f4c31e13b6427052fe6e0e5a}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57ae76ef078f4c31e13b6427052fe6e0e5a}} 
P\+R\+O\+P\+\_\+\+M\+A\+X\+\_\+\+M\+S\+G\+\_\+\+B\+U\+F\+\_\+\+S\+I\+ZE&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_QOS@{PROP\_MQTT\_QOS}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_MQTT\_QOS@{PROP\_MQTT\_QOS}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57abc82f1000422a4e81e189931a80c5c23}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57abc82f1000422a4e81e189931a80c5c23}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+Q\+OS&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_NTP\_SYNC@{PROP\_MQTT\_NTP\_SYNC}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_MQTT\_NTP\_SYNC@{PROP\_MQTT\_NTP\_SYNC}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a6b685390543919a7560e30f2107971f9}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57a6b685390543919a7560e30f2107971f9}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+N\+T\+P\+\_\+\+S\+Y\+NC&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_NTP\_SRVS@{PROP\_MQTT\_NTP\_SRVS}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_MQTT\_NTP\_SRVS@{PROP\_MQTT\_NTP\_SRVS}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57aba7948f9127c7a9641844a507545aaed}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57aba7948f9127c7a9641844a507545aaed}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+N\+T\+P\+\_\+\+S\+R\+VS&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_LAST@{PROP\_LAST}!mqttsink.c@{mqttsink.c}}\index{mqttsink.c@{mqttsink.c}!PROP\_LAST@{PROP\_LAST}}}\mbox{\Hypertarget{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57ab2ccf2ce99ca729409339bda94f10e60}\label{mqttsink_8c_ab04a0655cd1e3bcac5e8f48c18df1a57ab2ccf2ce99ca729409339bda94f10e60}} 
P\+R\+O\+P\+\_\+\+L\+A\+ST&\\
\hline

\end{DoxyEnumFields}


Definition at line 44 of file mqttsink.\+c.



\doxysubsection{Function Documentation}
\mbox{\Hypertarget{mqttsink_8c_a5ac0965fa2c75890da7e64aca889a4aa}\label{mqttsink_8c_a5ac0965fa2c75890da7e64aca889a4aa}} 
\index{mqttsink.c@{mqttsink.c}!\_mqtt\_set\_msg\_buf\_hdr@{\_mqtt\_set\_msg\_buf\_hdr}}
\index{\_mqtt\_set\_msg\_buf\_hdr@{\_mqtt\_set\_msg\_buf\_hdr}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{\_mqtt\_set\_msg\_buf\_hdr()}{\_mqtt\_set\_msg\_buf\_hdr()}}
{\footnotesize\ttfamily static gboolean \+\_\+mqtt\+\_\+set\+\_\+msg\+\_\+buf\+\_\+hdr (\begin{DoxyParamCaption}\item[{Gst\+Buffer $\ast$}]{gst\+\_\+buf,  }\item[{\mbox{\hyperlink{mqttcommon_8h_aebbdc549dc7aa1431f3b2b9a0b5e8f2c}{Gst\+M\+Q\+T\+T\+Message\+Hdr}} $\ast$}]{hdr }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A utility function to set the message header. 



Definition at line 725 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a5ac0965fa2c75890da7e64aca889a4aa_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_adc7a1f9f31690e0edadf4fdee8a5232d}\label{mqttsink_8c_adc7a1f9f31690e0edadf4fdee8a5232d}} 
\index{mqttsink.c@{mqttsink.c}!\_put\_timestamp\_to\_msg\_buf\_hdr@{\_put\_timestamp\_to\_msg\_buf\_hdr}}
\index{\_put\_timestamp\_to\_msg\_buf\_hdr@{\_put\_timestamp\_to\_msg\_buf\_hdr}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{\_put\_timestamp\_to\_msg\_buf\_hdr()}{\_put\_timestamp\_to\_msg\_buf\_hdr()}}
{\footnotesize\ttfamily static void \+\_\+put\+\_\+timestamp\+\_\+to\+\_\+msg\+\_\+buf\+\_\+hdr (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{Gst\+Buffer $\ast$}]{gst\+\_\+buf,  }\item[{\mbox{\hyperlink{mqttcommon_8h_aebbdc549dc7aa1431f3b2b9a0b5e8f2c}{Gst\+M\+Q\+T\+T\+Message\+Hdr}} $\ast$}]{hdr }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A utility function to set the timestamp information onto the given buffer. 



Definition at line 688 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_adc7a1f9f31690e0edadf4fdee8a5232d_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a61a1d8fe3eae6fe768ecd6cd5dab78d7}\label{mqttsink_8c_a61a1d8fe3eae6fe768ecd6cd5dab78d7}} 
\index{mqttsink.c@{mqttsink.c}!cb\_mqtt\_on\_connect@{cb\_mqtt\_on\_connect}}
\index{cb\_mqtt\_on\_connect@{cb\_mqtt\_on\_connect}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_connect()}{cb\_mqtt\_on\_connect()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+connect (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+connect\+Options\textquotesingle{}s on\+Success. This callback is invoked when the connection between this element and the broker is properly established. 

Callback function definitions 

Definition at line 1267 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=340pt]{mqttsink_8c_a61a1d8fe3eae6fe768ecd6cd5dab78d7_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a0c22b06eae9165e52844885f7c48404c}\label{mqttsink_8c_a0c22b06eae9165e52844885f7c48404c}} 
\index{mqttsink.c@{mqttsink.c}!cb\_mqtt\_on\_connect\_failure@{cb\_mqtt\_on\_connect\_failure}}
\index{cb\_mqtt\_on\_connect\_failure@{cb\_mqtt\_on\_connect\_failure}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_connect\_failure()}{cb\_mqtt\_on\_connect\_failure()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+connect\+\_\+failure (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+connect\+Options\textquotesingle{}s on\+Failure. This callback is invoked when it is failed to connect to the broker. 



Definition at line 1285 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=340pt]{mqttsink_8c_a0c22b06eae9165e52844885f7c48404c_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a9d1641daa30b926d359514e56da29323}\label{mqttsink_8c_a9d1641daa30b926d359514e56da29323}} 
\index{mqttsink.c@{mqttsink.c}!cb\_mqtt\_on\_connection\_lost@{cb\_mqtt\_on\_connection\_lost}}
\index{cb\_mqtt\_on\_connection\_lost@{cb\_mqtt\_on\_connection\_lost}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_connection\_lost()}{cb\_mqtt\_on\_connection\_lost()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+connection\+\_\+lost (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{char $\ast$}]{cause }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback function to be given to the M\+Q\+T\+T\+Async\+\_\+set\+Callbacks function. When the connection between this element and the broker is broken, this callback will be invoked. 



Definition at line 1351 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a9d1641daa30b926d359514e56da29323_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a07089dfec60112e4bff3327ad3d8b60c}\label{mqttsink_8c_a07089dfec60112e4bff3327ad3d8b60c}} 
\index{mqttsink.c@{mqttsink.c}!cb\_mqtt\_on\_delivery\_complete@{cb\_mqtt\_on\_delivery\_complete}}
\index{cb\_mqtt\_on\_delivery\_complete@{cb\_mqtt\_on\_delivery\_complete}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_delivery\_complete()}{cb\_mqtt\_on\_delivery\_complete()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+delivery\+\_\+complete (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+token}]{token }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback function to be given to the M\+Q\+T\+T\+Async\+\_\+set\+Callbacks function. This callback is activated when {\ttfamily mqtt-\/qos} is higher then 0. 



Definition at line 1336 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a07089dfec60112e4bff3327ad3d8b60c_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a0a13f8bdaa1198220b583ab012a8d8a3}\label{mqttsink_8c_a0a13f8bdaa1198220b583ab012a8d8a3}} 
\index{mqttsink.c@{mqttsink.c}!cb\_mqtt\_on\_disconnect@{cb\_mqtt\_on\_disconnect}}
\index{cb\_mqtt\_on\_disconnect@{cb\_mqtt\_on\_disconnect}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_disconnect()}{cb\_mqtt\_on\_disconnect()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+disconnect (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+disconnect\+Options\textquotesingle{}s on\+Success. Regardless of the M\+Q\+T\+T\+Async\+\_\+disconnect function\textquotesingle{}s result, the pipeline should be stopped after this callback. 



Definition at line 1303 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a0a13f8bdaa1198220b583ab012a8d8a3_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a8ceece44216de84303b55f04ef859a86}\label{mqttsink_8c_a8ceece44216de84303b55f04ef859a86}} 
\index{mqttsink.c@{mqttsink.c}!cb\_mqtt\_on\_disconnect\_failure@{cb\_mqtt\_on\_disconnect\_failure}}
\index{cb\_mqtt\_on\_disconnect\_failure@{cb\_mqtt\_on\_disconnect\_failure}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_disconnect\_failure()}{cb\_mqtt\_on\_disconnect\_failure()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+disconnect\+\_\+failure (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+disconnect\+Options\textquotesingle{}s on\+Failure. Regardless of the M\+Q\+T\+T\+Async\+\_\+disconnect function\textquotesingle{}s result, the pipeline should be stopped after this callback. 



Definition at line 1320 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a8ceece44216de84303b55f04ef859a86_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a0d9251e9e546ca5dbcb0e3ca51110d15}\label{mqttsink_8c_a0d9251e9e546ca5dbcb0e3ca51110d15}} 
\index{mqttsink.c@{mqttsink.c}!cb\_mqtt\_on\_message\_arrived@{cb\_mqtt\_on\_message\_arrived}}
\index{cb\_mqtt\_on\_message\_arrived@{cb\_mqtt\_on\_message\_arrived}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_message\_arrived()}{cb\_mqtt\_on\_message\_arrived()}}
{\footnotesize\ttfamily static int cb\+\_\+mqtt\+\_\+on\+\_\+message\+\_\+arrived (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{char $\ast$}]{topic\+Name,  }\item[{int}]{topic\+Len,  }\item[{M\+Q\+T\+T\+Async\+\_\+message $\ast$}]{message }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback function to be given to the M\+Q\+T\+T\+Async\+\_\+set\+Callbacks function. In the case of the publisher, this callback is not used. 



Definition at line 1368 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a0d9251e9e546ca5dbcb0e3ca51110d15_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a81620d2cfcb2094cb044b80cb15fb835}\label{mqttsink_8c_a81620d2cfcb2094cb044b80cb15fb835}} 
\index{mqttsink.c@{mqttsink.c}!cb\_mqtt\_on\_send\_failure@{cb\_mqtt\_on\_send\_failure}}
\index{cb\_mqtt\_on\_send\_failure@{cb\_mqtt\_on\_send\_failure}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_send\_failure()}{cb\_mqtt\_on\_send\_failure()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+send\+\_\+failure (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Failure. 



Definition at line 1404 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a81620d2cfcb2094cb044b80cb15fb835_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a8d41ca19f03ded61f4cd2709d6fc23db}\label{mqttsink_8c_a8d41ca19f03ded61f4cd2709d6fc23db}} 
\index{mqttsink.c@{mqttsink.c}!cb\_mqtt\_on\_send\_success@{cb\_mqtt\_on\_send\_success}}
\index{cb\_mqtt\_on\_send\_success@{cb\_mqtt\_on\_send\_success}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_send\_success()}{cb\_mqtt\_on\_send\_success()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+send\+\_\+success (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback function corresponding to M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Success. 



Definition at line 1384 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a8d41ca19f03ded61f4cd2709d6fc23db_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a446884c3b6e4a0899846ec05be47ce81}\label{mqttsink_8c_a446884c3b6e4a0899846ec05be47ce81}} 
\index{mqttsink.c@{mqttsink.c}!G\_DEFINE\_TYPE@{G\_DEFINE\_TYPE}}
\index{G\_DEFINE\_TYPE@{G\_DEFINE\_TYPE}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{G\_DEFINE\_TYPE()}{G\_DEFINE\_TYPE()}}
{\footnotesize\ttfamily G\+\_\+\+D\+E\+F\+I\+N\+E\+\_\+\+T\+Y\+PE (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}}}]{,  }\item[{gst\+\_\+mqtt\+\_\+sink}]{,  }\item[{G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+B\+A\+S\+E\+\_\+\+S\+I\+NK}]{ }\end{DoxyParamCaption})}

\mbox{\Hypertarget{mqttsink_8c_ad2e9db03440272783fb3a753417eedc4}\label{mqttsink_8c_ad2e9db03440272783fb3a753417eedc4}} 
\index{mqttsink.c@{mqttsink.c}!GST\_DEBUG\_CATEGORY\_STATIC@{GST\_DEBUG\_CATEGORY\_STATIC}}
\index{GST\_DEBUG\_CATEGORY\_STATIC@{GST\_DEBUG\_CATEGORY\_STATIC}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{GST\_DEBUG\_CATEGORY\_STATIC()}{GST\_DEBUG\_CATEGORY\_STATIC()}}
{\footnotesize\ttfamily G\+S\+T\+\_\+\+D\+E\+B\+U\+G\+\_\+\+C\+A\+T\+E\+G\+O\+R\+Y\+\_\+\+S\+T\+A\+T\+IC (\begin{DoxyParamCaption}\item[{gst\+\_\+mqtt\+\_\+sink\+\_\+debug}]{ }\end{DoxyParamCaption})}

\mbox{\Hypertarget{mqttsink_8c_a45e3f1a4ca996bfb319218a5a9768ace}\label{mqttsink_8c_a45e3f1a4ca996bfb319218a5a9768ace}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_change\_state@{gst\_mqtt\_sink\_change\_state}}
\index{gst\_mqtt\_sink\_change\_state@{gst\_mqtt\_sink\_change\_state}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_change\_state()}{gst\_mqtt\_sink\_change\_state()}}
{\footnotesize\ttfamily static Gst\+State\+Change\+Return gst\+\_\+mqtt\+\_\+sink\+\_\+change\+\_\+state (\begin{DoxyParamCaption}\item[{Gst\+Element $\ast$}]{element,  }\item[{Gst\+State\+Change}]{transition }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Handle mqttsink\textquotesingle{}s state change. 



Definition at line 491 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a45e3f1a4ca996bfb319218a5a9768ace_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a45e3f1a4ca996bfb319218a5a9768ace_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a212e9187279b4ae469b3128f24d05ac1}\label{mqttsink_8c_a212e9187279b4ae469b3128f24d05ac1}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_class\_finalize@{gst\_mqtt\_sink\_class\_finalize}}
\index{gst\_mqtt\_sink\_class\_finalize@{gst\_mqtt\_sink\_class\_finalize}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_class\_finalize()}{gst\_mqtt\_sink\_class\_finalize()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+class\+\_\+finalize (\begin{DoxyParamCaption}\item[{G\+Object $\ast$}]{object }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Finalize Gst\+Mqtt\+Sink\+Class object. 



Definition at line 454 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=279pt]{mqttsink_8c_a212e9187279b4ae469b3128f24d05ac1_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a212e9187279b4ae469b3128f24d05ac1_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_ad99a4da0c22898b0d677d0ccca352e37}\label{mqttsink_8c_ad99a4da0c22898b0d677d0ccca352e37}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_class\_init@{gst\_mqtt\_sink\_class\_init}}
\index{gst\_mqtt\_sink\_class\_init@{gst\_mqtt\_sink\_class\_init}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_class\_init()}{gst\_mqtt\_sink\_class\_init()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+class\+\_\+init (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_a8e42ae78b176c0877fcb932446611cb8}{Gst\+Mqtt\+Sink\+Class}} $\ast$}]{klass }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Initialize Gst\+Mqtt\+Sink\+Class object. 



Definition at line 229 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[height=550pt]{mqttsink_8c_ad99a4da0c22898b0d677d0ccca352e37_cgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a3080bc2ba662a5ebf37a34190db4da13}\label{mqttsink_8c_a3080bc2ba662a5ebf37a34190db4da13}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_event@{gst\_mqtt\_sink\_event}}
\index{gst\_mqtt\_sink\_event@{gst\_mqtt\_sink\_event}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_event()}{gst\_mqtt\_sink\_event()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+sink\+\_\+event (\begin{DoxyParamCaption}\item[{Gst\+Base\+Sink $\ast$}]{basesink,  }\item[{Gst\+Event $\ast$}]{event }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Handle events arriving on the sink pad. 



Definition at line 898 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a3080bc2ba662a5ebf37a34190db4da13_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a14f3f1987b65bdeb438373ee24bf1770}\label{mqttsink_8c_a14f3f1987b65bdeb438373ee24bf1770}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_client\_id@{gst\_mqtt\_sink\_get\_client\_id}}
\index{gst\_mqtt\_sink\_get\_client\_id@{gst\_mqtt\_sink\_get\_client\_id}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_client\_id()}{gst\_mqtt\_sink\_get\_client\_id()}}
{\footnotesize\ttfamily static gchar $\ast$ gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+client\+\_\+id (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}client-\/id\textquotesingle{} property. 



Definition at line 976 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a14f3f1987b65bdeb438373ee24bf1770_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a8b34f3079a834aa0ace6f2c4a0995a1f}\label{mqttsink_8c_a8b34f3079a834aa0ace6f2c4a0995a1f}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_debug@{gst\_mqtt\_sink\_get\_debug}}
\index{gst\_mqtt\_sink\_get\_debug@{gst\_mqtt\_sink\_get\_debug}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_debug()}{gst\_mqtt\_sink\_get\_debug()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+debug (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}debug\textquotesingle{} property. 



Definition at line 958 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a8b34f3079a834aa0ace6f2c4a0995a1f_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a8630ec547c7e101ea10641b0994137ba}\label{mqttsink_8c_a8630ec547c7e101ea10641b0994137ba}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_host\_address@{gst\_mqtt\_sink\_get\_host\_address}}
\index{gst\_mqtt\_sink\_get\_host\_address@{gst\_mqtt\_sink\_get\_host\_address}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_host\_address()}{gst\_mqtt\_sink\_get\_host\_address()}}
{\footnotesize\ttfamily static gchar $\ast$ gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+host\+\_\+address (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}host\textquotesingle{} property. 



Definition at line 995 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a8630ec547c7e101ea10641b0994137ba_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a848bd59298c2af36ccbaf46e3a39d1ce}\label{mqttsink_8c_a848bd59298c2af36ccbaf46e3a39d1ce}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_host\_port@{gst\_mqtt\_sink\_get\_host\_port}}
\index{gst\_mqtt\_sink\_get\_host\_port@{gst\_mqtt\_sink\_get\_host\_port}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_host\_port()}{gst\_mqtt\_sink\_get\_host\_port()}}
{\footnotesize\ttfamily static gchar $\ast$ gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+host\+\_\+port (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}port\textquotesingle{} property. 



Definition at line 1017 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a848bd59298c2af36ccbaf46e3a39d1ce_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_ae2591fbaee7aea1f59a7f14621daaaf7}\label{mqttsink_8c_ae2591fbaee7aea1f59a7f14621daaaf7}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_max\_msg\_buf\_size@{gst\_mqtt\_sink\_get\_max\_msg\_buf\_size}}
\index{gst\_mqtt\_sink\_get\_max\_msg\_buf\_size@{gst\_mqtt\_sink\_get\_max\_msg\_buf\_size}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_max\_msg\_buf\_size()}{gst\_mqtt\_sink\_get\_max\_msg\_buf\_size()}}
{\footnotesize\ttfamily static gsize gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+max\+\_\+msg\+\_\+buf\+\_\+size (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}max-\/buffer-\/size\textquotesingle{} property. 



Definition at line 1109 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_ae2591fbaee7aea1f59a7f14621daaaf7_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_ae6d3ba1d312db2ede64042d3b3aadd7f}\label{mqttsink_8c_ae6d3ba1d312db2ede64042d3b3aadd7f}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_mqtt\_ntp\_srvs@{gst\_mqtt\_sink\_get\_mqtt\_ntp\_srvs}}
\index{gst\_mqtt\_sink\_get\_mqtt\_ntp\_srvs@{gst\_mqtt\_sink\_get\_mqtt\_ntp\_srvs}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_mqtt\_ntp\_srvs()}{gst\_mqtt\_sink\_get\_mqtt\_ntp\_srvs()}}
{\footnotesize\ttfamily static gchar $\ast$ gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+mqtt\+\_\+ntp\+\_\+srvs (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}ntp-\/srvs\textquotesingle{} property. 



Definition at line 1185 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_ae6d3ba1d312db2ede64042d3b3aadd7f_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a1203251ce25e17dd2f911821d1ea2d70}\label{mqttsink_8c_a1203251ce25e17dd2f911821d1ea2d70}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_mqtt\_ntp\_sync@{gst\_mqtt\_sink\_get\_mqtt\_ntp\_sync}}
\index{gst\_mqtt\_sink\_get\_mqtt\_ntp\_sync@{gst\_mqtt\_sink\_get\_mqtt\_ntp\_sync}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_mqtt\_ntp\_sync()}{gst\_mqtt\_sink\_get\_mqtt\_ntp\_sync()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+mqtt\+\_\+ntp\+\_\+sync (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}ntp-\/sync\textquotesingle{} property. 



Definition at line 1167 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a1203251ce25e17dd2f911821d1ea2d70_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a52f797e11bf9b1b0db40fbb657c88295}\label{mqttsink_8c_a52f797e11bf9b1b0db40fbb657c88295}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_mqtt\_qos@{gst\_mqtt\_sink\_get\_mqtt\_qos}}
\index{gst\_mqtt\_sink\_get\_mqtt\_qos@{gst\_mqtt\_sink\_get\_mqtt\_qos}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_mqtt\_qos()}{gst\_mqtt\_sink\_get\_mqtt\_qos()}}
{\footnotesize\ttfamily static gint gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+mqtt\+\_\+qos (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}mqtt-\/qos\textquotesingle{} property. 



Definition at line 1149 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a52f797e11bf9b1b0db40fbb657c88295_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a17a7395b0868f8cf4070fcb761a4dde4}\label{mqttsink_8c_a17a7395b0868f8cf4070fcb761a4dde4}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_num\_buffers@{gst\_mqtt\_sink\_get\_num\_buffers}}
\index{gst\_mqtt\_sink\_get\_num\_buffers@{gst\_mqtt\_sink\_get\_num\_buffers}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_num\_buffers()}{gst\_mqtt\_sink\_get\_num\_buffers()}}
{\footnotesize\ttfamily static gint gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+num\+\_\+buffers (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}num-\/buffers\textquotesingle{} property. 



Definition at line 1127 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a17a7395b0868f8cf4070fcb761a4dde4_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a0ebee221306a8610d720141bc34d7d96}\label{mqttsink_8c_a0ebee221306a8610d720141bc34d7d96}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_opt\_cleansession@{gst\_mqtt\_sink\_get\_opt\_cleansession}}
\index{gst\_mqtt\_sink\_get\_opt\_cleansession@{gst\_mqtt\_sink\_get\_opt\_cleansession}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_opt\_cleansession()}{gst\_mqtt\_sink\_get\_opt\_cleansession()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+opt\+\_\+cleansession (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}cleansession\textquotesingle{} property. 



Definition at line 1055 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a0ebee221306a8610d720141bc34d7d96_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a3ac8d0f930067295dfcdceef969f500a}\label{mqttsink_8c_a3ac8d0f930067295dfcdceef969f500a}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_opt\_keep\_alive\_interval@{gst\_mqtt\_sink\_get\_opt\_keep\_alive\_interval}}
\index{gst\_mqtt\_sink\_get\_opt\_keep\_alive\_interval@{gst\_mqtt\_sink\_get\_opt\_keep\_alive\_interval}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_opt\_keep\_alive\_interval()}{gst\_mqtt\_sink\_get\_opt\_keep\_alive\_interval()}}
{\footnotesize\ttfamily static gint gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+opt\+\_\+keep\+\_\+alive\+\_\+interval (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}keep-\/alive-\/interval\textquotesingle{} property. 



Definition at line 1091 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a3ac8d0f930067295dfcdceef969f500a_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_adda4e8ece8bf03f2a180eb4e8379b0f9}\label{mqttsink_8c_adda4e8ece8bf03f2a180eb4e8379b0f9}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_property@{gst\_mqtt\_sink\_get\_property}}
\index{gst\_mqtt\_sink\_get\_property@{gst\_mqtt\_sink\_get\_property}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_property()}{gst\_mqtt\_sink\_get\_property()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+property (\begin{DoxyParamCaption}\item[{G\+Object $\ast$}]{object,  }\item[{guint}]{prop\+\_\+id,  }\item[{G\+Value $\ast$}]{value,  }\item[{G\+Param\+Spec $\ast$}]{pspec }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



The getter for the mqttsink\textquotesingle{}s properties. 



Definition at line 399 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[height=550pt]{mqttsink_8c_adda4e8ece8bf03f2a180eb4e8379b0f9_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_adda4e8ece8bf03f2a180eb4e8379b0f9_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a13ca7457ccd4555f29490a802ef7859f}\label{mqttsink_8c_a13ca7457ccd4555f29490a802ef7859f}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_pub\_topic@{gst\_mqtt\_sink\_get\_pub\_topic}}
\index{gst\_mqtt\_sink\_get\_pub\_topic@{gst\_mqtt\_sink\_get\_pub\_topic}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_pub\_topic()}{gst\_mqtt\_sink\_get\_pub\_topic()}}
{\footnotesize\ttfamily static gchar $\ast$ gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+pub\+\_\+topic (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}pub-\/topic\textquotesingle{} property. 



Definition at line 1036 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a13ca7457ccd4555f29490a802ef7859f_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a19417a2cfad2bd8e87fe9f5f2d968f94}\label{mqttsink_8c_a19417a2cfad2bd8e87fe9f5f2d968f94}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_get\_pub\_wait\_timeout@{gst\_mqtt\_sink\_get\_pub\_wait\_timeout}}
\index{gst\_mqtt\_sink\_get\_pub\_wait\_timeout@{gst\_mqtt\_sink\_get\_pub\_wait\_timeout}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_get\_pub\_wait\_timeout()}{gst\_mqtt\_sink\_get\_pub\_wait\_timeout()}}
{\footnotesize\ttfamily static gulong gst\+\_\+mqtt\+\_\+sink\+\_\+get\+\_\+pub\+\_\+wait\+\_\+timeout (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}pub-\/wait-\/timeout\textquotesingle{} property. 



Definition at line 1073 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a19417a2cfad2bd8e87fe9f5f2d968f94_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a84d9d3bfe28b20306516a5be8705f693}\label{mqttsink_8c_a84d9d3bfe28b20306516a5be8705f693}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_init@{gst\_mqtt\_sink\_init}}
\index{gst\_mqtt\_sink\_init@{gst\_mqtt\_sink\_init}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_init()}{gst\_mqtt\_sink\_init()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+init (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Initialize Gst\+Mqtt\+Sink object. 

init M\+Q\+TT related variables

init private variables

init mqttsink properties

init basesink properties

Definition at line 171 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a84d9d3bfe28b20306516a5be8705f693_cgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a2836c285ad0197c865f6b78b72f935ed}\label{mqttsink_8c_a2836c285ad0197c865f6b78b72f935ed}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_query@{gst\_mqtt\_sink\_query}}
\index{gst\_mqtt\_sink\_query@{gst\_mqtt\_sink\_query}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_query()}{gst\_mqtt\_sink\_query()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+sink\+\_\+query (\begin{DoxyParamCaption}\item[{Gst\+Base\+Sink $\ast$}]{basesink,  }\item[{Gst\+Query $\ast$}]{query }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Perform queries on the element. 



Definition at line 661 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a2836c285ad0197c865f6b78b72f935ed_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a6b4f078dca25799d9268ab8131f62135}\label{mqttsink_8c_a6b4f078dca25799d9268ab8131f62135}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_render@{gst\_mqtt\_sink\_render}}
\index{gst\_mqtt\_sink\_render@{gst\_mqtt\_sink\_render}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_render()}{gst\_mqtt\_sink\_render()}}
{\footnotesize\ttfamily static Gst\+Flow\+Return gst\+\_\+mqtt\+\_\+sink\+\_\+render (\begin{DoxyParamCaption}\item[{Gst\+Base\+Sink $\ast$}]{basesink,  }\item[{Gst\+Buffer $\ast$}]{buffer }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



The callback to process each buffer receiving on the sink pad. 

Allocate a message buffer

Definition at line 751 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a6b4f078dca25799d9268ab8131f62135_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a6b4f078dca25799d9268ab8131f62135_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a9c8d34e33ab06a590efee97dd59c55c6}\label{mqttsink_8c_a9c8d34e33ab06a590efee97dd59c55c6}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_render\_list@{gst\_mqtt\_sink\_render\_list}}
\index{gst\_mqtt\_sink\_render\_list@{gst\_mqtt\_sink\_render\_list}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_render\_list()}{gst\_mqtt\_sink\_render\_list()}}
{\footnotesize\ttfamily static Gst\+Flow\+Return gst\+\_\+mqtt\+\_\+sink\+\_\+render\+\_\+list (\begin{DoxyParamCaption}\item[{Gst\+Base\+Sink $\ast$}]{basesink,  }\item[{Gst\+Buffer\+List $\ast$}]{list }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



The callback to process Gst\+Buffer\+List (instead of a single buffer) on the sink pad. 



Definition at line 877 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a9c8d34e33ab06a590efee97dd59c55c6_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a9c8d34e33ab06a590efee97dd59c55c6_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a7f5f4f9bd130074a34ccace77e57466b}\label{mqttsink_8c_a7f5f4f9bd130074a34ccace77e57466b}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_caps@{gst\_mqtt\_sink\_set\_caps}}
\index{gst\_mqtt\_sink\_set\_caps@{gst\_mqtt\_sink\_set\_caps}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_caps()}{gst\_mqtt\_sink\_set\_caps()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+caps (\begin{DoxyParamCaption}\item[{Gst\+Base\+Sink $\ast$}]{basesink,  }\item[{Gst\+Caps $\ast$}]{caps }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



An implementation of the set\+\_\+caps vmethod in Gst\+Base\+Sink\+Class. 



Definition at line 924 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=297pt]{mqttsink_8c_a7f5f4f9bd130074a34ccace77e57466b_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a7f5f4f9bd130074a34ccace77e57466b_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_af8da02029fabce70bccc38e90705de44}\label{mqttsink_8c_af8da02029fabce70bccc38e90705de44}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_client\_id@{gst\_mqtt\_sink\_set\_client\_id}}
\index{gst\_mqtt\_sink\_set\_client\_id@{gst\_mqtt\_sink\_set\_client\_id}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_client\_id()}{gst\_mqtt\_sink\_set\_client\_id()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+client\+\_\+id (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gchar $\ast$}]{id }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}client-\/id\textquotesingle{} property. 



Definition at line 985 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=315pt]{mqttsink_8c_af8da02029fabce70bccc38e90705de44_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_af8da02029fabce70bccc38e90705de44_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_af02f1d4a1d6204f8a10e6543c8554c61}\label{mqttsink_8c_af02f1d4a1d6204f8a10e6543c8554c61}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_debug@{gst\_mqtt\_sink\_set\_debug}}
\index{gst\_mqtt\_sink\_set\_debug@{gst\_mqtt\_sink\_set\_debug}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_debug()}{gst\_mqtt\_sink\_set\_debug()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+debug (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gboolean}]{flag }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}debug\textquotesingle{} property. 



Definition at line 967 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_af02f1d4a1d6204f8a10e6543c8554c61_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a7b378bb6e2e458ed9cf97fd37c0b4e48}\label{mqttsink_8c_a7b378bb6e2e458ed9cf97fd37c0b4e48}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_host\_address@{gst\_mqtt\_sink\_set\_host\_address}}
\index{gst\_mqtt\_sink\_set\_host\_address@{gst\_mqtt\_sink\_set\_host\_address}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_host\_address()}{gst\_mqtt\_sink\_set\_host\_address()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+host\+\_\+address (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gchar $\ast$}]{addr }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}host\textquotesingle{} property. 

\begin{DoxyRefDesc}{Todo}
\item[\mbox{\hyperlink{todo__todo000002}{Todo}}]Handle the case where the addr is changed at runtime \end{DoxyRefDesc}


Definition at line 1004 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=295pt]{mqttsink_8c_a7b378bb6e2e458ed9cf97fd37c0b4e48_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a7b378bb6e2e458ed9cf97fd37c0b4e48_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_ac225e69c01dad0b85df1838322f59ddb}\label{mqttsink_8c_ac225e69c01dad0b85df1838322f59ddb}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_host\_port@{gst\_mqtt\_sink\_set\_host\_port}}
\index{gst\_mqtt\_sink\_set\_host\_port@{gst\_mqtt\_sink\_set\_host\_port}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_host\_port()}{gst\_mqtt\_sink\_set\_host\_port()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+host\+\_\+port (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gchar $\ast$}]{port }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}port\textquotesingle{} property. 



Definition at line 1026 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=320pt]{mqttsink_8c_ac225e69c01dad0b85df1838322f59ddb_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_ac225e69c01dad0b85df1838322f59ddb_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_aa07d26953b9749db2c4131df0c662de7}\label{mqttsink_8c_aa07d26953b9749db2c4131df0c662de7}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_max\_msg\_buf\_size@{gst\_mqtt\_sink\_set\_max\_msg\_buf\_size}}
\index{gst\_mqtt\_sink\_set\_max\_msg\_buf\_size@{gst\_mqtt\_sink\_set\_max\_msg\_buf\_size}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_max\_msg\_buf\_size()}{gst\_mqtt\_sink\_set\_max\_msg\_buf\_size()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+max\+\_\+msg\+\_\+buf\+\_\+size (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gsize}]{size }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}max-\/buffer-\/size\textquotesingle{} property. 



Definition at line 1118 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_aa07d26953b9749db2c4131df0c662de7_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_aff65b6f2e29ee4f8886207c2ead6354c}\label{mqttsink_8c_aff65b6f2e29ee4f8886207c2ead6354c}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_mqtt\_ntp\_srvs@{gst\_mqtt\_sink\_set\_mqtt\_ntp\_srvs}}
\index{gst\_mqtt\_sink\_set\_mqtt\_ntp\_srvs@{gst\_mqtt\_sink\_set\_mqtt\_ntp\_srvs}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_mqtt\_ntp\_srvs()}{gst\_mqtt\_sink\_set\_mqtt\_ntp\_srvs()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+mqtt\+\_\+ntp\+\_\+srvs (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gchar $\ast$}]{pairs }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}ntp-\/srvs\textquotesingle{} property. 



Definition at line 1194 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=297pt]{mqttsink_8c_aff65b6f2e29ee4f8886207c2ead6354c_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_aff65b6f2e29ee4f8886207c2ead6354c_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_ad73ceb171ab90d9de8ae0878e58c4470}\label{mqttsink_8c_ad73ceb171ab90d9de8ae0878e58c4470}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_mqtt\_ntp\_sync@{gst\_mqtt\_sink\_set\_mqtt\_ntp\_sync}}
\index{gst\_mqtt\_sink\_set\_mqtt\_ntp\_sync@{gst\_mqtt\_sink\_set\_mqtt\_ntp\_sync}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_mqtt\_ntp\_sync()}{gst\_mqtt\_sink\_set\_mqtt\_ntp\_sync()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+mqtt\+\_\+ntp\+\_\+sync (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gboolean}]{flag }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}ntp-\/sync\textquotesingle{} property. 



Definition at line 1176 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_ad73ceb171ab90d9de8ae0878e58c4470_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_abc37bb8fe4c3c8a2a65f94bd28f0e187}\label{mqttsink_8c_abc37bb8fe4c3c8a2a65f94bd28f0e187}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_mqtt\_qos@{gst\_mqtt\_sink\_set\_mqtt\_qos}}
\index{gst\_mqtt\_sink\_set\_mqtt\_qos@{gst\_mqtt\_sink\_set\_mqtt\_qos}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_mqtt\_qos()}{gst\_mqtt\_sink\_set\_mqtt\_qos()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+mqtt\+\_\+qos (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gint}]{qos }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}mqtt-\/qos\textquotesingle{} property. 



Definition at line 1158 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_abc37bb8fe4c3c8a2a65f94bd28f0e187_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_af67a8f119649f1bc4531aa874cc4e2bf}\label{mqttsink_8c_af67a8f119649f1bc4531aa874cc4e2bf}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_num\_buffers@{gst\_mqtt\_sink\_set\_num\_buffers}}
\index{gst\_mqtt\_sink\_set\_num\_buffers@{gst\_mqtt\_sink\_set\_num\_buffers}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_num\_buffers()}{gst\_mqtt\_sink\_set\_num\_buffers()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+num\+\_\+buffers (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gint}]{num }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}num-\/buffers\textquotesingle{} property. 



Definition at line 1140 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_af67a8f119649f1bc4531aa874cc4e2bf_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a4b8ba78d41a91612cb00ad0485280725}\label{mqttsink_8c_a4b8ba78d41a91612cb00ad0485280725}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_opt\_cleansession@{gst\_mqtt\_sink\_set\_opt\_cleansession}}
\index{gst\_mqtt\_sink\_set\_opt\_cleansession@{gst\_mqtt\_sink\_set\_opt\_cleansession}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_opt\_cleansession()}{gst\_mqtt\_sink\_set\_opt\_cleansession()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+opt\+\_\+cleansession (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gboolean}]{val }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}cleansession\textquotesingle{} property. 



Definition at line 1064 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a4b8ba78d41a91612cb00ad0485280725_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a86a86b830fb8ca6aa60e2ad39093e5c7}\label{mqttsink_8c_a86a86b830fb8ca6aa60e2ad39093e5c7}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_opt\_keep\_alive\_interval@{gst\_mqtt\_sink\_set\_opt\_keep\_alive\_interval}}
\index{gst\_mqtt\_sink\_set\_opt\_keep\_alive\_interval@{gst\_mqtt\_sink\_set\_opt\_keep\_alive\_interval}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_opt\_keep\_alive\_interval()}{gst\_mqtt\_sink\_set\_opt\_keep\_alive\_interval()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+opt\+\_\+keep\+\_\+alive\+\_\+interval (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gint}]{num }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}keep-\/alive-\/interval\textquotesingle{} property. 



Definition at line 1100 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a86a86b830fb8ca6aa60e2ad39093e5c7_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a512a632468de7eb9c8be567653ac1a50}\label{mqttsink_8c_a512a632468de7eb9c8be567653ac1a50}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_property@{gst\_mqtt\_sink\_set\_property}}
\index{gst\_mqtt\_sink\_set\_property@{gst\_mqtt\_sink\_set\_property}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_property()}{gst\_mqtt\_sink\_set\_property()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+property (\begin{DoxyParamCaption}\item[{G\+Object $\ast$}]{object,  }\item[{guint}]{prop\+\_\+id,  }\item[{const G\+Value $\ast$}]{value,  }\item[{G\+Param\+Spec $\ast$}]{pspec }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



The setter for the mqttsink\textquotesingle{}s properties. 

Function prototype declarations 

Definition at line 344 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a512a632468de7eb9c8be567653ac1a50_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a512a632468de7eb9c8be567653ac1a50_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a849521ce7de32553b2a1c464ed7fefe9}\label{mqttsink_8c_a849521ce7de32553b2a1c464ed7fefe9}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_pub\_topic@{gst\_mqtt\_sink\_set\_pub\_topic}}
\index{gst\_mqtt\_sink\_set\_pub\_topic@{gst\_mqtt\_sink\_set\_pub\_topic}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_pub\_topic()}{gst\_mqtt\_sink\_set\_pub\_topic()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+pub\+\_\+topic (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gchar $\ast$}]{topic }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}pub-\/topic\textquotesingle{} property. 



Definition at line 1045 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=292pt]{mqttsink_8c_a849521ce7de32553b2a1c464ed7fefe9_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a849521ce7de32553b2a1c464ed7fefe9_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_adc88a227f9366dd080f76f0906d9b5e1}\label{mqttsink_8c_adc88a227f9366dd080f76f0906d9b5e1}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_set\_pub\_wait\_timeout@{gst\_mqtt\_sink\_set\_pub\_wait\_timeout}}
\index{gst\_mqtt\_sink\_set\_pub\_wait\_timeout@{gst\_mqtt\_sink\_set\_pub\_wait\_timeout}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_set\_pub\_wait\_timeout()}{gst\_mqtt\_sink\_set\_pub\_wait\_timeout()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+sink\+\_\+set\+\_\+pub\+\_\+wait\+\_\+timeout (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsink_8h_ac5b6721bc3cdf8023dc047985f344292}{Gst\+Mqtt\+Sink}} $\ast$}]{self,  }\item[{const gulong}]{to }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}pub-\/wait-\/timeout\textquotesingle{} property. 



Definition at line 1082 of file mqttsink.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_adc88a227f9366dd080f76f0906d9b5e1_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a7094cca07819556c382d454fcd9e2c76}\label{mqttsink_8c_a7094cca07819556c382d454fcd9e2c76}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_start@{gst\_mqtt\_sink\_start}}
\index{gst\_mqtt\_sink\_start@{gst\_mqtt\_sink\_start}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_start()}{gst\_mqtt\_sink\_start()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+sink\+\_\+start (\begin{DoxyParamCaption}\item[{Gst\+Base\+Sink $\ast$}]{basesink }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Start mqttsink, called when state changed null to ready. 

\begin{DoxyRefDesc}{Todo}
\item[\mbox{\hyperlink{todo__todo000001}{Todo}}]Support other persistence mechanisms M\+Q\+T\+T\+C\+L\+I\+E\+N\+T\+\_\+\+P\+E\+R\+S\+I\+S\+T\+E\+N\+C\+E\+\_\+\+N\+O\+NE\+: A memory-\/based persistence mechanism M\+Q\+T\+T\+C\+L\+I\+E\+N\+T\+\_\+\+P\+E\+R\+S\+I\+S\+T\+E\+N\+C\+E\+\_\+\+D\+E\+F\+A\+U\+LT\+: The default file system-\/based persistence mechanism M\+Q\+T\+T\+C\+L\+I\+E\+N\+T\+\_\+\+P\+E\+R\+S\+I\+S\+T\+E\+N\+C\+E\+\_\+\+U\+S\+ER\+: An application-\/specific persistence mechanism \end{DoxyRefDesc}


Definition at line 554 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a7094cca07819556c382d454fcd9e2c76_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a7094cca07819556c382d454fcd9e2c76_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsink_8c_a0153e8f1598015ef892e2e072db97ea5}\label{mqttsink_8c_a0153e8f1598015ef892e2e072db97ea5}} 
\index{mqttsink.c@{mqttsink.c}!gst\_mqtt\_sink\_stop@{gst\_mqtt\_sink\_stop}}
\index{gst\_mqtt\_sink\_stop@{gst\_mqtt\_sink\_stop}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_sink\_stop()}{gst\_mqtt\_sink\_stop()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+sink\+\_\+stop (\begin{DoxyParamCaption}\item[{Gst\+Base\+Sink $\ast$}]{basesink }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Stop mqttsink, called when state changed ready to null. 



Definition at line 623 of file mqttsink.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a0153e8f1598015ef892e2e072db97ea5_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsink_8c_a0153e8f1598015ef892e2e072db97ea5_icgraph}
\end{center}
\end{figure}


\doxysubsection{Variable Documentation}
\mbox{\Hypertarget{mqttsink_8c_ad7802f55a92df9e9b9d3cfd5e2fb11bf}\label{mqttsink_8c_ad7802f55a92df9e9b9d3cfd5e2fb11bf}} 
\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_CLIENT\_ID@{DEFAULT\_MQTT\_CLIENT\_ID}}
\index{DEFAULT\_MQTT\_CLIENT\_ID@{DEFAULT\_MQTT\_CLIENT\_ID}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{DEFAULT\_MQTT\_CLIENT\_ID}{DEFAULT\_MQTT\_CLIENT\_ID}}
{\footnotesize\ttfamily const gchar D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+ID\mbox{[}$\,$\mbox{]} = \char`\"{}\$H\+O\+S\+T\+\_\+\$\+P\+I\+D\+\_\+$^\wedge$\mbox{[}0-\/9\mbox{]}\mbox{[}0-\/9\mbox{]}?\$$\vert$$^\wedge$255\$\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 85 of file mqttsink.\+c.

\mbox{\Hypertarget{mqttsink_8c_acf4f9062c5331fe5613e31c923468e30}\label{mqttsink_8c_acf4f9062c5331fe5613e31c923468e30}} 
\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT@{DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT}}
\index{DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT@{DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT}{DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT}}
{\footnotesize\ttfamily const gchar D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+I\+D\+\_\+\+F\+O\+R\+M\+AT\mbox{[}$\,$\mbox{]} = \char`\"{}\%s\+\_\+\%u\+\_\+sink\%u\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 86 of file mqttsink.\+c.

\mbox{\Hypertarget{mqttsink_8c_adb7c1d7abe7c50e461f495f2b6b9adbc}\label{mqttsink_8c_adb7c1d7abe7c50e461f495f2b6b9adbc}} 
\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_HOST\_ADDRESS@{DEFAULT\_MQTT\_HOST\_ADDRESS}}
\index{DEFAULT\_MQTT\_HOST\_ADDRESS@{DEFAULT\_MQTT\_HOST\_ADDRESS}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{DEFAULT\_MQTT\_HOST\_ADDRESS}{DEFAULT\_MQTT\_HOST\_ADDRESS}}
{\footnotesize\ttfamily const gchar D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+A\+D\+D\+R\+E\+SS\mbox{[}$\,$\mbox{]} = \char`\"{}127.\+0.\+0.\+1\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 82 of file mqttsink.\+c.

\mbox{\Hypertarget{mqttsink_8c_a782553475a8ab1e231242a2ab4fcd43f}\label{mqttsink_8c_a782553475a8ab1e231242a2ab4fcd43f}} 
\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_HOST\_PORT@{DEFAULT\_MQTT\_HOST\_PORT}}
\index{DEFAULT\_MQTT\_HOST\_PORT@{DEFAULT\_MQTT\_HOST\_PORT}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{DEFAULT\_MQTT\_HOST\_PORT}{DEFAULT\_MQTT\_HOST\_PORT}}
{\footnotesize\ttfamily const gchar D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+P\+O\+RT\mbox{[}$\,$\mbox{]} = \char`\"{}1883\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 83 of file mqttsink.\+c.

\mbox{\Hypertarget{mqttsink_8c_a18bad0d631a1a2e27fe43a9f1600d862}\label{mqttsink_8c_a18bad0d631a1a2e27fe43a9f1600d862}} 
\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_NTP\_SERVERS@{DEFAULT\_MQTT\_NTP\_SERVERS}}
\index{DEFAULT\_MQTT\_NTP\_SERVERS@{DEFAULT\_MQTT\_NTP\_SERVERS}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{DEFAULT\_MQTT\_NTP\_SERVERS}{DEFAULT\_MQTT\_NTP\_SERVERS}}
{\footnotesize\ttfamily const gchar D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+N\+T\+P\+\_\+\+S\+E\+R\+V\+E\+RS\mbox{[}$\,$\mbox{]} = \char`\"{}pool.\+ntp.\+org\+:123\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 89 of file mqttsink.\+c.

\mbox{\Hypertarget{mqttsink_8c_a8fe55f82926f7d81e8ca99903b89e944}\label{mqttsink_8c_a8fe55f82926f7d81e8ca99903b89e944}} 
\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_PUB\_TOPIC@{DEFAULT\_MQTT\_PUB\_TOPIC}}
\index{DEFAULT\_MQTT\_PUB\_TOPIC@{DEFAULT\_MQTT\_PUB\_TOPIC}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{DEFAULT\_MQTT\_PUB\_TOPIC}{DEFAULT\_MQTT\_PUB\_TOPIC}}
{\footnotesize\ttfamily const gchar D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+P\+U\+B\+\_\+\+T\+O\+P\+IC\mbox{[}$\,$\mbox{]} = \char`\"{}\$client-\/id/topic\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 87 of file mqttsink.\+c.

\mbox{\Hypertarget{mqttsink_8c_a79081b9c55a5af6166b02d133af346e0}\label{mqttsink_8c_a79081b9c55a5af6166b02d133af346e0}} 
\index{mqttsink.c@{mqttsink.c}!DEFAULT\_MQTT\_PUB\_TOPIC\_FORMAT@{DEFAULT\_MQTT\_PUB\_TOPIC\_FORMAT}}
\index{DEFAULT\_MQTT\_PUB\_TOPIC\_FORMAT@{DEFAULT\_MQTT\_PUB\_TOPIC\_FORMAT}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{DEFAULT\_MQTT\_PUB\_TOPIC\_FORMAT}{DEFAULT\_MQTT\_PUB\_TOPIC\_FORMAT}}
{\footnotesize\ttfamily const gchar D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+P\+U\+B\+\_\+\+T\+O\+P\+I\+C\+\_\+\+F\+O\+R\+M\+AT\mbox{[}$\,$\mbox{]} = \char`\"{}\%s/topic\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 88 of file mqttsink.\+c.

\mbox{\Hypertarget{mqttsink_8c_a012d33d4cc636f79991b60a45766d1f4}\label{mqttsink_8c_a012d33d4cc636f79991b60a45766d1f4}} 
\index{mqttsink.c@{mqttsink.c}!sink\_client\_id@{sink\_client\_id}}
\index{sink\_client\_id@{sink\_client\_id}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{sink\_client\_id}{sink\_client\_id}}
{\footnotesize\ttfamily guint8 sink\+\_\+client\+\_\+id = 0\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 81 of file mqttsink.\+c.

\mbox{\Hypertarget{mqttsink_8c_a0be0d54e5dfda4b5ee0fe40c0002d47e}\label{mqttsink_8c_a0be0d54e5dfda4b5ee0fe40c0002d47e}} 
\index{mqttsink.c@{mqttsink.c}!sink\_pad\_template@{sink\_pad\_template}}
\index{sink\_pad\_template@{sink\_pad\_template}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{sink\_pad\_template}{sink\_pad\_template}}
{\footnotesize\ttfamily Gst\+Static\+Pad\+Template sink\+\_\+pad\+\_\+template\hspace{0.3cm}{\ttfamily [static]}}

{\bfseries Initial value\+:}
\begin{DoxyCode}{0}
\DoxyCodeLine{= GST\_STATIC\_PAD\_TEMPLATE (\textcolor{stringliteral}{"sink"},}
\DoxyCodeLine{    GST\_PAD\_SINK, GST\_PAD\_ALWAYS, GST\_STATIC\_CAPS\_ANY)}

\end{DoxyCode}


Definition at line 35 of file mqttsink.\+c.

\mbox{\Hypertarget{mqttsink_8c_a70bd54d26129acad3ade3d7200f3e771}\label{mqttsink_8c_a70bd54d26129acad3ade3d7200f3e771}} 
\index{mqttsink.c@{mqttsink.c}!TAG\_ERR\_MQTTSINK@{TAG\_ERR\_MQTTSINK}}
\index{TAG\_ERR\_MQTTSINK@{TAG\_ERR\_MQTTSINK}!mqttsink.c@{mqttsink.c}}
\doxysubsubsection{\texorpdfstring{TAG\_ERR\_MQTTSINK}{TAG\_ERR\_MQTTSINK}}
{\footnotesize\ttfamily const gchar T\+A\+G\+\_\+\+E\+R\+R\+\_\+\+M\+Q\+T\+T\+S\+I\+NK\mbox{[}$\,$\mbox{]} = \char`\"{}E\+R\+R\+O\+R\+: M\+Q\+T\+T\+Sink\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 84 of file mqttsink.\+c.

