diff options
Diffstat (limited to 'src/test/java/org/onap/dmaap/mr/dme/client')
9 files changed, 377 insertions, 221 deletions
diff --git a/src/test/java/org/onap/dmaap/mr/dme/client/DefaultLoggingFailoverFaultHandlerTest.java b/src/test/java/org/onap/dmaap/mr/dme/client/DefaultLoggingFailoverFaultHandlerTest.java deleted file mode 100644 index 5fa72dd..0000000 --- a/src/test/java/org/onap/dmaap/mr/dme/client/DefaultLoggingFailoverFaultHandlerTest.java +++ /dev/null @@ -1,59 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * ONAP Policy Engine - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - */ - -package org.onap.dmaap.mr.dme.client; - -import org.junit.After; -import org.junit.Before; -import org.junit.Test; - -import static org.junit.Assert.assertTrue; - -public class DefaultLoggingFailoverFaultHandlerTest { - private DefaultLoggingFailoverFaultHandler handler = null; - - @Before - public void setUp() throws Exception { - handler = new DefaultLoggingFailoverFaultHandler(); - - } - - @After - public void tearDown() throws Exception { - - } - - @Test - public void testHandleEndpointFailover() { - -// handler.handleEndpointFailover(null); - assertTrue(true); - - } - /* - @Test - public void testHandleRouteOfferFailover() { - - handler.handleRouteOfferFailover(null); - assertTrue(true); - - } -*/ -} diff --git a/src/test/java/org/onap/dmaap/mr/dme/client/HeaderReplyHandlerTest.java b/src/test/java/org/onap/dmaap/mr/dme/client/HeaderReplyHandlerTest.java index c3a0bb1..0cc824d 100644 --- a/src/test/java/org/onap/dmaap/mr/dme/client/HeaderReplyHandlerTest.java +++ b/src/test/java/org/onap/dmaap/mr/dme/client/HeaderReplyHandlerTest.java @@ -4,12 +4,14 @@ * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. * ================================================================================ + * Modifications Copyright © 2021 Orange. + * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -20,60 +22,58 @@ package org.onap.dmaap.mr.dme.client; -import static org.junit.Assert.assertTrue; - -import java.util.HashMap; -import java.util.Map; - +import com.att.aft.dme2.api.util.DME2ExchangeResponseContext; import org.junit.After; import org.junit.Before; import org.junit.Test; -import com.att.aft.dme2.api.util.DME2ExchangeResponseContext; +import java.util.HashMap; +import java.util.Map; + +import static org.junit.Assert.assertTrue; public class HeaderReplyHandlerTest { - private HeaderReplyHandler handler = null; + private HeaderReplyHandler handler = null; + + @Before + public void setUp() throws Exception { + handler = new HeaderReplyHandler(); + + } + + @After + public void tearDown() throws Exception { + + } - @Before - public void setUp() throws Exception { - handler = new HeaderReplyHandler(); + @Test + public void testHandleFault() { - } + handler.handleFault(null); + assertTrue(true); - @After - public void tearDown() throws Exception { + } - } + @Test + public void testHandleEndpointFault() { - @Test - public void testHandleFault() { + handler.handleEndpointFault(null); + assertTrue(true); - handler.handleFault(null); - assertTrue(true); + } - } - - @Test - public void testHandleEndpointFault() { + @Test + public void testHandleReply() { - handler.handleEndpointFault(null); - assertTrue(true); + Map<String, String> responseHeaders = new HashMap<String, String>(); + responseHeaders.put("transactionId", "1234"); - } - - @Test - public void testHandleReply() { - - Map <String, String>responseHeaders = new HashMap<String, String>(); - responseHeaders.put("transactionId", "1234"); + DME2ExchangeResponseContext responseData = new DME2ExchangeResponseContext("service", + 200, new HashMap<String, String>(), responseHeaders, "routeOffer", "1.0.0", "http://"); + handler.handleReply(responseData); + assertTrue(true); - DME2ExchangeResponseContext responseData = new DME2ExchangeResponseContext ("service", - 200, new HashMap <String, String>(), responseHeaders, "routeOffer", "1.0.0", "http://"); - handler.handleReply(responseData); - assertTrue(true); + } - } - - } diff --git a/src/test/java/org/onap/dmaap/mr/dme/client/JUnitTestSuite.java b/src/test/java/org/onap/dmaap/mr/dme/client/JUnitTestSuite.java index e1f8431..cc13578 100644 --- a/src/test/java/org/onap/dmaap/mr/dme/client/JUnitTestSuite.java +++ b/src/test/java/org/onap/dmaap/mr/dme/client/JUnitTestSuite.java @@ -4,12 +4,14 @@ * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. * ================================================================================ + * Modifications Copyright © 2021 Orange. + * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -21,7 +23,6 @@ package org.onap.dmaap.mr.dme.client; import junit.framework.TestSuite; - import org.junit.runner.RunWith; import org.junit.runners.Suite; import org.junit.runners.Suite.SuiteClasses; @@ -29,18 +30,17 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @RunWith(Suite.class) -@SuiteClasses({ DefaultLoggingFailoverFaultHandlerTest.class, HeaderReplyHandlerTest.class,PreferredRouteReplyHandlerTest.class, - PreferredRouteRequestHandlerTest.class,SimpleExamplePublisherTest.class }) - +@SuiteClasses({HeaderReplyHandlerTest.class, PreferredRouteReplyHandlerTest.class, + PreferredRouteRequestHandlerTest.class, SimpleExamplePublisherTest.class}) public class JUnitTestSuite { - private static final Logger LOGGER = LoggerFactory.getLogger(JUnitTestSuite.class); + private static final Logger logger = LoggerFactory.getLogger(JUnitTestSuite.class); + + public static void main(String[] args) { + logger.info("Running the test suite"); - public static void main(String[] args) { - LOGGER.info("Running the test suite"); - - TestSuite tstSuite = new TestSuite(); - LOGGER.info("Total Test Counts " + tstSuite.countTestCases()); - } + TestSuite tstSuite = new TestSuite(); + logger.info("Total Test Counts " + tstSuite.countTestCases()); + } } diff --git a/src/test/java/org/onap/dmaap/mr/dme/client/PreferredRouteReplyHandlerTest.java b/src/test/java/org/onap/dmaap/mr/dme/client/PreferredRouteReplyHandlerTest.java index acfea5a..fb3b8d0 100644 --- a/src/test/java/org/onap/dmaap/mr/dme/client/PreferredRouteReplyHandlerTest.java +++ b/src/test/java/org/onap/dmaap/mr/dme/client/PreferredRouteReplyHandlerTest.java @@ -4,12 +4,14 @@ * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. * ================================================================================ + * Modifications Copyright © 2021 Orange. + * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -20,70 +22,64 @@ package org.onap.dmaap.mr.dme.client; -import java.util.HashMap; -import java.util.Map; - +import com.att.aft.dme2.api.util.DME2ExchangeResponseContext; import org.junit.After; import org.junit.Before; import org.junit.Test; -import com.att.aft.dme2.api.util.DME2ExchangeResponseContext; +import java.util.HashMap; +import java.util.Map; + import static org.junit.Assert.assertNotNull; public class PreferredRouteReplyHandlerTest { - private PreferredRouteReplyHandler handler = null; - - @Before - public void setUp() throws Exception { - handler = new PreferredRouteReplyHandler(); - - } - - @After - public void tearDown() throws Exception { + private PreferredRouteReplyHandler handler = null; - } + @Before + public void setUp() throws Exception { + handler = new PreferredRouteReplyHandler(); - @Test - public void testHandleReply() { - - Map <String, String> responseHeaders = new HashMap <String, String>(); - responseHeaders.put("transactionId", "1234"); + } - DME2ExchangeResponseContext responseData = new DME2ExchangeResponseContext ("service", - 200, new HashMap<String, String>(), responseHeaders, "routeOffer", "1.0.0", "http://"); + @After + public void tearDown() throws Exception { - handler.handleReply(responseData); - assert(true); - assertNotNull(responseHeaders); + } - } -/* - @Test - public void testHandleFault() { - - handler.handleFault(null); - assertTrue(true); + @Test + public void testHandleReply() { - } - - @Test - public void testHandleEndpointFault() { + Map<String, String> responseHeaders = new HashMap<String, String>(); + responseHeaders.put("transactionId", "1234"); - handler.handleEndpointFault(null); - assertTrue(true); + DME2ExchangeResponseContext responseData = new DME2ExchangeResponseContext("service", + 200, new HashMap<String, String>(), responseHeaders, "routeOffer", "1.0.0", "http://"); - } - - @Test - public void testRouteWriter() { + handler.handleReply(responseData); + assert (true); + assertNotNull(responseHeaders); - handler.routeWriter("routeKey", "routeValue"); - assertTrue(true); + } +/* + @Test + public void testHandleFault() { + handler.handleFault(null); + assertTrue(true); + } + + @Test + public void testHandleEndpointFault() { + handler.handleEndpointFault(null); + assertTrue(true); + } + + @Test + public void testRouteWriter() { + handler.routeWriter("routeKey", "routeValue"); + assertTrue(true); + } - } - */ - + } diff --git a/src/test/java/org/onap/dmaap/mr/dme/client/PreferredRouteRequestHandlerTest.java b/src/test/java/org/onap/dmaap/mr/dme/client/PreferredRouteRequestHandlerTest.java index 167f3ff..01e6c69 100644 --- a/src/test/java/org/onap/dmaap/mr/dme/client/PreferredRouteRequestHandlerTest.java +++ b/src/test/java/org/onap/dmaap/mr/dme/client/PreferredRouteRequestHandlerTest.java @@ -4,12 +4,14 @@ * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. * ================================================================================ + * Modifications Copyright © 2021 Orange. + * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -24,39 +26,43 @@ import org.junit.After; import org.junit.Before; import org.junit.Test; -public class PreferredRouteRequestHandlerTest { - private PreferredRouteRequestHandler handler = null; +import static org.junit.Assert.assertTrue; - @Before - public void setUp() throws Exception { - handler = new PreferredRouteRequestHandler(); +public class PreferredRouteRequestHandlerTest { + private PreferredRouteRequestHandler handler = null; - } + @Before + public void setUp() throws Exception { + handler = new PreferredRouteRequestHandler(); - @After - public void tearDown() throws Exception { + } - } + @After + public void tearDown() throws Exception { - @Test - public void testHandleRequest() { + } - /* handler.handleRequest(null); - assertTrue(true);*/ + @Test + public void testHandleRequest() { - } + assertTrue(true); + /* + handler.handleRequest(null); + assertTrue(true);*/ - @Test - public void testReadRoute() { + } -// try { -// handler.readRoute("routeKey"); -// } catch (NullPointerException e) { -// assertTrue(true); -// } + @Test + public void testReadRoute() { + assertTrue(true); +// try { +// handler.readRoute("routeKey"); +// } catch (NullPointerException e) { +// assertTrue(true); +// } // -// assertTrue(true); +// assertTrue(true); - } + } } diff --git a/src/test/java/org/onap/dmaap/mr/dme/client/SimpleExampleConsumer.java b/src/test/java/org/onap/dmaap/mr/dme/client/SimpleExampleConsumer.java new file mode 100644 index 0000000..ab49cb3 --- /dev/null +++ b/src/test/java/org/onap/dmaap/mr/dme/client/SimpleExampleConsumer.java @@ -0,0 +1,87 @@ +/******************************************************************************* + * ============LICENSE_START======================================================= + * org.onap.dmaap + * ================================================================================ + * Copyright © 2017 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * Modifications Copyright © 2021 Orange. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + * + * ECOMP is a trademark and service mark of AT&T Intellectual Property. + * + *******************************************************************************/ + +package org.onap.dmaap.mr.dme.client; + +import org.onap.dmaap.mr.client.MRClientFactory; +import org.onap.dmaap.mr.client.MRConsumer; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import javax.ws.rs.core.MultivaluedMap; +import java.util.List; +import java.util.Map; + +public class SimpleExampleConsumer { + + private static final Logger logger = LoggerFactory.getLogger(SimpleExampleConsumer.class); + + private SimpleExampleConsumer() { + } + + public static void main(String[] args) { + + long count = 0; + long nextReport = 5000; + String key; + + final long startMs = System.currentTimeMillis(); + + try { + + final MRConsumer cc = MRClientFactory.createConsumer("D:\\SG\\consumer.properties"); + while (true) { + for (String msg : cc.fetch()) { + logger.debug("Message Received: " + msg); + } + // Header for DME2 Call. + MultivaluedMap<String, Object> headersMap = MRClientFactory.getHTTPHeadersMap(); + for (Map.Entry<String, List<Object>> entry : headersMap.entrySet()) { + key = entry.getKey(); + logger.debug("Header Key " + key); + logger.debug("Header Value " + headersMap.get(key)); + } + // Header for HTTP Call. + + Map<String, String> dme2headersMap = MRClientFactory.DME2HeadersMap; + for (Map.Entry<String, String> entry : dme2headersMap.entrySet()) { + key = entry.getKey(); + logger.debug("Header Key " + key); + logger.debug("Header Value " + dme2headersMap.get(key)); + } + + if (count > nextReport) { + nextReport += 5000; + + final long endMs = System.currentTimeMillis(); + final long elapsedMs = endMs - startMs; + final double elapsedSec = elapsedMs / 1000.0; + final double eps = count / elapsedSec; + } + } + } catch (Exception x) { + logger.error("Exception in SimpleExampleConsumer", x); + } + } +} diff --git a/src/test/java/org/onap/dmaap/mr/dme/client/SimpleExamplePublisher.java b/src/test/java/org/onap/dmaap/mr/dme/client/SimpleExamplePublisher.java new file mode 100644 index 0000000..6a67774 --- /dev/null +++ b/src/test/java/org/onap/dmaap/mr/dme/client/SimpleExamplePublisher.java @@ -0,0 +1,123 @@ +/******************************************************************************* + * ============LICENSE_START======================================================= + * org.onap.dmaap + * ================================================================================ + * Copyright © 2017 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * Modifications Copyright © 2021 Orange. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + * + * ECOMP is a trademark and service mark of AT&T Intellectual Property. + * + *******************************************************************************/ + +package org.onap.dmaap.mr.dme.client; + + +import org.json.JSONObject; +import org.onap.dmaap.mr.client.MRBatchingPublisher; +import org.onap.dmaap.mr.client.MRClientFactory; + +import javax.ws.rs.core.MultivaluedMap; +import java.io.IOException; +import java.util.Map; + +/** + * An example of how to use the Java publisher. + * + * @author author + */ +public class SimpleExamplePublisher { + static String content = null; + static String messageSize = null; + static String transport = null; + static String messageCount = null; + + public void publishMessage(String producerFilePath) throws IOException, InterruptedException { + + // create our publisher + // publish some messages + + StringBuilder sb = new StringBuilder(); + final MRBatchingPublisher pub = MRClientFactory.createBatchingPublisher(producerFilePath); + + if (content.equalsIgnoreCase("text/plain")) { + for (int i = 0; i < Integer.parseInt(messageCount); i++) { + for (int j = 0; j < Integer.parseInt(messageSize); j++) { + sb.append("T"); + } + + pub.send(sb.toString()); + } + } else if (content.equalsIgnoreCase("application/cambria")) { + for (int i = 0; i < Integer.parseInt(messageCount); i++) { + for (int j = 0; j < Integer.parseInt(messageSize); j++) { + sb.append("C"); + } + pub.send("Key", sb.toString()); + } + } else if (content.equalsIgnoreCase("application/json")) { + for (int i = 0; i < Integer.parseInt(messageCount); i++) { + + final JSONObject msg12 = new JSONObject(); + msg12.put("Name", "DMaaP Reference Client to Test jason Message"); + + pub.send(msg12.toString()); + + } + } + + // close the publisher to make sure everything's sent before exiting. + // The batching + // publisher interface allows the app to get the set of unsent messages. + // It could + // write them to disk, for example, to try to send them later. + /* final List<message> stuck = pub.close(20, TimeUnit.SECONDS); + if (stuck.size() > 0) { + System.err.println(stuck.size() + " messages unsent"); + } else { + System.out.println("Clean exit; all messages sent."); + }*/ + + if (transport.equalsIgnoreCase("HTTP")) { + MultivaluedMap<String, Object> headersMap = MRClientFactory.getHTTPHeadersMap(); + for (String key : headersMap.keySet()) { + System.out.println("Header Key " + key); + System.out.println("Header Value " + headersMap.get(key)); + } + } else { + Map<String, String> dme2headersMap = MRClientFactory.DME2HeadersMap; + for (String key : dme2headersMap.keySet()) { + System.out.println("Header Key " + key); + System.out.println("Header Value " + dme2headersMap.get(key)); + } + } + + } + + public static void main(String[] args) throws InterruptedException, Exception { + + String producerFilePath = args[0]; + content = args[1]; + messageSize = args[2]; + transport = args[3]; + messageCount = args[4]; + + + SimpleExamplePublisher publisher = new SimpleExamplePublisher(); + + publisher.publishMessage("D:\\SG\\producer.properties"); + } + +} diff --git a/src/test/java/org/onap/dmaap/mr/dme/client/SimpleExamplePublisherTest.java b/src/test/java/org/onap/dmaap/mr/dme/client/SimpleExamplePublisherTest.java index 477e92c..f787d88 100644 --- a/src/test/java/org/onap/dmaap/mr/dme/client/SimpleExamplePublisherTest.java +++ b/src/test/java/org/onap/dmaap/mr/dme/client/SimpleExamplePublisherTest.java @@ -4,12 +4,14 @@ * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. * ================================================================================ + * Modifications Copyright © 2021 Orange. + * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -20,39 +22,38 @@ package org.onap.dmaap.mr.dme.client; -import static org.junit.Assert.assertTrue; - import org.junit.After; import org.junit.Before; import org.junit.Test; +import static org.junit.Assert.assertTrue; + public class SimpleExamplePublisherTest { - private SimpleExamplePublisher pub = null; + private SimpleExamplePublisher pub = null; - @Before - public void setUp() throws Exception { - pub = new SimpleExamplePublisher(); + @Before + public void setUp() throws Exception { + pub = new SimpleExamplePublisher(); - } + } - @After - public void tearDown() throws Exception { + @After + public void tearDown() throws Exception { - } + } - @Test - public void testPublishMessage() { + @Test + public void testPublishMessage() { - try { - pub.publishMessage("/producer"); - } catch (Exception e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } - assertTrue(true); + try { + pub.publishMessage("/producer"); + } catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + assertTrue(true); - } + } - } diff --git a/src/test/java/org/onap/dmaap/mr/dme/client/TestRunner.java b/src/test/java/org/onap/dmaap/mr/dme/client/TestRunner.java index 59fc7f0..8b31b77 100644 --- a/src/test/java/org/onap/dmaap/mr/dme/client/TestRunner.java +++ b/src/test/java/org/onap/dmaap/mr/dme/client/TestRunner.java @@ -4,12 +4,14 @@ * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. * ================================================================================ + * Modifications Copyright © 2021 Orange. + * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -27,16 +29,16 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class TestRunner { - private static final Logger LOGGER = LoggerFactory.getLogger(TestRunner.class); + private static final Logger logger = LoggerFactory.getLogger(TestRunner.class); + + public static void main(String[] args) { + // TODO Auto-generated method stub + Result result = JUnitCore.runClasses(JUnitTestSuite.class); + for (Failure failure : result.getFailures()) { + logger.info(failure.toString()); - public static void main(String[] args) { - // TODO Auto-generated method stub - Result result = JUnitCore.runClasses(JUnitTestSuite.class); - for (Failure failure : result.getFailures()) { - LOGGER.info(failure.toString()); - - } - LOGGER.info(String.valueOf(result.wasSuccessful())); - } + } + logger.info(String.valueOf(result.wasSuccessful())); + } } |