'Invoked when the socket is connected and it\'s time to start speaking
AMQP with the broker.'

def _on_connected(self):

    self._set_connection_state(self.CONNECTION_PROTOCOL)
    self._send_frame(frame.ProtocolHeader())
