aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/cpp/sampleGetClient.cpp
diff options
context:
space:
mode:
authorVarun Gudisena <vg411h@att.com>2017-08-30 20:49:32 -0500
committerVarun Gudisena <vg411h@att.com>2017-08-30 20:50:47 -0500
commitcc9de9bc6803212f0233e0e1bf06aa63fe8b7a6a (patch)
tree7425883592f6cfe97c415f17ca80a0ba13041ce2 /src/main/cpp/sampleGetClient.cpp
parentffc0ccd5ab1ad5e6a5db2d674a4a6c30a31bc732 (diff)
Add Initial Code Import
Intial Code import for dmaapClient Issue-id: DMAAP-82 Change-Id: Ib627672d37e233b796619f93dd91f5caaf1592e4 Signed-off-by: Varun Gudisena <vg411h@att.com>
Diffstat (limited to 'src/main/cpp/sampleGetClient.cpp')
-rw-r--r--src/main/cpp/sampleGetClient.cpp61
1 files changed, 61 insertions, 0 deletions
diff --git a/src/main/cpp/sampleGetClient.cpp b/src/main/cpp/sampleGetClient.cpp
new file mode 100644
index 0000000..610988c
--- /dev/null
+++ b/src/main/cpp/sampleGetClient.cpp
@@ -0,0 +1,61 @@
+/*******************************************************************************
+ * ============LICENSE_START=======================================================
+ * org.onap.dmaap
+ * ================================================================================
+ * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ *
+ * ECOMP is a trademark and service mark of AT&T Intellectual Property.
+ *
+ *******************************************************************************/
+
+#include <stdio.h>
+#include "cambria.h"
+
+int main ( int argc, const char* argv[] )
+{
+ const CAMBRIA_CLIENT cc = ::cambriaCreateClient ( "localhost", 8080, "topic", CAMBRIA_NATIVE_FORMAT );
+ if ( !cc )
+ {
+ ::printf ( "Couldn't create client.\n" );
+ return 1;
+ }
+
+ int count = 0;
+ while ( 1 )
+ {
+ cambriaGetResponse* response = ::cambriaGetMessages ( cc, 5000, 1024*1024 );
+ if ( response && response->statusCode < 300 )
+ {
+ for ( int i=0; i<response->messageCount; i++ )
+ {
+ const char* msg = response->messageSet [ i ];
+ ::printf ( "%d: %s\n", count++, msg );
+ }
+ ::cambriaDestroyGetResponse ( cc, response );
+ }
+ else if ( response )
+ {
+ ::fprintf ( stderr, "%d %s", response->statusCode, response->statusMessage );
+ }
+ else
+ {
+ ::fprintf ( stderr, "No response object.\n" );
+ }
+ }
+
+ ::cambriaDestroyClient ( cc );
+
+ return 0;
+}