@Test public void testProcess() throws Exception { MyMessageProcessor proc = new MyMessageProcessor(); MessageTarget target = new MessageTarget().withAdapter(testName.getMethodName()).withChannel(testName.getMethodName()) .withWorkflow(testName.getMethodName()); DefaultSerializableMessage msg = new DefaultSerializableMessage().withPayload(testName.getMethodName()); register(createObjectName(target), proc); InterlokJmxClient client = new InterlokJmxClient(jmxConnectorServer.getAddress()); try { client.connect(); SerializableMessage reply = client.process(target, msg); assertNotSame(reply.getUniqueId(), proc.getMessage().getUniqueId()); assertEquals(testName.getMethodName(), reply.getContent()); assertEquals(testName.getMethodName(), reply.getContent()); } finally { client.disconnect(); } }
@Override public SerializableMessage process(MessageTarget target, SerializableMessage msg) throws InterlokException { connect(jmxURL, jmxEnv); return findWorkflow(target).process(msg); }
InterlokJmxClient extends InterlokClientImpl { @Override public SerializableMessage process(MessageTarget target, SerializableMessage msg) throws InterlokException { connect(jmxURL, jmxEnv); return findWorkflow(target).process(msg); } }
InterlokJmxClient extends InterlokClientImpl { @Override public SerializableMessage process(MessageTarget target, SerializableMessage msg) throws InterlokException { connect(jmxURL, jmxEnv); return findWorkflow(target).process(msg); } InterlokJmxClient();  InterlokJmxClient(JMXServiceURL url);  InterlokJmxClient(JMXServiceURL url, Map<String, ?> env); }
InterlokJmxClient extends InterlokClientImpl { @Override public SerializableMessage process(MessageTarget target, SerializableMessage msg) throws InterlokException { connect(jmxURL, jmxEnv); return findWorkflow(target).process(msg); } InterlokJmxClient();  InterlokJmxClient(JMXServiceURL url);  InterlokJmxClient(JMXServiceURL url, Map<String, ?> env); @Override void connect(); @Override void disconnect(); @Override void processAsync(MessageTarget target, SerializableMessage msg); @Override SerializableMessage process(MessageTarget target, SerializableMessage msg); }
InterlokJmxClient extends InterlokClientImpl { @Override public SerializableMessage process(MessageTarget target, SerializableMessage msg) throws InterlokException { connect(jmxURL, jmxEnv); return findWorkflow(target).process(msg); } InterlokJmxClient();  InterlokJmxClient(JMXServiceURL url);  InterlokJmxClient(JMXServiceURL url, Map<String, ?> env); @Override void connect(); @Override void disconnect(); @Override void processAsync(MessageTarget target, SerializableMessage msg); @Override SerializableMessage process(MessageTarget target, SerializableMessage msg);  }