ex/ios/intro/HelloWorldPubExample.m

/*
 *  This source is distributed under the terms and conditions
 *  of any contract or contracts between Solace and you or
 *  your company. If there are no contracts in place use of
 *  this source is not authorized. No support is provided and
 *  no distribution, sharing with others or re-use of this
 *  source is authorized unless specifically stated in the
 *  contracts referred to above.
 *
 *  Copyright 2012-2024 Solace Corporation. All rights reserved.
 */

#import "HelloWorldPubExample.h"

@implementation HelloWorldPubExample

- (id)initWithExampleInterface:(ExampleInterface *)exampleInterface {
    self = [super initWithExampleInterface:exampleInterface];

    // Set example name and description
    self.name = @"HelloWorldPub";
    self.description = @"Demonstrates the basics of session creation, "
        @"connection and publishing direct messages to a topic";

    // Set up example parameters
    [self.parameters addParameter:PARAMETER_DESTINATION_TOPIC];

    [self.parameters removeParameter:PARAMETER_PASSWORD];
    [self.parameters removeParameter:PARAMETER_COMPRESSION];
    [self.parameters removeParameter:PARAMETER_LOGGING_LEVEL];

    return self;
}

- (solClient_rxMsgCallback_returnCode_t)
    messageReceiveCallbackWithSession:
        (solClient_opaqueSession_pt)opaqueSession_p
                              message:(solClient_opaqueMsg_pt)msg_p
                             userData:(void *)user_p {
    // The use of an empty function is necessary as the message receive callback
    // function is mandatory for session creation.
    return SOLCLIENT_CALLBACK_OK;
}

- (void)eventCallbackWithSession:(solClient_opaqueSession_pt)opaqueSession_p
                       eventInfo:
                           (solClient_session_eventCallbackInfo_pt)eventInfo_p
                        userData:(void *)user_p {
    // The use of an empty function is necessary as the event callback function
    // is mandatory for session creation.
}

- (void)run {
    [super run];

    // Context variables
    solClient_opaqueContext_pt context_p;
    solClient_context_createFuncInfo_t contextFuncInfo =
        SOLCLIENT_CONTEXT_CREATEFUNC_INITIALIZER;

    // Session variables
    solClient_opaqueSession_pt session_p;
    solClient_session_createFuncInfo_t sessionFuncInfo =
        SOLCLIENT_SESSION_CREATEFUNC_INITIALIZER;

    // Session properties
    const char *sessionProps[20];
    int propIndex = 0;

    // Message variables
    solClient_opaqueMsg_pt msg_p = NULL;
    solClient_destination_t destination;
    const char *text_p = "Hello world!";

    // Initialize the API; this must be done prior to first usage
    solClient_initialize(SOLCLIENT_LOG_DEFAULT_FILTER, NULL);

    solClient_log(SOLCLIENT_LOG_NOTICE, "HelloWorldPub initializing...\n");

    // Create a context, and specify that the context thread be created
    // automatically instead of having the application create its own
    // context thread.
    solClient_context_create(SOLCLIENT_CONTEXT_PROPS_DEFAULT_WITH_CREATE_THREAD,
                             &context_p, &contextFuncInfo,
                             sizeof(contextFuncInfo));

    // Message receive callback function and the Session event function
    // are both mandatory. In this sample, default functions are used.
    sessionFuncInfo.rxMsgInfo.callback_p = messageReceiveCallback;
    sessionFuncInfo.rxMsgInfo.user_p = self.nullBridge_p;
    sessionFuncInfo.eventInfo.callback_p = eventCallback;
    sessionFuncInfo.eventInfo.user_p = self.nullBridge_p;

    // Configure the session's properties
    propIndex = 0;

    sessionProps[propIndex++] = SOLCLIENT_SESSION_PROP_HOST;
    sessionProps[propIndex++] =
        [[self.parameters parameterWithId:PARAMETER_HOST].value
            cStringUsingEncoding:NSASCIIStringEncoding];

    sessionProps[propIndex++] = SOLCLIENT_SESSION_PROP_VPN_NAME;
    sessionProps[propIndex++] =
        [[self.parameters parameterWithId:PARAMETER_VPN].value
            cStringUsingEncoding:NSASCIIStringEncoding];

    sessionProps[propIndex++] = SOLCLIENT_SESSION_PROP_USERNAME;
    sessionProps[propIndex++] =
        [[self.parameters parameterWithId:PARAMETER_USERNAME].value
            cStringUsingEncoding:NSASCIIStringEncoding];

    sessionProps[propIndex] = NULL;

    // Create the session
    solClient_session_create((char **)sessionProps, context_p, &session_p,
                             &sessionFuncInfo, sizeof(sessionFuncInfo));

    // Connect the session
    solClient_session_connect(session_p);
    solClient_log(SOLCLIENT_LOG_NOTICE, "Connected.\n");

    // Allocate memory for the message that is to be sent
    solClient_msg_alloc(&msg_p);

    // Set the message delivery mode
    solClient_msg_setDeliveryMode(msg_p, SOLCLIENT_DELIVERY_MODE_DIRECT);

    // Set the destination
    destination.destType = SOLCLIENT_TOPIC_DESTINATION;
    destination.dest =
        [[self.parameters parameterWithId:PARAMETER_DESTINATION_TOPIC].value
            cStringUsingEncoding:NSASCIIStringEncoding];
    solClient_msg_setDestination(msg_p, &destination, sizeof(destination));

    // Add some content to the message
    solClient_msg_setBinaryAttachment(
        msg_p, text_p, (solClient_uint32_t)strlen((char *)text_p));

    // Send the message
    solClient_log(
        SOLCLIENT_LOG_NOTICE, "About to send message '%s' to topic '%s'...\n",
        (char *)text_p,
        [[self.parameters parameterWithId:PARAMETER_DESTINATION_TOPIC].value
            cStringUsingEncoding:NSASCIIStringEncoding]);
    solClient_session_sendMsg(session_p, msg_p);

    // Free the message
    solClient_log(SOLCLIENT_LOG_NOTICE, "Message sent. Exiting.\n");
    solClient_msg_free(&msg_p);

    // Cleanup solclient
    solClient_cleanup();

    [self cleanup];
}

@end