lib/rflow/connection.rb in rflow-1.0.1 vs lib/rflow/connection.rb in rflow-1.1.0

@@ -8,11 +8,11 @@
         when 'RFlow::Configuration::ZMQConnection'
           RFlow::Connections::ZMQConnection.new(config)
         when 'RFlow::Configuration::BrokeredZMQConnection'
           RFlow::Connections::BrokeredZMQConnection.new(config)
         else
-          raise ArgumentError, "Only ZMQConnections currently supported"
+          raise ArgumentError, 'Only ZMQConnections currently supported'
         end
       end
     end
 
     attr_accessor :config, :uuid, :name, :options
@@ -30,25 +30,25 @@
 
     # Subclass and implement to be able to handle future 'recv'
     # methods.  Will only be called in the context of a running
     # EventMachine reactor
     def connect_input!
-      raise NotImplementedError, "Raw connections do not support connect_input.  Please subclass and define a connect_input method."
+      raise NotImplementedError, 'Raw connections do not support connect_input.  Please subclass and define a connect_input method.'
     end
 
     # Subclass and implement to be able to handle future 'send'
     # methods.  Will only be called in the context of a running
     # EventMachine reactor
     def connect_output!
-      raise NotImplementedError, "Raw connections do not support connect_output.  Please subclass and define a connect_output method."
+      raise NotImplementedError, 'Raw connections do not support connect_output.  Please subclass and define a connect_output method.'
     end
 
     # Subclass and implement to handle outgoing messages.  The message
     # will be a RFlow::Message object and the subclasses are expected
     # to marshal it up into something that will be unmarshalled on the
     # other side
     def send_message(message)
-      raise NotImplementedError, "Raw connections do not support send_message.  Please subclass and define a send_message method."
+      raise NotImplementedError, 'Raw connections do not support send_message.  Please subclass and define a send_message method.'
     end
 
     # Parent component will set this attribute if it expects to
     # recieve messages.  Connection subclass should call it
     # (recv_callback.call(message)) when it gets a new message, which