old_contents: import logging
  from flow.command_runner.messages import CommandLineSubmitMessage
  
  LOG = logging.getLogger(__name__)
  
  class CommandLineClient(object):
      def __init__(self, broker=None,
              submit_routing_key=None,
              success_routing_key=None,
              failure_routing_key=None,
              error_routing_key=None,
              wrapper=[]):
          self.broker                     = broker
          self.submit_routing_key         = submit_routing_key
          self.success_routing_key = success_routing_key
          self.failure_routing_key = failure_routing_key
          self.error_routing_key   = error_routing_key
          self.wrapper                    = wrapper
  
      def submit(self, command_line, return_identifier=None, **executor_options):
          message = CommandLineSubmitMessage(
                  command_line=self.wrapper + command_line,
                  return_identifier=return_identifier,
                  success_routing_key=self.success_routing_key,
                  failure_routing_key=self.failure_routing_key,
                  error_routing_key=self.error_routing_key,
                  executor_options=executor_options)
  
          self.broker.publish(self.submit_routing_key, message)
  
new_contents: import logging
  from flow.command_runner.messages import CommandLineSubmitMessage
  
  LOG = logging.getLogger(__name__)
  
  class CommandLineClient(object):
      def __init__(self, broker=None, submit_routing_key=None):
          self.broker = broker
  
      def submit(self, command_line, net_key=None, response_places=None,
              **executor_options):
          message = CommandLineSubmitMessage(
                  command_line=command_line,
                  net_key=net_key,
                  response_places=response_places
                  executor_options=executor_options)
  
          self.broker.publish(self.submit_routing_key, message)
  
subject: update command_runner client to work with new message