EchoSender extends SenderWithParametersBase { @Override public Message sendMessage(Message message, IPipeLineSession session) throws SenderException, TimeOutException { return message; }  @Override Message sendMessage(Message message, IPipeLineSession session); @IbisDoc({"hack to allow to introduce a correlationid", "true"}) void setSynchronous(boolean b); @Override boolean isSynchronous();  }
@Test public void basic() throws SenderException, TimeOutException, ConfigurationException, IOException { sender.configure(); sender.open(); String input = "<dummy/>"; Message message = new Message(input); String result = sender.sendMessage(message, session).asString(); assertEquals(input, result); }