#include <lbm.h>
Collaboration diagram for lbm_msg_t_stct:
Data Fields | |
| char | source [LBM_MSG_MAX_SOURCE_LEN] |
| char | topic_name [LBM_MSG_MAX_TOPIC_LEN] |
| char | copied_state [LBM_MSG_MAX_STATE_LEN] |
| int | type |
| int | flags |
| const char * | data |
| size_t | len |
| lbm_response_t * | response |
| lbm_uint_t | sequence_number |
| long | refcnt |
| size_t | apphdr_len |
| lbm_ulong_t | apphdr_code |
| lbm_timeval_t | tsp |
| lbm_ushort_t | hdrlen |
| const lbm_buff_t * | buffer |
| const void * | fragment_info |
| const char * | apphdr_data |
| const void * | source_clientd |
| const void * | umeack |
| const void * | src_cd |
| lbm_uint_t | osqn |
| lbm_msg_channel_info_t * | channel_info |
| const void * | umq_msgid |
| const void * | umq_cr |
| const void * | pdata |
| size_t | plen |
| lbm_msg_properties_t * | properties |
| lbm_hf_sequence_number_t | hf_sequence_number |
| char lbm_msg_t_stct::source[LBM_MSG_MAX_SOURCE_LEN] |
Source string of transport session. Format depends on transport type. For string formats and examples, see lbm_transport_source_info_t_stct.
| char lbm_msg_t_stct::topic_name[LBM_MSG_MAX_TOPIC_LEN] |
Name of the topic. Although this field is allocated at 256 bytes, legal topic names are restricted to 246 bytes.
| char lbm_msg_t_stct::copied_state[LBM_MSG_MAX_STATE_LEN] |
Copy of the state of the msg (only used on specific platforms. DO NOT ACCESS DIRECTLY!)
Type of message.
LBM_MSG_DATA - Data message, Message is composed of user data LBM_MSG_BOS - Beginning of Transport Session (source connection established) (data received) LBM_MSG_EOS - End of Transport Session (connection closed to source) (no further data) LBM_MSG_REQUEST - Request message from source LBM_MSG_RESPONSE - Response message from requestee LBM_MSG_UNRECOVERABLE_LOSS - Missing message detected and not recovered in given time (no data) LBM_MSG_UNRECOVERABLE_LOSS_BURST - Missing burst of messages detected and not recovered (no data) LBM_MSG_NO_SOURCE_NOTIFICATION - No source has been found for topic, Still querying for topic source LBM_MSG_UME_REGISTRATION_ERROR - UMP receiver registration encountered an error. Data holds error message LBM_MSG_UME_REGISTRATION_SUCCESS - UMP receiver registration successful. Data holds registration IDs LBM_MSG_UME_REGISTRATION_CHANGE - UMP receiver notification of source registration change. Data holds info message LBM_MSG_UME_REGISTRATION_SUCCESS_EX - UMP receiver registration successful for a store (extended form). Data holds registration IDs, etc. LBM_MSG_UME_REGISTRATION_CHANGE_EX - UMP receiver notification of registration completion. Data holds sequence number and flags, etc. LBM_MSG_UME_DEREGISTRATION_SUCCESS_EX - UMP receiver notification of deregistration success. Data holds registration IDs, etc. LBM_MSG_UME_DEREGISTRATION_COMPLETE_EX - UMP receiver notification of deregistration complete. LBM_MSG_UMQ_REGISTRATION_ERROR - UMQ receiver registration encountered an error. Data holds error message. LBM_MSG_UMQ_REGISTRATION_COMPLETE_EX - UMQ receiver notification of registration completion. Data holds Queue information, assignment ID, etc. LBM_MSG_UMQ_DEREGISTRATION_COMPLETE_EX - UMQ receiver notification of de-registration completion. Data holds Queue information, etc. LBM_MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_ERROR - UMQ receiver index assignment start/stop encountered an error. Data holds error message. LBM_MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_START_COMPLETE_EX - UMQ receiver notification of beginning of index assignment eligibility or index assignment. Data holds index information, etc. LBM_MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_STOP_COMPLETE_EX - UMQ receiver notification of end of index assignment eligibility or index assignment. Data holds index information, etc. LBM_MSG_UMQ_INDEX_ASSIGNED_EX - UMQ receiver notification of beginning of index. LBM_MSG_UMQ_INDEX_RELEASED_EX - UMQ receiver notification of end of index. LBM_MSG_UMQ_INDEX_ASSIGNMENT_ERROR - UMQ receiver notification of an index assignment error. LBM_MSG_HF_RESET - Hot-failover reset message was handled. UMS is now expecting msg->hf_sequence_number as the next non-reset hot-failover message. Flags associated with the message.
LBM_MSG_FLAG_START_BATCH - Message starts a batch LBM_MSG_FLAG_END_BATCH - Message ends a batch LBM_MSG_FLAG_HF_PASS_THROUGH - Message is a passed-through Hot Failover message LBM_MSG_FLAG_RETRANSMIT - Message is a late join recovered message LBM_MSG_FLAG_UME_RETRANSMIT - Message is a UM recovered message LBM_MSG_FLAG_IMMEDIATE - Message is an immediate message LBM_MSG_FLAG_TOPICLESS - Message has no topic LBM_MSG_FLAG_HF_32 - Message has a 32 bit hot failover sequence number LBM_MSG_FLAG_HF_64 - Message has a 64 bit hot failover sequence number | const char* lbm_msg_t_stct::data |
Data contents of the message if of a message type that carries data. Note that UM does not guarantee any alignment of that data.
| size_t lbm_msg_t_stct::len |
Length of data in bytes
| lbm_response_t* lbm_msg_t_stct::response |
Pointer to response object used for sending responses for lbm_msg_t request.
| lbm_uint_t lbm_msg_t_stct::sequence_number |
Topic level sequence number of message. For fragmented messages, this is the sequence number of the final fragment comprising the message.
| const void* lbm_msg_t_stct::source_clientd |
Pointer set by lbm_rcv_src_notification_create_function_cb callback
Channel information set when using Spectrum channels
| lbm_msg_properties_t* lbm_msg_t_stct::properties |
Message properties structure for this message
Hot failover sequence number, check message flags for LBM_MSG_FLAG_HF_32 or LBM_MSG_FLAG_HF_64.
1.5.2