Module: Rocketmq::C

Extended by:
FFI::Library
Included in:
Client::Message, Client::Producer, Client::PushConsumer, Client::ReceivedMessage, Client::TransactionMQProducer
Defined in:
lib/rocketmq-client-ruby/rocketmq.rb

Overview

This module mainly defines the export method of librockmqclient

Defined Under Namespace

Classes: SendResult

Constant Summary collapse

Status = 
enum(
  # Success
  :ok, 0,
  # Failed
  :null_pointer, 1,
  :malloc_failed, 2,
  # producer
  :producer_start_failed, 10,
  :producer_send_sync_failed, 11,
  :producer_send_oneway_failed, 12,
  :producer_send_orderly_failed, 13,
  :producer_send_async_failed, 14,
  :producer_send_orderlyasync_failed, 15,
  :producer_send_transaction_failed, 16,
  # push consumer
  :push_consumer_start_failed, 20,
  # pull consumer
  :pullconsumer_start_failed, 30,
  :pullconsumer_fetch_mq_failed, 31,
  :pullconsumer_fetch_message_failed, 32,

  :not_suport, 500,
  :not_support_now, -1
)
MessageModel = 
enum(
  :broadcasting, 0,
  :clustering, 1
)
TransactionStatus = 
enum(
  :commit, 0,
  :rollback, 1,
  :unknown, 2
)
SendStatus = 
enum(
  :send_ok, 0,
  :send_flush_disk_timeout, 1,
  :send_flush_slave_timeout, 2,
  :send_slave_not_available, 3
)
ConsumeStatus = 
enum(
  :consume_success, 0,
  :reconsume_later, 1
)
MessageProperty = 
enum(
  :trace_switch, 'TRACE_ON',
  :msg_region, 'MSG_REGION',
  :keys, 'KEYS',
  :tags, 'TAGS',
  :wait_store_msg_ok, 'WAIT',
  :delay_time_level, 'DELAY',
  :retry_topic, 'RETRY_TOPIC',
  :real_topic, 'REAL_TOPIC',
  :real_queue_id, 'REAL_QID',
  :transaction_prepared, 'TRAN_MSG',
  :producer_group, 'PGROUP',
  :min_offset, 'MIN_OFFSET',
  :max_offset, 'MAX_OFFSET',
  :buyer_id, 'BUYER_ID',
  :origin_message_id, 'ORIGIN_MESSAGE_ID',
  :transfer_flag, 'TRANSFER_FLAG',
  :correction_flag, 'CORRECTION_FLAG',
  :mq2_flag, 'MQ2_FLAG',
  :reconsume_tiem, 'RECONSUME_TIME',
  :uniq_client_message_id_keyidx, 'UNIQ_KEY',
  :max_reconsume_times, 'MAX_RECONSUME_TIMES',
  :consume_start_timestamp, 'CONSUME_START_TIME'
)

Class Method Summary collapse

Class Method Details

.attach_function_maybe(*args) ⇒ Object 



8
9
10
11
12
 
# File 'lib/rocketmq-client-ruby/rocketmq.rb', line 8

def self.attach_function_maybe(*args)
  attach_function(*args)
rescue FFI::NotFoundError
  puts("Missing function: #{args[0]} detail: #{args}")
end