DefaultSerializableMessage implements SerializableMessage { @Override public void addMessageHeader(String key, String val) { messageHeaders.put(key, val); } DefaultSerializableMessage(); @Override void addMessageHeader(String key, String val); @Override void removeMessageHeader(String key); @Override Map<String, String> getMessageHeaders(); @Override void setMessageHeaders(Map<String, String> hdrs); @Override String getUniqueId(); @Override void setUniqueId(String uniqueId); @Override String getContent(); @Override void setContent(String payload); @Override String getContentEncoding(); @Override void setContentEncoding(String payloadEncoding); DefaultSerializableMessage withPayload(String payload); DefaultSerializableMessage withUniqueId(String uid); DefaultSerializableMessage withPayloadEncoding(String enc); DefaultSerializableMessage withMessageHeaders(Map<String, String> hdrs); DefaultSerializableMessage withNextServiceId(String s); DefaultSerializableMessage withHeadersFromProperties(Properties props); String getNextServiceId(); void setNextServiceId(String s);  }
@Test public void testAddMessageHeader() { DefaultSerializableMessage msg = new DefaultSerializableMessage(); assertEquals(0, msg.getMessageHeaders().size()); msg.addMessageHeader(testName.getMethodName(), testName.getMethodName()); assertEquals(1, msg.getMessageHeaders().size()); assertEquals(testName.getMethodName(), msg.getMessageHeaders().get(testName.getMethodName())); }