Class: LS4::Bus

Inherits:

EventBus::Bus

• Object
• EventBus::Bus
• LS4::Bus

Defined in:

lib/ls4/service/bus.rb

Direct Known Subclasses

BalanceBus, CSRPCBus, CachedMDSBus, ConfigBus, DSRPCBus, DataClientBus, GWRPCBus, MDSBus, MDSCacheBus, MasterSelectBus, MembershipBus, ProcessBus, RPCBus, RelayTimeStampBus, SlaveBus, StatBus, StorageBus, SyncBus, UpdateLogBus, WeightBus

Class Method Summary

• .ebus_call_log(method, args, &block) ⇒ Object
• .ebus_signal_error(err) ⇒ Object
• .ebus_signal_log(methods, args, &block) ⇒ Object

Methods included from EventBus::BusMixin

#ebus_all_slots, #ebus_disconnect!

Methods included from EventBus::DeclarerBase::Methods

#connect, #ebus_all_slots, #ebus_call_log, #ebus_call_slots, #ebus_signal_error, #ebus_signal_log, #ebus_signal_slots

Methods included from EventBus::DeclarerBase

#call_slot, #signal_slot

Class Method Details

.ebus_call_log(method, args, &block) ⇒ Object

# File 'lib/ls4/service/bus.rb', line 22

def self.ebus_call_log(method, args, &block)
	$log.trace { "ebus call #{method}" }
end

.ebus_signal_error(err) ⇒ Object

# File 'lib/ls4/service/bus.rb', line 30

def self.ebus_signal_error(err)
	$log.warn err
	$log.debug_backtrace err.backtrace
end

.ebus_signal_log(methods, args, &block) ⇒ Object

# File 'lib/ls4/service/bus.rb', line 26

def self.ebus_signal_log(methods, args, &block)
	$log.trace { "ebus signal #{methods.join(', ')}" }
end