Classes Files

mama/dqpublisher.h

Functions

  Name
MAMAExpDLL mama_status mamaDQPublisher_allocate(mamaDQPublisher * result)
MAMAExpDLL mama_status mamaDQPublisher_create(mamaDQPublisher pub, mamaTransport transport, const char * topic)
MAMAExpDLL mama_status mamaDQPublisher_addTopic(mamaDQPublisher pub, const char * topic)
MAMAExpDLL mama_status mamaDQPublisher_send(mamaDQPublisher pub, mamaMsg msg)
MAMAExpDLL mama_status mamaDQPublisher_sendReply(mamaDQPublisher pub, mamaMsg request, mamaMsg reply)
MAMAExpDLL mama_status mamaDQPublisher_sendReplyWithHandle(mamaDQPublisher pub, mamaMsgReply replyAddress, mamaMsg reply)
MAMAExpDLL void mamaDQPublisher_destroy(mamaDQPublisher pub)
MAMAExpDLL void mamaDQPublisher_setStatus(mamaDQPublisher pub, mamaMsgStatus status)
MAMAExpDLL void mamaDQPublisher_setSenderId(mamaDQPublisher pub, uint64_t senderid)
MAMAExpDLL void mamaDQPublisher_setSeqNum(mamaDQPublisher pub, mama_seqnum_t num)
MAMAExpDLL void mamaDQPublisher_setClosure(mamaDQPublisher pub, void * closure)
MAMAExpDLL void mamaDQPublisher_enableSendTime(mamaDQPublisher pub, mama_bool_t enable)
MAMAExpDLL void * mamaDQPublisher_getClosure(mamaDQPublisher pub)
MAMAExpDLL void mamaDQPublisher_setCache(mamaDQPublisher pub, void * cache)
MAMAExpDLL void * mamaDQPublisher_getCache(mamaDQPublisher pub)

Functions Documentation

function mamaDQPublisher_allocate

MAMAExpDLL mama_status mamaDQPublisher_allocate(
    mamaDQPublisher * result
)

Parameters:

  • result A pointer to hold the mamaDQPublisher.

Responsible for publishing mama marketdata messages. Allocate a mamaDQPublisher.

function mamaDQPublisher_create

MAMAExpDLL mama_status mamaDQPublisher_create(
    mamaDQPublisher pub,
    mamaTransport transport,
    const char * topic
)

Parameters:

  • pub A pointer to the mamaDQPublisher.
  • transport The transport.
  • topic Symbol on which to publish.

Create a mamaDQPublisher for the corresponding transport.

function mamaDQPublisher_addTopic

MAMAExpDLL mama_status mamaDQPublisher_addTopic(
    mamaDQPublisher pub,
    const char * topic
)

Add a new topic context to a mamaDQPublisher.

Having topic contexts allows a single publisher to publish messages with different wIssueSymbol fields with sequence number and status tracked separately for each wIssueSymbol.

function mamaDQPublisher_send

MAMAExpDLL mama_status mamaDQPublisher_send(
    mamaDQPublisher pub,
    mamaMsg msg
)

Parameters:

  • publisher The publish from which to send the message.
  • msg The mamaMsg to send.

Send a message.

function mamaDQPublisher_sendReply

MAMAExpDLL mama_status mamaDQPublisher_sendReply(
    mamaDQPublisher pub,
    mamaMsg request,
    mamaMsg reply
)

function mamaDQPublisher_sendReplyWithHandle

MAMAExpDLL mama_status mamaDQPublisher_sendReplyWithHandle(
    mamaDQPublisher pub,
    mamaMsgReply replyAddress,
    mamaMsg reply
)

function mamaDQPublisher_destroy

MAMAExpDLL void mamaDQPublisher_destroy(
    mamaDQPublisher pub
)

function mamaDQPublisher_setStatus

MAMAExpDLL void mamaDQPublisher_setStatus(
    mamaDQPublisher pub,
    mamaMsgStatus status
)

function mamaDQPublisher_setSenderId

MAMAExpDLL void mamaDQPublisher_setSenderId(
    mamaDQPublisher pub,
    uint64_t senderid
)

function mamaDQPublisher_setSeqNum

MAMAExpDLL void mamaDQPublisher_setSeqNum(
    mamaDQPublisher pub,
    mama_seqnum_t num
)

function mamaDQPublisher_setClosure

MAMAExpDLL void mamaDQPublisher_setClosure(
    mamaDQPublisher pub,
    void * closure
)

function mamaDQPublisher_enableSendTime

MAMAExpDLL void mamaDQPublisher_enableSendTime(
    mamaDQPublisher pub,
    mama_bool_t enable
)

function mamaDQPublisher_getClosure

MAMAExpDLL void * mamaDQPublisher_getClosure(
    mamaDQPublisher pub
)

function mamaDQPublisher_setCache

MAMAExpDLL void mamaDQPublisher_setCache(
    mamaDQPublisher pub,
    void * cache
)

function mamaDQPublisher_getCache

MAMAExpDLL void * mamaDQPublisher_getCache(
    mamaDQPublisher pub
)

Source code

/* $Id$
 *
 * OpenMAMA: The open middleware agnostic messaging API
 * Copyright (C) 2011 NYSE Technologies, Inc.
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
 * 02110-1301 USA
 */

#ifndef MAMA_DQPUBLISHER_H__
#define MAMA_DQPUBLISHER_H__

#include "mama/types.h"
#include "wombat/wConfig.h"

#if defined( __cplusplus )
extern "C"
{
#endif /* defined( __cplusplus ) */

MAMAExpDLL
extern mama_status
mamaDQPublisher_allocate (mamaDQPublisher* result );

MAMAExpDLL
extern mama_status
mamaDQPublisher_create (mamaDQPublisher pub, mamaTransport transport,
                         const char* topic);


MAMAExpDLL
mama_status mamaDQPublisher_addTopic (mamaDQPublisher pub, const char* topic);


MAMAExpDLL
extern mama_status
mamaDQPublisher_send (mamaDQPublisher pub, mamaMsg msg);


/*
 * Send a p2p message reply.
 *
 * @param publisher The mamaPublisher from which to send the message.
 * @param request The mamaMsg being responded to.
 * @param reply The mamaMsg to be send
 */
MAMAExpDLL
extern mama_status
mamaDQPublisher_sendReply (mamaDQPublisher pub, mamaMsg request,
                                     mamaMsg reply) ;


MAMAExpDLL
extern mama_status
mamaDQPublisher_sendReplyWithHandle (mamaDQPublisher pub,
                                     mamaMsgReply  replyAddress,
                                     mamaMsg reply);

MAMAExpDLL
extern void
mamaDQPublisher_destroy (mamaDQPublisher pub);



MAMAExpDLL
extern void
mamaDQPublisher_setStatus (mamaDQPublisher pub, mamaMsgStatus  status);

MAMAExpDLL
extern void
mamaDQPublisher_setSenderId (mamaDQPublisher pub, uint64_t  senderid);

MAMAExpDLL
extern void
mamaDQPublisher_setSeqNum (mamaDQPublisher pub, mama_seqnum_t num);

MAMAExpDLL
extern void
mamaDQPublisher_setClosure (mamaDQPublisher pub, void*  closure);

MAMAExpDLL
extern void
mamaDQPublisher_enableSendTime (mamaDQPublisher pub, mama_bool_t enable);

MAMAExpDLL
extern void*
mamaDQPublisher_getClosure (mamaDQPublisher pub);

MAMAExpDLL
extern void
mamaDQPublisher_setCache (mamaDQPublisher pub, void*  cache);

MAMAExpDLL
extern void*
mamaDQPublisher_getCache (mamaDQPublisher pub);

#if defined( __cplusplus )
}
#endif /* defined( __cplusplus ) */

#endif /* MAMA_PUBLISHER_H_*/

Updated on 2023-03-31 at 15:29:16 +0100