+ @Test
+ public void validateConsumer() throws Exception {
+ try {
+ EventBusComponent rc = new EventBusComponent();
+ EventBusEndpoint endpoint = new EventBusEndpoint("http://host.com:8443/endpoint", rc);
+
+ endpoint.setApiSecret("OBF:1y0q1uvc1uum1uvg1pil1pjl1uuq1uvk1uuu1y10");
+ endpoint.setApiKey("OBF:1y0q1uvc1uum1uvg1pil1pjl1uuq1uvk1uuu1y10");
+ endpoint.setEventTopic("eventTopic");
+ endpoint.setGroupId("groupId");
+ endpoint.setGroupName("gn");
+ endpoint.setName("name");
+ endpoint.setPoolSize(45);
+ endpoint.setPollingDelay(10);
+ endpoint.setUrl("url");
+
+ TestProcessor processor = new TestProcessor();
+ EventBusConsumer consumer = new EventBusConsumer(endpoint, processor);
+
+ }
+ catch (Exception ex) {
+ StringWriter writer = new StringWriter();
+ PrintWriter printWriter = new PrintWriter( writer );
+ ex.printStackTrace( printWriter );
+ printWriter.flush();
+ System.out.println(writer.toString());
+ throw ex;
+ }
+ }