@Test public void testPublish() throws Exception { MessageTarget target = new MessageTarget().withAdapter(testName.getMethodName()).withChannel(testName.getMethodName()) .withWorkflow(testName.getMethodName()); Map<String, String> hdrs = new HashMap<>(); hdrs.put(testName.getMethodName(), testName.getMethodName()); InterlokClientStub c = new InterlokClientStub(); c.processAsync(target, testName.getMethodName(), hdrs); assertNotNull(c.msg); assertEquals(target, c.target); assertNotNull(c.msg.getUniqueId()); assertEquals(testName.getMethodName(), c.msg.getContent()); assertNull(c.msg.getContentEncoding()); assertEquals(1, c.msg.getMessageHeaders().size()); assertEquals(testName.getMethodName(), c.msg.getMessageHeaders().get(testName.getMethodName())); }
public void processAsync(MessageTarget f, String payload, Map<String, String> hdrs) throws InterlokException { processAsync(f, new DefaultSerializableMessage().withPayload(payload).withMessageHeaders(hdrs)); }
InterlokClientImpl implements InterlokClient { public void processAsync(MessageTarget f, String payload, Map<String, String> hdrs) throws InterlokException { processAsync(f, new DefaultSerializableMessage().withPayload(payload).withMessageHeaders(hdrs)); } }
InterlokClientImpl implements InterlokClient { public void processAsync(MessageTarget f, String payload, Map<String, String> hdrs) throws InterlokException { processAsync(f, new DefaultSerializableMessage().withPayload(payload).withMessageHeaders(hdrs)); }  }
InterlokClientImpl implements InterlokClient { public void processAsync(MessageTarget f, String payload, Map<String, String> hdrs) throws InterlokException { processAsync(f, new DefaultSerializableMessage().withPayload(payload).withMessageHeaders(hdrs)); }  void processAsync(MessageTarget f, String payload, Map<String, String> hdrs); }
InterlokClientImpl implements InterlokClient { public void processAsync(MessageTarget f, String payload, Map<String, String> hdrs) throws InterlokException { processAsync(f, new DefaultSerializableMessage().withPayload(payload).withMessageHeaders(hdrs)); }  void processAsync(MessageTarget f, String payload, Map<String, String> hdrs);  }