MessengerImpl implements Messenger, MessageProcessor { @Override public Message createMessage( final Object payload ) { Preconditions.checkNotNull( payload, "Invalid payload" ); return new MessageImpl( getPeerManager().getLocalPeer().getId(), payload ); }  void init(); void destroy(); void setDaoManager( final DaoManager daoManager ); @Override Message createMessage( final Object payload ); @Override void sendMessage( final Peer peer, final Message message, final String recipient, final int timeToLive,
                             final Map<String, String> headers ); @Override MessageStatus getMessageStatus( final UUID messageId ); @Override void processMessage( String envelopeString ); void addMessageListener( final MessageListener listener ); void removeMessageListener( final MessageListener listener );  }
@Test public void testCreateMessage() throws Exception { Message message = messenger.createMessage( PAYLOAD ); assertNotNull( message ); }