Connection
Object Hierarchy:
Description:
[ Compact ]
[ CCode ( cname = "struct amqp_connection_state_t_" , free_function = "amqp_destroy_connection" , lower_case_cprefix = "amqp_" ) ]
public class Connection
[ CCode ( cname = "struct amqp_connection_state_t_" , free_function = "amqp_destroy_connection" , lower_case_cprefix = "amqp_" ) ]
public class Connection
Namespace: AMQP
Package: librabbitmq
Content:
Creation methods:
- public Connection ()
Methods:
- public RPCReply basic_get (Channel channel, Bytes queue, bool no_ack)
- public int basic_publish (Channel channel, Bytes exchange, Bytes routing_key, bool mandatory, bool immediate, BasicProperties? properties, Bytes body)
- public int basic_reject (Channel channel, uint64 delivery_tag, bool requeue)
- public RPCReply channel_close (Channel channel, int code)
- public unowned ChannelOpen channel_open (Channel channel)
- public RPCReply close (int code)
- public bool data_in_buffer ()
- public bool frames_enqeued ()
- public int get_channel_max ()
- public RPCReply get_rpc_reply ()
- public int get_sockfd ()
- public int handle_input (Bytes received_data, Frame decoded_frame)
- public RPCReply login (string vhost, int channel_max, int frame_max, int heartbeat, SASLMethod sasl_method, ...)
- public void maybe_release_buffers ()
- public void release_buffers ()
- public int send_frame (Frame frame)
- public int send_header ()
- public int send_method (Channel channel, MethodNumber id, void* decoded)
- public void set_sockfd (int sockfd)
- public RPCReply simple_rpc (Channel channel, MethodNumber request_id, out MethodNumber expected_reply_ids, void* decoded_request_method)
- public void* simple_rpc_decoded (Channel channel, MethodNumber request_id, MethodNumber reply_id, void* decoded_request_method)
- public int simple_wait_frame (Frame decoded_frame)
- public int simple_wait_method (Channel expected_channel, Method expected_method, out Method output)
- public int tune (int channel_max, int frame_max, int heartbeat)
Fields:
- public bool buffers_ok