| :begin |
:begin
|
true |
true |
| abort |
abort
|
true |
true |
| abort |
abort(tx_id, headers=<optional hash>)
|
true |
true |
| ack |
ack
|
true |
true |
| ack |
ack(message_frame, headers=<optional hash>)
|
true |
true |
| ack |
ack(message_id, subscription_id, headers=<optional hash>)
|
true |
true |
| ack |
ack(message_id, headers=<optional hash>)
|
true |
false |
| after_receiving |
create_event_methods :receiving, :before, :after
|
true |
true |
| after_transmitting |
create_event_methods :transmitting, :before, :after
|
true |
true |
| beat |
beat( )
|
false |
true |
| before_abort |
create_event_methods :abort, :before, :on
|
true |
true |
| before_ack |
create_event_methods :ack, :before, :on
|
true |
true |
| before_begin |
create_event_methods :begin, :before, :on
|
true |
true |
| before_broker_beat |
create_event_methods :broker_beat, :before, :on
|
false |
true |
| before_client_beat |
create_event_methods :client_beat, :before, :on
|
false |
true |
| before_commit |
create_event_methods :commit, :before, :on
|
true |
true |
| before_disconnect |
create_event_methods :disconnect, :before, :on
|
true |
true |
| before_error |
create_event_methods :error, :before, :on
|
true |
true |
| before_message |
create_event_methods :message, :before, :on
|
true |
true |
| before_nack |
create_event_methods :nack, :before, :on
|
false |
true |
| before_receipt |
create_event_methods :receipt, :before, :on
|
true |
true |
| before_receiving |
create_event_methods :receiving, :before, :after
|
true |
true |
| before_send |
create_event_methods :send, :before, :on
|
true |
true |
| before_subscribe |
create_event_methods :subscribe, :before, :on
|
true |
true |
| before_transmitting |
create_event_methods :transmitting, :before, :after
|
true |
true |
| before_unsubscribe |
create_event_methods :unsubscribe, :before, :on
|
true |
true |
| begin |
begin(tx_id, headers=<optional hash>)
|
true |
true |
| blocked |
blocked
|
true |
true |
| broker_beat |
broker_beat
|
false |
true |
| client_beat |
client_beat
|
false |
true |
| close! |
close!( )
|
true |
true |
| closed |
closed
|
true |
true |
| commit |
commit
|
true |
true |
| commit |
commit(tx_id, headers=<optional hash>)
|
true |
true |
| connect |
connect
|
true |
true |
| connect |
connect(headers=<optional hash>)
|
true |
true |
| connected? |
connected?( )
|
true |
true |
| died |
died
|
false |
true |
| disconnect |
disconnect
|
true |
true |
| disconnect |
disconnect_with_flush(headers=<optional hash>)
|
true |
true |
| disconnect |
disconnect(headers=<optional hash>)
|
true |
true |
| disconnect_with_flush |
disconnect_with_flush(headers=<optional hash>)
|
true |
true |
| error |
error
|
true |
true |
| established |
established
|
true |
true |
| initialize |
initialize(uri, options=<optional hash>)
|
true |
true |
| message |
message
|
true |
true |
| nack |
nack(message_frame, headers=<optional hash>)
|
false |
true |
| nack |
nack
|
false |
true |
| nack |
nack(message_id, subscription_id, heders=<optional hash>)
|
false |
true |
| on_abort |
create_event_methods :abort, :before, :on
|
true |
true |
| on_ack |
create_event_methods :ack, :before, :on
|
true |
true |
| on_begin |
create_event_methods :begin, :before, :on
|
true |
true |
| on_blocked |
create_event_methods :blocked, :on
|
true |
true |
| on_broker_beat |
create_event_methods :broker_beat, :before, :on
|
false |
true |
| on_client_beat |
create_event_methods :client_beat, :before, :on
|
false |
true |
| on_closed |
create_event_methods :closed, :on
|
true |
true |
| on_commit |
create_event_methods :commit, :before, :on
|
true |
true |
| on_connect |
create_event_methods :connect, :on
|
true |
true |
| on_died |
create_event_methods :died, :on
|
false |
true |
| on_disconnect |
create_event_methods :disconnect, :before, :on
|
true |
true |
| on_error |
create_event_methods :error, :before, :on
|
true |
true |
| on_established |
create_event_methods :established, :on
|
true |
true |
| on_message |
create_event_methods :message, :before, :on
|
true |
true |
| on_nack |
create_event_methods :nack, :before, :on
|
false |
true |
| on_receipt |
create_event_methods :receipt, :before, :on
|
true |
true |
| on_send |
create_event_methods :send, :before, :on
|
true |
true |
| on_subscribe |
create_event_methods :subscribe, :before, :on
|
true |
true |
| on_terminated |
create_event_methods :terminated, :on
|
true |
true |
| on_unsubscribe |
create_event_methods :unsubscribe, :before, :on
|
true |
true |
| open |
connect(headers=<optional hash>)
|
true |
true |
| puts |
send(dest, body, headers=<optional hash>, &cb)
|
true |
true |
| receipt |
receipt
|
true |
true |
| receiving |
receiving
|
true |
true |
| send |
send(dest, body, headers=<optional hash>, &cb)
|
true |
true |
| send |
send
|
true |
true |
| subscribe |
subscribe
|
true |
true |
| subscribe |
subscribe(dest, headers=<optional hash>, &cb)
|
true |
true |
| terminated |
terminated
|
true |
true |
| transmitting |
transmitting
|
true |
true |
| unsubscribe |
unsubscribe(subscribe_frame, headers=<optional hash>)
|
true |
true |
| unsubscribe |
unsubscribe(id, headers=<optional hash>)
|
true |
true |
| unsubscribe |
unsubscribe
|
true |
true |