\hypertarget{mqttsrc_8h}{}\doxysection{mqtt/mqttsrc.h File Reference}
\label{mqttsrc_8h}\index{mqtt/mqttsrc.h@{mqtt/mqttsrc.h}}


Subscribe a M\+Q\+TT topic and push incoming data to the G\+Streamer pipeline.  


{\ttfamily \#include $<$gst/base/gstbasesrc.\+h$>$}\newline
{\ttfamily \#include $<$gst/base/gstdataqueue.\+h$>$}\newline
{\ttfamily \#include $<$gst/gst.\+h$>$}\newline
{\ttfamily \#include $<$M\+Q\+T\+T\+Async.\+h$>$}\newline
{\ttfamily \#include \char`\"{}mqttcommon.\+h\char`\"{}}\newline
Include dependency graph for mqttsrc.\+h\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8h__incl}
\end{center}
\end{figure}
This graph shows which files directly or indirectly include this file\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=308pt]{mqttsrc_8h__dep__incl}
\end{center}
\end{figure}
\doxysubsection*{Classes}
\begin{DoxyCompactItemize}
\item 
struct \mbox{\hyperlink{struct__GstMqttSrc}{\+\_\+\+Gst\+Mqtt\+Src}}
\begin{DoxyCompactList}\small\item\em Gst\+Mqtt\+Src data structure. \end{DoxyCompactList}\item 
struct \mbox{\hyperlink{struct__GstMqttSrcClass}{\+\_\+\+Gst\+Mqtt\+Src\+Class}}
\begin{DoxyCompactList}\small\item\em Gst\+Mqtt\+Src\+Class data structure. \end{DoxyCompactList}\end{DoxyCompactItemize}
\doxysubsection*{Macros}
\begin{DoxyCompactItemize}
\item 
\#define \mbox{\hyperlink{mqttsrc_8h_a8a8501891d570f14aa08d84cde4db804}{G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC}}~(\mbox{\hyperlink{mqttsrc_8h_a548a425f4925a785276e42c7569f27ce}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+type}}())
\item 
\#define \mbox{\hyperlink{mqttsrc_8h_a5118a8004b700e38fca220ccee241938}{G\+S\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC}}(obj)~(G\+\_\+\+T\+Y\+P\+E\+\_\+\+C\+H\+E\+C\+K\+\_\+\+I\+N\+S\+T\+A\+N\+C\+E\+\_\+\+C\+A\+ST ((obj), \mbox{\hyperlink{mqttsrc_8h_a8a8501891d570f14aa08d84cde4db804}{G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC}}, \mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}}))
\item 
\#define \mbox{\hyperlink{mqttsrc_8h_a578ca2877da3d493d00435a64a393721}{G\+S\+T\+\_\+\+I\+S\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC}}(obj)~(G\+\_\+\+T\+Y\+P\+E\+\_\+\+C\+H\+E\+C\+K\+\_\+\+I\+N\+S\+T\+A\+N\+C\+E\+\_\+\+T\+Y\+PE ((obj), \mbox{\hyperlink{mqttsrc_8h_a8a8501891d570f14aa08d84cde4db804}{G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC}}))
\item 
\#define \mbox{\hyperlink{mqttsrc_8h_aa39b8a7ecda3aec34c99f6c648b15078}{G\+S\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+R\+C\+\_\+\+C\+A\+ST}}(obj)~((\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$) obj)
\item 
\#define \mbox{\hyperlink{mqttsrc_8h_a4262f18e0fa8d9ca198a6d0cb0e20481}{G\+S\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+R\+C\+\_\+\+C\+L\+A\+SS}}(klass)~(G\+\_\+\+T\+Y\+P\+E\+\_\+\+C\+H\+E\+C\+K\+\_\+\+C\+L\+A\+S\+S\+\_\+\+C\+A\+ST ((klass), \mbox{\hyperlink{mqttsrc_8h_a8a8501891d570f14aa08d84cde4db804}{G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC}}, \mbox{\hyperlink{mqttsrc_8h_af3dd6005e7d4f293d044445ccff99cb0}{Gst\+Mqtt\+Src\+Class}}))
\item 
\#define \mbox{\hyperlink{mqttsrc_8h_a481b5cae5dd3c54c940588ca5184ae05}{G\+S\+T\+\_\+\+I\+S\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+R\+C\+\_\+\+C\+L\+A\+SS}}(klass)~(G\+\_\+\+T\+Y\+P\+E\+\_\+\+C\+H\+E\+C\+K\+\_\+\+C\+L\+A\+S\+S\+\_\+\+T\+Y\+PE ((klass), \mbox{\hyperlink{mqttsrc_8h_a8a8501891d570f14aa08d84cde4db804}{G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC}}))
\end{DoxyCompactItemize}
\doxysubsection*{Typedefs}
\begin{DoxyCompactItemize}
\item 
typedef struct \mbox{\hyperlink{struct__GstMqttSrc}{\+\_\+\+Gst\+Mqtt\+Src}} \mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}}
\item 
typedef struct \mbox{\hyperlink{struct__GstMqttSrcClass}{\+\_\+\+Gst\+Mqtt\+Src\+Class}} \mbox{\hyperlink{mqttsrc_8h_af3dd6005e7d4f293d044445ccff99cb0}{Gst\+Mqtt\+Src\+Class}}
\end{DoxyCompactItemize}
\doxysubsection*{Functions}
\begin{DoxyCompactItemize}
\item 
G\+Type \mbox{\hyperlink{mqttsrc_8h_a548a425f4925a785276e42c7569f27ce}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+type}} (void)
\end{DoxyCompactItemize}


\doxysubsection{Detailed Description}
Subscribe a M\+Q\+TT topic and push incoming data to the G\+Streamer pipeline. 

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

\begin{DoxyDate}{Date}
08 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__bug000021}{Bug}}]No known bugs except for N\+YI items \end{DoxyRefDesc}


\doxysubsection{Macro Definition Documentation}
\mbox{\Hypertarget{mqttsrc_8h_a578ca2877da3d493d00435a64a393721}\label{mqttsrc_8h_a578ca2877da3d493d00435a64a393721}} 
\index{mqttsrc.h@{mqttsrc.h}!GST\_IS\_MQTT\_SRC@{GST\_IS\_MQTT\_SRC}}
\index{GST\_IS\_MQTT\_SRC@{GST\_IS\_MQTT\_SRC}!mqttsrc.h@{mqttsrc.h}}
\doxysubsubsection{\texorpdfstring{GST\_IS\_MQTT\_SRC}{GST\_IS\_MQTT\_SRC}}
{\footnotesize\ttfamily \#define G\+S\+T\+\_\+\+I\+S\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC(\begin{DoxyParamCaption}\item[{}]{obj }\end{DoxyParamCaption})~(G\+\_\+\+T\+Y\+P\+E\+\_\+\+C\+H\+E\+C\+K\+\_\+\+I\+N\+S\+T\+A\+N\+C\+E\+\_\+\+T\+Y\+PE ((obj), \mbox{\hyperlink{mqttsrc_8h_a8a8501891d570f14aa08d84cde4db804}{G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC}}))}



Definition at line 29 of file mqttsrc.\+h.

\mbox{\Hypertarget{mqttsrc_8h_a481b5cae5dd3c54c940588ca5184ae05}\label{mqttsrc_8h_a481b5cae5dd3c54c940588ca5184ae05}} 
\index{mqttsrc.h@{mqttsrc.h}!GST\_IS\_MQTT\_SRC\_CLASS@{GST\_IS\_MQTT\_SRC\_CLASS}}
\index{GST\_IS\_MQTT\_SRC\_CLASS@{GST\_IS\_MQTT\_SRC\_CLASS}!mqttsrc.h@{mqttsrc.h}}
\doxysubsubsection{\texorpdfstring{GST\_IS\_MQTT\_SRC\_CLASS}{GST\_IS\_MQTT\_SRC\_CLASS}}
{\footnotesize\ttfamily \#define G\+S\+T\+\_\+\+I\+S\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+R\+C\+\_\+\+C\+L\+A\+SS(\begin{DoxyParamCaption}\item[{}]{klass }\end{DoxyParamCaption})~(G\+\_\+\+T\+Y\+P\+E\+\_\+\+C\+H\+E\+C\+K\+\_\+\+C\+L\+A\+S\+S\+\_\+\+T\+Y\+PE ((klass), \mbox{\hyperlink{mqttsrc_8h_a8a8501891d570f14aa08d84cde4db804}{G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC}}))}



Definition at line 35 of file mqttsrc.\+h.

\mbox{\Hypertarget{mqttsrc_8h_a5118a8004b700e38fca220ccee241938}\label{mqttsrc_8h_a5118a8004b700e38fca220ccee241938}} 
\index{mqttsrc.h@{mqttsrc.h}!GST\_MQTT\_SRC@{GST\_MQTT\_SRC}}
\index{GST\_MQTT\_SRC@{GST\_MQTT\_SRC}!mqttsrc.h@{mqttsrc.h}}
\doxysubsubsection{\texorpdfstring{GST\_MQTT\_SRC}{GST\_MQTT\_SRC}}
{\footnotesize\ttfamily \#define G\+S\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC(\begin{DoxyParamCaption}\item[{}]{obj }\end{DoxyParamCaption})~(G\+\_\+\+T\+Y\+P\+E\+\_\+\+C\+H\+E\+C\+K\+\_\+\+I\+N\+S\+T\+A\+N\+C\+E\+\_\+\+C\+A\+ST ((obj), \mbox{\hyperlink{mqttsrc_8h_a8a8501891d570f14aa08d84cde4db804}{G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC}}, \mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}}))}



Definition at line 27 of file mqttsrc.\+h.

\mbox{\Hypertarget{mqttsrc_8h_aa39b8a7ecda3aec34c99f6c648b15078}\label{mqttsrc_8h_aa39b8a7ecda3aec34c99f6c648b15078}} 
\index{mqttsrc.h@{mqttsrc.h}!GST\_MQTT\_SRC\_CAST@{GST\_MQTT\_SRC\_CAST}}
\index{GST\_MQTT\_SRC\_CAST@{GST\_MQTT\_SRC\_CAST}!mqttsrc.h@{mqttsrc.h}}
\doxysubsubsection{\texorpdfstring{GST\_MQTT\_SRC\_CAST}{GST\_MQTT\_SRC\_CAST}}
{\footnotesize\ttfamily \#define G\+S\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+R\+C\+\_\+\+C\+A\+ST(\begin{DoxyParamCaption}\item[{}]{obj }\end{DoxyParamCaption})~((\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$) obj)}



Definition at line 31 of file mqttsrc.\+h.

\mbox{\Hypertarget{mqttsrc_8h_a4262f18e0fa8d9ca198a6d0cb0e20481}\label{mqttsrc_8h_a4262f18e0fa8d9ca198a6d0cb0e20481}} 
\index{mqttsrc.h@{mqttsrc.h}!GST\_MQTT\_SRC\_CLASS@{GST\_MQTT\_SRC\_CLASS}}
\index{GST\_MQTT\_SRC\_CLASS@{GST\_MQTT\_SRC\_CLASS}!mqttsrc.h@{mqttsrc.h}}
\doxysubsubsection{\texorpdfstring{GST\_MQTT\_SRC\_CLASS}{GST\_MQTT\_SRC\_CLASS}}
{\footnotesize\ttfamily \#define G\+S\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+R\+C\+\_\+\+C\+L\+A\+SS(\begin{DoxyParamCaption}\item[{}]{klass }\end{DoxyParamCaption})~(G\+\_\+\+T\+Y\+P\+E\+\_\+\+C\+H\+E\+C\+K\+\_\+\+C\+L\+A\+S\+S\+\_\+\+C\+A\+ST ((klass), \mbox{\hyperlink{mqttsrc_8h_a8a8501891d570f14aa08d84cde4db804}{G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC}}, \mbox{\hyperlink{mqttsrc_8h_af3dd6005e7d4f293d044445ccff99cb0}{Gst\+Mqtt\+Src\+Class}}))}



Definition at line 33 of file mqttsrc.\+h.

\mbox{\Hypertarget{mqttsrc_8h_a8a8501891d570f14aa08d84cde4db804}\label{mqttsrc_8h_a8a8501891d570f14aa08d84cde4db804}} 
\index{mqttsrc.h@{mqttsrc.h}!GST\_TYPE\_MQTT\_SRC@{GST\_TYPE\_MQTT\_SRC}}
\index{GST\_TYPE\_MQTT\_SRC@{GST\_TYPE\_MQTT\_SRC}!mqttsrc.h@{mqttsrc.h}}
\doxysubsubsection{\texorpdfstring{GST\_TYPE\_MQTT\_SRC}{GST\_TYPE\_MQTT\_SRC}}
{\footnotesize\ttfamily \#define G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+RC~(\mbox{\hyperlink{mqttsrc_8h_a548a425f4925a785276e42c7569f27ce}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+type}}())}



Definition at line 25 of file mqttsrc.\+h.



\doxysubsection{Typedef Documentation}
\mbox{\Hypertarget{mqttsrc_8h_a057d9175cc50a072767da28154041956}\label{mqttsrc_8h_a057d9175cc50a072767da28154041956}} 
\index{mqttsrc.h@{mqttsrc.h}!GstMqttSrc@{GstMqttSrc}}
\index{GstMqttSrc@{GstMqttSrc}!mqttsrc.h@{mqttsrc.h}}
\doxysubsubsection{\texorpdfstring{GstMqttSrc}{GstMqttSrc}}
{\footnotesize\ttfamily typedef struct \mbox{\hyperlink{struct__GstMqttSrc}{\+\_\+\+Gst\+Mqtt\+Src}} \mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}}}



Definition at line 38 of file mqttsrc.\+h.

\mbox{\Hypertarget{mqttsrc_8h_af3dd6005e7d4f293d044445ccff99cb0}\label{mqttsrc_8h_af3dd6005e7d4f293d044445ccff99cb0}} 
\index{mqttsrc.h@{mqttsrc.h}!GstMqttSrcClass@{GstMqttSrcClass}}
\index{GstMqttSrcClass@{GstMqttSrcClass}!mqttsrc.h@{mqttsrc.h}}
\doxysubsubsection{\texorpdfstring{GstMqttSrcClass}{GstMqttSrcClass}}
{\footnotesize\ttfamily typedef struct \mbox{\hyperlink{struct__GstMqttSrcClass}{\+\_\+\+Gst\+Mqtt\+Src\+Class}} \mbox{\hyperlink{mqttsrc_8h_af3dd6005e7d4f293d044445ccff99cb0}{Gst\+Mqtt\+Src\+Class}}}



Definition at line 39 of file mqttsrc.\+h.



\doxysubsection{Function Documentation}
\mbox{\Hypertarget{mqttsrc_8h_a548a425f4925a785276e42c7569f27ce}\label{mqttsrc_8h_a548a425f4925a785276e42c7569f27ce}} 
\index{mqttsrc.h@{mqttsrc.h}!gst\_mqtt\_src\_get\_type@{gst\_mqtt\_src\_get\_type}}
\index{gst\_mqtt\_src\_get\_type@{gst\_mqtt\_src\_get\_type}!mqttsrc.h@{mqttsrc.h}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_type()}{gst\_mqtt\_src\_get\_type()}}
{\footnotesize\ttfamily G\+Type gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+type (\begin{DoxyParamCaption}\item[{void}]{ }\end{DoxyParamCaption})}

