Module: RSMP

Defined in:
lib/rsmp/node.rb,
lib/rsmp/cli.rb,
lib/rsmp/rsmp.rb,
lib/rsmp/site.rb,
lib/rsmp/wait.rb,
lib/rsmp/error.rb,
lib/rsmp/proxy.rb,
lib/rsmp/logger.rb,
lib/rsmp/archive.rb,
lib/rsmp/inspect.rb,
lib/rsmp/logging.rb,
lib/rsmp/message.rb,
lib/rsmp/version.rb,
lib/rsmp/component.rb,
lib/rsmp/components.rb,
lib/rsmp/site_proxy.rb,
lib/rsmp/supervisor.rb,
lib/rsmp/collect/query.rb,
lib/rsmp/collect/matcher.rb,
lib/rsmp/tlc/signal_plan.rb,
lib/rsmp/collect/listener.rb,
lib/rsmp/collect/notifier.rb,
lib/rsmp/supervisor_proxy.rb,
lib/rsmp/tlc/signal_group.rb,
lib/rsmp/collect/collector.rb,
lib/rsmp/tlc/detector_logic.rb,
lib/rsmp/convert/import/yaml.rb,
lib/rsmp/tlc/traffic_controller.rb,
lib/rsmp/collect/message_queries.rb,
lib/rsmp/collect/message_matchers.rb,
lib/rsmp/collect/message_collector.rb,
lib/rsmp/convert/export/json_schema.rb,
lib/rsmp/tlc/traffic_controller_site.rb

Overview

Distributes messages to listeners

Defined Under Namespace

Modules: Components, Convert, Inspect, Logging, Notifier, TLC, Wait Classes: AggregatedStatus, AggregatedStatusMatcher, AggregatedStatusRequest, Alarm, AlarmAcknowledged, AlarmIssue, AlarmRequest, AlarmResume, AlarmSuspend, Archive, CLI, Clock, Collector, CommandQuery, CommandRequest, CommandResponse, CommandResponseMatcher, Component, ConfigurationError, ConnectionError, DisconnectError, Error, FatalError, HandshakeError, InvalidMessage, InvalidPacket, Listener, Logger, Malformed, MalformedMessage, Matcher, Message, MessageAck, MessageAcking, MessageCollector, MessageNotAck, MessageRejected, MissingAcknowledgment, MissingAttribute, MissingWatchdog, Node, NotReady, Proxy, Query, RepeatedAlarmError, RepeatedStatusError, SchemaError, Site, SiteProxy, StatusQuery, StatusRequest, StatusResponse, StatusResponseMatcher, StatusSubscribe, StatusUnsubscribe, StatusUpdate, StatusUpdateMatcher, StatusUpdateOrResponseMatcher, Supervisor, SupervisorProxy, TimeoutError, TimestampError, Unknown, UnknownCommand, UnknownComponent, UnknownMessage, UnknownStatus, Version, Watchdog

Constant Summary collapse

VERSION = 
"0.8.0"

Instance Method Summary collapse

Instance Method Details

#block_match?(message) ⇒ Boolean

Returns:

  • (Boolean) 


206
207
208
 
# File 'lib/rsmp/collect/message_collector.rb', line 206

def block_match? message
  @block.call(message) == true
end