lib/rflow/connection.rb in rflow-1.0.0a5 vs lib/rflow/connection.rb in rflow-1.0.0a6
- old
+ new
@@ -67,11 +67,11 @@
# Primarily for testing purposes. Captures whatever messages are sent on it.
class MessageCollectingConnection < Connection
attr_accessor :messages
def initialize
- super(RFlow::Configuration::NullConfiguration.new)
+ super(RFlow::Configuration::NullConnectionConfiguration.new)
@messages = []
end
def send_message(message)
@messages << message
@@ -82,11 +82,11 @@
# port. Can be used to get a Facade pattern effect - to have one component
# contain other components within it, shuttling messages in and out without
# making the internal component visible to the larger RFlow network.
class ForwardToOutputPort < Connection
def initialize(target_port)
- super(RFlow::Configuration::NullConfiguration.new)
+ super(RFlow::Configuration::NullConnectionConfiguration.new)
@target_port = target_port
end
def send_message(message)
@target_port.send_message(message)
@@ -97,10 +97,10 @@
# port. Can be used to get a Facade pattern effect - to have one component
# contain other components within it, shuttling messages in and out without
# making the internal component visible to the larger RFlow network.
class ForwardToInputPort < Connection
def initialize(target_port)
- super(RFlow::Configuration::NullConfiguration.new)
+ super(RFlow::Configuration::NullConnectionConfiguration.new)
@receiver = target_port.component
@target_port = target_port
end
def send_message(message)