: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 |