}
  }

  void VerifyFDefEdges(
      const tensorflow::FunctionDef& fdef,
      const std::vector<EdgeSpec>& e_edges,  // expected edges
      const std::vector<EdgeSpec>& c_edges,  // expected ctrl edges
      bool is_exact_edges = true) {
    // Build a set of edges from fdef
    std::set<EdgeSpec> a_edges;  // actual edges
    // Get edges from inputs to body nodes and between body nodes

        assertTrue(json.contains("\\r"));
    }

    @Test
    public void test_jsonFormatter_unicodeControlCharacter() {
        final Map<String, Object> source = new LinkedHashMap<>();
        source.put("text", "ctrl\u0001char");

        final String json = new JsonIndexExportFormatter().format(source, Collections.emptySet());

        assertTrue(json.contains("\\u0001"));
    }

    @Test

result = channel.queue_declare(exclusive=False)
queue_name = result.method.queue

channel.queue_bind(exchange='bucketevents',
                   queue=queue_name)

print(' [*] Waiting for logs. To exit press CTRL+C')

def callback(ch, method, properties, body):
    print(" [x] %r" % body)

channel.basic_consume(callback,
                      queue=queue_name,
                      no_ack=False)