sig
type shortstr = string
type octet = int
type reply_text = string
type path = string
type longlong = Netnumber.uint8
type bit = bool
type class_id = int
type longstr = string
type peer_properties = Netamqp_rtypes.table
type exchange_name = string
type delivery_tag = Netnumber.uint8
type timestamp = float
type consumer_tag = string
type long = Netnumber.uint4
type reply_code = int
type message_count = Netnumber.uint4
type method_id = int
type no_wait = bool
type no_ack = bool
type queue_name = string
type redelivered = bool
type table = Netamqp_rtypes.table
type short = int
type no_local = bool
type arg_Connection_start =
Netamqp_methods_0_9.octet * Netamqp_methods_0_9.octet *
Netamqp_methods_0_9.peer_properties * Netamqp_methods_0_9.longstr *
Netamqp_methods_0_9.longstr
type arg_Connection_start_ok =
Netamqp_methods_0_9.peer_properties * Netamqp_methods_0_9.shortstr *
Netamqp_methods_0_9.longstr * Netamqp_methods_0_9.shortstr
type arg_Connection_secure = Netamqp_methods_0_9.longstr
type arg_Connection_secure_ok = Netamqp_methods_0_9.longstr
type arg_Connection_tune =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.long *
Netamqp_methods_0_9.short
type arg_Connection_tune_ok =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.long *
Netamqp_methods_0_9.short
type arg_Connection_open =
Netamqp_methods_0_9.path * Netamqp_methods_0_9.shortstr *
Netamqp_methods_0_9.bit
type arg_Connection_open_ok = Netamqp_methods_0_9.shortstr
type arg_Connection_close =
Netamqp_methods_0_9.reply_code * Netamqp_methods_0_9.reply_text *
Netamqp_methods_0_9.class_id * Netamqp_methods_0_9.method_id
type arg_Channel_open = Netamqp_methods_0_9.shortstr
type arg_Channel_open_ok = Netamqp_methods_0_9.longstr
type arg_Channel_flow = Netamqp_methods_0_9.bit
type arg_Channel_flow_ok = Netamqp_methods_0_9.bit
type arg_Channel_close =
Netamqp_methods_0_9.reply_code * Netamqp_methods_0_9.reply_text *
Netamqp_methods_0_9.class_id * Netamqp_methods_0_9.method_id
type arg_Exchange_declare =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.exchange_name *
Netamqp_methods_0_9.shortstr * Netamqp_methods_0_9.bit *
Netamqp_methods_0_9.bit * Netamqp_methods_0_9.bit *
Netamqp_methods_0_9.bit * Netamqp_methods_0_9.no_wait *
Netamqp_methods_0_9.table
type arg_Exchange_delete =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.exchange_name *
Netamqp_methods_0_9.bit * Netamqp_methods_0_9.no_wait
type arg_Queue_declare =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
Netamqp_methods_0_9.bit * Netamqp_methods_0_9.bit *
Netamqp_methods_0_9.bit * Netamqp_methods_0_9.bit *
Netamqp_methods_0_9.no_wait * Netamqp_methods_0_9.table
type arg_Queue_declare_ok =
Netamqp_methods_0_9.queue_name * Netamqp_methods_0_9.message_count *
Netamqp_methods_0_9.long
type arg_Queue_bind =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
Netamqp_methods_0_9.exchange_name * Netamqp_methods_0_9.shortstr *
Netamqp_methods_0_9.no_wait * Netamqp_methods_0_9.table
type arg_Queue_unbind =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
Netamqp_methods_0_9.exchange_name * Netamqp_methods_0_9.shortstr *
Netamqp_methods_0_9.table
type arg_Queue_purge =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
Netamqp_methods_0_9.no_wait
type arg_Queue_purge_ok = Netamqp_methods_0_9.message_count
type arg_Queue_delete =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
Netamqp_methods_0_9.bit * Netamqp_methods_0_9.bit *
Netamqp_methods_0_9.no_wait
type arg_Queue_delete_ok = Netamqp_methods_0_9.message_count
type arg_Basic_qos =
Netamqp_methods_0_9.long * Netamqp_methods_0_9.short *
Netamqp_methods_0_9.bit
type arg_Basic_consume =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
Netamqp_methods_0_9.consumer_tag * Netamqp_methods_0_9.no_local *
Netamqp_methods_0_9.no_ack * Netamqp_methods_0_9.bit *
Netamqp_methods_0_9.no_wait * Netamqp_methods_0_9.table
type arg_Basic_consume_ok = Netamqp_methods_0_9.consumer_tag
type arg_Basic_cancel =
Netamqp_methods_0_9.consumer_tag * Netamqp_methods_0_9.no_wait
type arg_Basic_cancel_ok = Netamqp_methods_0_9.consumer_tag
type arg_Basic_publish =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.exchange_name *
Netamqp_methods_0_9.shortstr * Netamqp_methods_0_9.bit *
Netamqp_methods_0_9.bit
type arg_Basic_return =
Netamqp_methods_0_9.reply_code * Netamqp_methods_0_9.reply_text *
Netamqp_methods_0_9.exchange_name * Netamqp_methods_0_9.shortstr
type arg_Basic_deliver =
Netamqp_methods_0_9.consumer_tag * Netamqp_methods_0_9.delivery_tag *
Netamqp_methods_0_9.redelivered * Netamqp_methods_0_9.exchange_name *
Netamqp_methods_0_9.shortstr
type arg_Basic_get =
Netamqp_methods_0_9.short * Netamqp_methods_0_9.queue_name *
Netamqp_methods_0_9.no_ack
type arg_Basic_get_ok =
Netamqp_methods_0_9.delivery_tag * Netamqp_methods_0_9.redelivered *
Netamqp_methods_0_9.exchange_name * Netamqp_methods_0_9.shortstr *
Netamqp_methods_0_9.message_count
type arg_Basic_get_empty = Netamqp_methods_0_9.shortstr
type arg_Basic_ack =
Netamqp_methods_0_9.delivery_tag * Netamqp_methods_0_9.bit
type arg_Basic_reject =
Netamqp_methods_0_9.delivery_tag * Netamqp_methods_0_9.bit
type arg_Basic_recover_async = Netamqp_methods_0_9.bit
type arg_Basic_recover = Netamqp_methods_0_9.bit
type method_t =
[ `Basic_ack of Netamqp_methods_0_9.arg_Basic_ack
| `Basic_cancel of Netamqp_methods_0_9.arg_Basic_cancel
| `Basic_cancel_ok of Netamqp_methods_0_9.arg_Basic_cancel_ok
| `Basic_consume of Netamqp_methods_0_9.arg_Basic_consume
| `Basic_consume_ok of Netamqp_methods_0_9.arg_Basic_consume_ok
| `Basic_deliver of Netamqp_methods_0_9.arg_Basic_deliver
| `Basic_get of Netamqp_methods_0_9.arg_Basic_get
| `Basic_get_empty of Netamqp_methods_0_9.arg_Basic_get_empty
| `Basic_get_ok of Netamqp_methods_0_9.arg_Basic_get_ok
| `Basic_publish of Netamqp_methods_0_9.arg_Basic_publish
| `Basic_qos of Netamqp_methods_0_9.arg_Basic_qos
| `Basic_qos_ok
| `Basic_recover of Netamqp_methods_0_9.arg_Basic_recover
| `Basic_recover_async of Netamqp_methods_0_9.arg_Basic_recover_async
| `Basic_recover_ok
| `Basic_reject of Netamqp_methods_0_9.arg_Basic_reject
| `Basic_return of Netamqp_methods_0_9.arg_Basic_return
| `Channel_close of Netamqp_methods_0_9.arg_Channel_close
| `Channel_close_ok
| `Channel_flow of Netamqp_methods_0_9.arg_Channel_flow
| `Channel_flow_ok of Netamqp_methods_0_9.arg_Channel_flow_ok
| `Channel_open of Netamqp_methods_0_9.arg_Channel_open
| `Channel_open_ok of Netamqp_methods_0_9.arg_Channel_open_ok
| `Connection_close of Netamqp_methods_0_9.arg_Connection_close
| `Connection_close_ok
| `Connection_open of Netamqp_methods_0_9.arg_Connection_open
| `Connection_open_ok of Netamqp_methods_0_9.arg_Connection_open_ok
| `Connection_secure of Netamqp_methods_0_9.arg_Connection_secure
| `Connection_secure_ok of Netamqp_methods_0_9.arg_Connection_secure_ok
| `Connection_start of Netamqp_methods_0_9.arg_Connection_start
| `Connection_start_ok of Netamqp_methods_0_9.arg_Connection_start_ok
| `Connection_tune of Netamqp_methods_0_9.arg_Connection_tune
| `Connection_tune_ok of Netamqp_methods_0_9.arg_Connection_tune_ok
| `Exchange_declare of Netamqp_methods_0_9.arg_Exchange_declare
| `Exchange_declare_ok
| `Exchange_delete of Netamqp_methods_0_9.arg_Exchange_delete
| `Exchange_delete_ok
| `Queue_bind of Netamqp_methods_0_9.arg_Queue_bind
| `Queue_bind_ok
| `Queue_declare of Netamqp_methods_0_9.arg_Queue_declare
| `Queue_declare_ok of Netamqp_methods_0_9.arg_Queue_declare_ok
| `Queue_delete of Netamqp_methods_0_9.arg_Queue_delete
| `Queue_delete_ok of Netamqp_methods_0_9.arg_Queue_delete_ok
| `Queue_purge of Netamqp_methods_0_9.arg_Queue_purge
| `Queue_purge_ok of Netamqp_methods_0_9.arg_Queue_purge_ok
| `Queue_unbind of Netamqp_methods_0_9.arg_Queue_unbind
| `Queue_unbind_ok
| `Tx_commit
| `Tx_commit_ok
| `Tx_rollback
| `Tx_rollback_ok
| `Tx_select
| `Tx_select_ok ]
type sync_client_to_server_method_t =
[ `Basic_cancel of Netamqp_methods_0_9.arg_Basic_cancel
| `Basic_consume of Netamqp_methods_0_9.arg_Basic_consume
| `Basic_get of Netamqp_methods_0_9.arg_Basic_get
| `Basic_qos of Netamqp_methods_0_9.arg_Basic_qos
| `Basic_recover of Netamqp_methods_0_9.arg_Basic_recover
| `Channel_close of Netamqp_methods_0_9.arg_Channel_close
| `Channel_close_ok
| `Channel_flow of Netamqp_methods_0_9.arg_Channel_flow
| `Channel_flow_ok of Netamqp_methods_0_9.arg_Channel_flow_ok
| `Channel_open of Netamqp_methods_0_9.arg_Channel_open
| `Connection_close of Netamqp_methods_0_9.arg_Connection_close
| `Connection_close_ok
| `Connection_open of Netamqp_methods_0_9.arg_Connection_open
| `Connection_secure_ok of Netamqp_methods_0_9.arg_Connection_secure_ok
| `Connection_start_ok of Netamqp_methods_0_9.arg_Connection_start_ok
| `Connection_tune_ok of Netamqp_methods_0_9.arg_Connection_tune_ok
| `Exchange_declare of Netamqp_methods_0_9.arg_Exchange_declare
| `Exchange_delete of Netamqp_methods_0_9.arg_Exchange_delete
| `Queue_bind of Netamqp_methods_0_9.arg_Queue_bind
| `Queue_declare of Netamqp_methods_0_9.arg_Queue_declare
| `Queue_delete of Netamqp_methods_0_9.arg_Queue_delete
| `Queue_purge of Netamqp_methods_0_9.arg_Queue_purge
| `Queue_unbind of Netamqp_methods_0_9.arg_Queue_unbind
| `Tx_commit
| `Tx_rollback
| `Tx_select ]
type sync_server_to_client_method_t =
[ `Basic_cancel_ok of Netamqp_methods_0_9.arg_Basic_cancel_ok
| `Basic_consume_ok of Netamqp_methods_0_9.arg_Basic_consume_ok
| `Basic_get_empty of Netamqp_methods_0_9.arg_Basic_get_empty
| `Basic_get_ok of Netamqp_methods_0_9.arg_Basic_get_ok
| `Basic_qos_ok
| `Basic_recover_ok
| `Channel_close of Netamqp_methods_0_9.arg_Channel_close
| `Channel_close_ok
| `Channel_flow of Netamqp_methods_0_9.arg_Channel_flow
| `Channel_flow_ok of Netamqp_methods_0_9.arg_Channel_flow_ok
| `Channel_open_ok of Netamqp_methods_0_9.arg_Channel_open_ok
| `Connection_close of Netamqp_methods_0_9.arg_Connection_close
| `Connection_close_ok
| `Connection_open_ok of Netamqp_methods_0_9.arg_Connection_open_ok
| `Connection_secure of Netamqp_methods_0_9.arg_Connection_secure
| `Connection_start of Netamqp_methods_0_9.arg_Connection_start
| `Connection_tune of Netamqp_methods_0_9.arg_Connection_tune
| `Exchange_declare_ok
| `Exchange_delete_ok
| `Queue_bind_ok
| `Queue_declare_ok of Netamqp_methods_0_9.arg_Queue_declare_ok
| `Queue_delete_ok of Netamqp_methods_0_9.arg_Queue_delete_ok
| `Queue_purge_ok of Netamqp_methods_0_9.arg_Queue_purge_ok
| `Queue_unbind_ok
| `Tx_commit_ok
| `Tx_rollback_ok
| `Tx_select_ok ]
type sync_client_initiated_method_t =
[ `Basic_cancel of Netamqp_methods_0_9.arg_Basic_cancel
| `Basic_consume of Netamqp_methods_0_9.arg_Basic_consume
| `Basic_get of Netamqp_methods_0_9.arg_Basic_get
| `Basic_qos of Netamqp_methods_0_9.arg_Basic_qos
| `Basic_recover of Netamqp_methods_0_9.arg_Basic_recover
| `Channel_close of Netamqp_methods_0_9.arg_Channel_close
| `Channel_flow of Netamqp_methods_0_9.arg_Channel_flow
| `Channel_open of Netamqp_methods_0_9.arg_Channel_open
| `Connection_close of Netamqp_methods_0_9.arg_Connection_close
| `Connection_open of Netamqp_methods_0_9.arg_Connection_open
| `Exchange_declare of Netamqp_methods_0_9.arg_Exchange_declare
| `Exchange_delete of Netamqp_methods_0_9.arg_Exchange_delete
| `Queue_bind of Netamqp_methods_0_9.arg_Queue_bind
| `Queue_declare of Netamqp_methods_0_9.arg_Queue_declare
| `Queue_delete of Netamqp_methods_0_9.arg_Queue_delete
| `Queue_purge of Netamqp_methods_0_9.arg_Queue_purge
| `Queue_unbind of Netamqp_methods_0_9.arg_Queue_unbind
| `Tx_commit
| `Tx_rollback
| `Tx_select ]
type sync_server_initiated_method_t =
[ `Channel_close of Netamqp_methods_0_9.arg_Channel_close
| `Channel_flow of Netamqp_methods_0_9.arg_Channel_flow
| `Connection_close of Netamqp_methods_0_9.arg_Connection_close
| `Connection_secure of Netamqp_methods_0_9.arg_Connection_secure
| `Connection_start of Netamqp_methods_0_9.arg_Connection_start
| `Connection_tune of Netamqp_methods_0_9.arg_Connection_tune ]
type async_client_to_server_method_t =
[ `Basic_ack of Netamqp_methods_0_9.arg_Basic_ack
| `Basic_publish of Netamqp_methods_0_9.arg_Basic_publish
| `Basic_recover_async of Netamqp_methods_0_9.arg_Basic_recover_async
| `Basic_reject of Netamqp_methods_0_9.arg_Basic_reject ]
type async_server_to_client_method_t =
[ `Basic_deliver of Netamqp_methods_0_9.arg_Basic_deliver
| `Basic_return of Netamqp_methods_0_9.arg_Basic_return ]
type content_method_t =
[ `Basic_deliver of Netamqp_methods_0_9.arg_Basic_deliver
| `Basic_get_ok of Netamqp_methods_0_9.arg_Basic_get_ok
| `Basic_publish of Netamqp_methods_0_9.arg_Basic_publish
| `Basic_return of Netamqp_methods_0_9.arg_Basic_return ]
type method_type_t =
[ `Basic_ack
| `Basic_cancel
| `Basic_cancel_ok
| `Basic_consume
| `Basic_consume_ok
| `Basic_deliver
| `Basic_get
| `Basic_get_empty
| `Basic_get_ok
| `Basic_publish
| `Basic_qos
| `Basic_qos_ok
| `Basic_recover
| `Basic_recover_async
| `Basic_recover_ok
| `Basic_reject
| `Basic_return
| `Channel_close
| `Channel_close_ok
| `Channel_flow
| `Channel_flow_ok
| `Channel_open
| `Channel_open_ok
| `Connection_close
| `Connection_close_ok
| `Connection_open
| `Connection_open_ok
| `Connection_secure
| `Connection_secure_ok
| `Connection_start
| `Connection_start_ok
| `Connection_tune
| `Connection_tune_ok
| `Exchange_declare
| `Exchange_declare_ok
| `Exchange_delete
| `Exchange_delete_ok
| `Queue_bind
| `Queue_bind_ok
| `Queue_declare
| `Queue_declare_ok
| `Queue_delete
| `Queue_delete_ok
| `Queue_purge
| `Queue_purge_ok
| `Queue_unbind
| `Queue_unbind_ok
| `Tx_commit
| `Tx_commit_ok
| `Tx_rollback
| `Tx_rollback_ok
| `Tx_select
| `Tx_select_ok ]
type sync_client_to_server_method_type_t =
[ `Basic_cancel
| `Basic_consume
| `Basic_get
| `Basic_qos
| `Basic_recover
| `Channel_close
| `Channel_close_ok
| `Channel_flow
| `Channel_flow_ok
| `Channel_open
| `Connection_close
| `Connection_close_ok
| `Connection_open
| `Connection_secure_ok
| `Connection_start_ok
| `Connection_tune_ok
| `Exchange_declare
| `Exchange_delete
| `Queue_bind
| `Queue_declare
| `Queue_delete
| `Queue_purge
| `Queue_unbind
| `Tx_commit
| `Tx_rollback
| `Tx_select ]
type sync_server_to_client_method_type_t =
[ `Basic_cancel_ok
| `Basic_consume_ok
| `Basic_get_empty
| `Basic_get_ok
| `Basic_qos_ok
| `Basic_recover_ok
| `Channel_close
| `Channel_close_ok
| `Channel_flow
| `Channel_flow_ok
| `Channel_open_ok
| `Connection_close
| `Connection_close_ok
| `Connection_open_ok
| `Connection_secure
| `Connection_start
| `Connection_tune
| `Exchange_declare_ok
| `Exchange_delete_ok
| `Queue_bind_ok
| `Queue_declare_ok
| `Queue_delete_ok
| `Queue_purge_ok
| `Queue_unbind_ok
| `Tx_commit_ok
| `Tx_rollback_ok
| `Tx_select_ok ]
type sync_client_initiated_method_type_t =
[ `Basic_cancel
| `Basic_consume
| `Basic_get
| `Basic_qos
| `Basic_recover
| `Channel_close
| `Channel_flow
| `Channel_open
| `Connection_close
| `Connection_open
| `Exchange_declare
| `Exchange_delete
| `Queue_bind
| `Queue_declare
| `Queue_delete
| `Queue_purge
| `Queue_unbind
| `Tx_commit
| `Tx_rollback
| `Tx_select ]
type sync_server_initiated_method_type_t =
[ `Channel_close
| `Channel_flow
| `Connection_close
| `Connection_secure
| `Connection_start
| `Connection_tune ]
type async_client_to_server_method_type_t =
[ `Basic_ack | `Basic_publish | `Basic_recover_async | `Basic_reject ]
type async_server_to_client_method_type_t =
[ `Basic_deliver | `Basic_return ]
type content_method_type_t =
[ `Basic_deliver | `Basic_get_ok | `Basic_publish | `Basic_return ]
val type_of_method :
Netamqp_methods_0_9.method_t -> Netamqp_methods_0_9.method_type_t
val responses_of_method :
Netamqp_methods_0_9.method_type_t ->
Netamqp_methods_0_9.method_type_t list
val content_method_types : Netamqp_methods_0_9.method_type_t list
val string_of_method_type : Netamqp_methods_0_9.method_type_t -> string
val string_of_method_id : class_id:int -> meth_id:int -> string
type props_t =
[ `P_basic of
Netamqp_methods_0_9.shortstr option *
Netamqp_methods_0_9.shortstr option *
Netamqp_methods_0_9.table option *
Netamqp_methods_0_9.octet option *
Netamqp_methods_0_9.octet option *
Netamqp_methods_0_9.shortstr option *
Netamqp_methods_0_9.shortstr option *
Netamqp_methods_0_9.shortstr option *
Netamqp_methods_0_9.shortstr option *
Netamqp_methods_0_9.timestamp option *
Netamqp_methods_0_9.shortstr option *
Netamqp_methods_0_9.shortstr option *
Netamqp_methods_0_9.shortstr option *
Netamqp_methods_0_9.shortstr option
| `P_channel
| `P_connection
| `P_exchange
| `P_queue
| `P_tx ]
type message_t =
[ `Body of Netxdr_mstring.mstring list
| `Header of Netamqp_methods_0_9.props_t * int64
| `Heartbeat
| `Method of Netamqp_methods_0_9.method_t
| `Proto_header of string ]
val decode_method_message :
Netamqp_types.frame -> Netamqp_methods_0_9.method_t
val encode_method_message :
Netamqp_methods_0_9.method_t -> int -> Netamqp_types.frame
val decode_header_message :
Netamqp_types.frame -> Netamqp_methods_0_9.props_t * int64
val encode_header_message :
Netamqp_methods_0_9.props_t -> int64 -> int -> Netamqp_types.frame
val encode_heartbeat_message : unit -> Netamqp_types.frame
val encode_body_message :
Netxdr_mstring.mstring list -> int -> Netamqp_types.frame
val encode_proto_header_message : string -> Netamqp_types.frame
val decode_message : Netamqp_types.frame -> Netamqp_methods_0_9.message_t
val encode_message :
Netamqp_methods_0_9.message_t -> int -> Netamqp_types.frame
end