@Test
public void testPutAcceptsNullValueInHeader() {

  Configurables.configure(channel, new Context());
  Event event = EventBuilder.withBody("test body".getBytes(Charsets.UTF_8),
      Collections.<String, String>singletonMap("test_key", null));
  Transaction txPut = channel.getTransaction();
  txPut.begin();
  channel.put(event);
  txPut.commit();
  txPut.close();
  Transaction txTake = channel.getTransaction();
  txTake.begin();
  Event eventTaken = channel.take();
  Assert.assertEquals(event, eventTaken);
  txTake.commit();
}