before timing out

  The ``[message]`` section sets parameters for how messages are formed.

  * ``extra_limit`` -- the maximum allowed size for ``build.extra`` fields that

    appear in messages. If the ``build.extra`` field is longer (in terms of 

    json-encoded length), then it will be omitted. The default value is ``0``

    which means no limit.

  The ``[queue]`` section controls how (or if) the plugin will use the database

  to queue messages when they cannot be immediately sent.

  # if field is longer (json.dumps), ignore it

  # default value is 0 - unlimited size

  extra_limit = 0

  [queue]

  # enable persistent database queue

          return 'topic://' + koji_topic_prefix

      def send_msgs(self, event):

          for msg in self.msgs:

              # address is like "topic://koji.package.add"

              address = self.topic_prefix + '.' + msg['address']

                  self.log.debug('created new sender for %s', address)

                  self.senders[address] = sender

              pmsg = Message(properties=msg['props'], body=msg['body'])

              delivery = sender.send(pmsg)

              self.log.debug('sent message: %s', msg['props'])

              self.pending[delivery] = msg

  topic_prefix = koji

  connect_timeout = 10

  send_timeout = 60

  """)

          conf = ConfigParser()

          if six.PY2:

      @patch('protonmsg.SSLDomain')

      def test_send_msgs(self, SSLDomain, Message):

          event = MagicMock()

          self.handler.on_start(event)

          self.handler.msgs = [{'address': 'testtopic', 'props': {'testheader': 1},

                                'body': '"test body"'}]

          event.container.create_sender.assert_called_once_with(event.connection,

                                                                target='topic://koji.testtopic')

          Message.assert_called_once_with(properties={'testheader': 1}, body='"test body"')

          sender = event.container.create_sender.return_value

          sender.send.assert_called_once_with(Message.return_value)