</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
<appender-ref ref="CTXT_FILE" />
</logger>
- <logger name="org.onap.policy.apex.core.context" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context" level="INFO" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
</configuration>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
- <logger name="org.onap.policy.apex" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex" level="INFO" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
- <logger name="org.onap.policy.apex" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex" level="INFO" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
- <logger name="org.onap.policy.apex" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex" level="INFO" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
<appender-ref ref="FILE" />
</logger>
- <logger name="org.onap.policy.apex.core.context.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
<appender-ref ref="STDOUT" />
</logger>
- <logger name="org.onap.policy.apex.core.contextmodel" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.contextmodel" level="INFO" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
<appender-ref ref="STDOUT" />
</logger>
- <logger name="org.onap.policy.apex.core" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core" level="INFO" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
<appender-ref ref="STDOUT" />
</logger>
- <logger name="org.onap.policy.apex.core" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core" level="INFO" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
<appender-ref ref="FILE" />
</logger>
- <logger name="org.onap.policy.apex.core.context.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
<appender-ref ref="STDOUT" />
</root>
- <logger name="org.onap.policy.apex" level="debug" additivity="false">
+ <logger name="org.onap.policy.apex" level="info" additivity="false">
<appender-ref ref="FILE" />
</logger>
</encoder>
</appender>
- <root level="debug">
+ <root level="info">
<appender-ref ref="FILE" />
</root>
- <logger name="org.onap.policy.apex.executionlogging" level="debug" additivity="false">
+ <logger name="org.onap.policy.apex.executionlogging" level="info" additivity="false">
<appender-ref ref="FILE" />
</logger>
-</configuration>
\ No newline at end of file
+</configuration>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
- <logger name="org.onap.policy.apex.executionlogging.TaskExecutionLogging" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.executionlogging.TaskExecutionLogging" level="INFO" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
- <logger name="org.onap.policy.apex" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex" level="INFO" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
</configuration>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.plugins.event.carrier.restserver" level="trace" additivity="false">
+ <logger name="org.onap.policy.apex.plugins.event.carrier.restserver" level="info" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
</configuration>
</encoder>
</appender>
- <logger name="org.onap.policy.apex.core.context.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.context.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
- <logger name="org.onap.policy.apex.core.engine.monitoring" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.core.engine.monitoring" level="INFO" additivity="false">
<appender-ref ref="CTXT_FILE" />
</logger>
- <logger name="org.onap.policy.apex.executionlogging" level="TRACE" additivity="false">
+ <logger name="org.onap.policy.apex.executionlogging" level="INFO" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
* 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.
- *
+ *
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
import java.util.Random;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
/**
* The Class EventGenerator.
*
* @author Liam Fallon (liam.fallon@ericsson.com)
*/
public class EventGenerator {
+ private static final Logger LOGGER = LoggerFactory.getLogger(EventGenerator.class);
+
private static int nextEventNo = 0;
/**
*/
public static void main(final String[] args) {
if (args.length != 2) {
- System.err.println("usage EventGenerator #events XML|JSON");
+ LOGGER.error("usage EventGenerator #events XML|JSON");
return;
}
try {
eventCount = Integer.parseInt(args[0]);
} catch (final Exception e) {
- System.err.println("usage EventGenerator #events XML|JSON");
+ LOGGER.error("usage EventGenerator #events XML|JSON");
e.printStackTrace();
return;
}
if (args[1].equalsIgnoreCase("XML")) {
- System.out.println(xmlEvents(eventCount));
+ LOGGER.info(xmlEvents(eventCount));
} else if (args[1].equalsIgnoreCase("JSON")) {
- System.out.println(jsonEvents(eventCount));
+ LOGGER.info(jsonEvents(eventCount));
} else {
- System.err.println("usage EventGenerator #events XML|JSON");
+ LOGGER.error("usage EventGenerator #events XML|JSON");
return;
}
}
* @throws JMSException the JMS exception
*/
public JmsEventProducer(final String topic, final ConnectionFactory connectionFactory, final String username,
- final String password, final int eventCount, final boolean sendObjects, final long eventInterval)
- throws JMSException {
+ final String password, final int eventCount, final boolean sendObjects, final long eventInterval)
+ throws JMSException {
this.topic = topic;
this.eventCount = eventCount;
this.sendObjects = sendObjects;
public void run() {
final Topic jmsTopic = new ActiveMQTopic(topic);
try (final Session jmsSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
- final MessageProducer jmsProducer = jmsSession.createProducer(jmsTopic)) {
+ final MessageProducer jmsProducer = jmsSession.createProducer(jmsTopic)) {
while (producerThread.isAlive() && !stopFlag) {
ThreadUtilities.sleep(50);
*/
private void sendEventsToTopic(final Session jmsSession, final MessageProducer jmsProducer) throws JMSException {
- LOGGER.info("{} : sending events to JMS server, event count {}", this.getClass().getCanonicalName(),
- eventCount);
+ LOGGER.debug("{} : sending events to JMS server, event count {}", this.getClass().getCanonicalName(),
+ eventCount);
for (int i = 0; i < eventCount; i++) {
ThreadUtilities.sleep(eventInterval);
jmsProducer.send(jmsMessage);
eventsSentCount++;
}
- LOGGER.info("{} : completed, number of events sent", this.getClass().getCanonicalName(), eventsSentCount);
+ LOGGER.debug("{} : completed, number of events sent", this.getClass().getCanonicalName(), eventsSentCount);
}
/**
* Shutdown.
*/
public void shutdown() {
- LOGGER.info("{} : stopping", this.getClass().getCanonicalName());
+ LOGGER.debug("{} : stopping", this.getClass().getCanonicalName());
stopFlag = true;
while (producerThread.isAlive()) {
ThreadUtilities.sleep(10);
}
- LOGGER.info("{} : stopped", this.getClass().getCanonicalName());
+ LOGGER.debug("{} : stopped", this.getClass().getCanonicalName());
}
}
throw new ApexEventRuntimeException("JMS event consumption failed", e);
}
- LOGGER.info("{} : event reception completed", this.getClass().getCanonicalName());
+ LOGGER.debug("{} : event reception completed", this.getClass().getCanonicalName());
}
/**
}
connection.close();
- LOGGER.info("{} : stopped", this.getClass().getCanonicalName());
+ LOGGER.debug("{} : stopped", this.getClass().getCanonicalName());
}
}
import org.apache.kafka.common.serialization.StringSerializer;
import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
import org.onap.policy.apex.testsuites.integration.uservice.adapt.events.EventGenerator;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* The Class KafkaEventProducer.
* @author Liam Fallon (liam.fallon@ericsson.com)
*/
public class KafkaEventProducer implements Runnable {
+ // Get a reference to the logger
+ private static final Logger LOGGER = LoggerFactory.getLogger(KafkaEventProducer.class);
+
private final String topic;
private final SharedKafkaTestResource sharedKafkaTestResource;
private final int eventCount;
* @param producer the producer
*/
private void sendEventsToTopic(final Producer<String, String> producer) {
- System.out.println(KafkaEventProducer.class.getCanonicalName()
- + ": sending events to Kafka server , event count " + eventCount + ", xmlEvents " + xmlEvents);
+ LOGGER.debug("{} : sending events to Kafka server, event count {}, xmlEvents {}",
+ KafkaEventProducer.class.getCanonicalName(), eventCount, xmlEvents);
for (int i = 0; i < eventCount; i++) {
- System.out.println(KafkaEventProducer.class.getCanonicalName() + ": waiting " + eventInterval
- + " milliseconds before sending next event");
+ LOGGER.debug("{} : waiting {} milliseconds before sending next event",
+ KafkaEventProducer.class.getCanonicalName(), eventInterval);
ThreadUtilities.sleep(eventInterval);
String eventString = null;
producer.send(new ProducerRecord<String, String>(topic, "Event" + i + "Of" + eventCount, eventString));
producer.flush();
eventsSentCount++;
- System.out.println("****** Sent event No. " + eventsSentCount + " ******");
+ LOGGER.debug("****** Sent event No. {} ******", eventsSentCount);
}
- System.out.println(KafkaEventProducer.class.getCanonicalName() + ": completed");
+ LOGGER.debug("{}: completed", KafkaEventProducer.class.getCanonicalName());
}
/**
* Shutdown.
*/
public void shutdown() {
- System.out.println(KafkaEventProducer.class.getCanonicalName() + ": stopping");
+ LOGGER.debug("{} : stopping", KafkaEventProducer.class.getCanonicalName());
stopFlag = true;
ThreadUtilities.sleep(10);
}
- System.out.println(KafkaEventProducer.class.getCanonicalName() + ": stopped");
+ LOGGER.debug("{} : stopped", KafkaEventProducer.class.getCanonicalName());
}
}
import org.apache.kafka.common.serialization.StringDeserializer;
import org.onap.policy.apex.core.infrastructure.messaging.MessagingException;
import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* The Class KafkaEventSubscriber.
* @author Liam Fallon (liam.fallon@ericsson.com)
*/
public class KafkaEventSubscriber implements Runnable {
+ // Get a reference to the logger
+ private static final Logger LOGGER = LoggerFactory.getLogger(KafkaEventSubscriber.class);
+
private static final Duration POLL_DURATION = Duration.ofMillis(100);
private final String topic;
throws MessagingException {
this.topic = topic;
-
final Properties consumerProperties = new Properties();
consumerProperties.put("group.id", "test");
-
consumer = sharedKafkaTestResource.getKafkaTestUtils().getKafkaConsumer(StringDeserializer.class,
StringDeserializer.class, consumerProperties);
consumer.subscribe(Arrays.asList(topic));
*/
@Override
public void run() {
- System.out.println(KafkaEventSubscriber.class.getCanonicalName()
- + ": receiving events from Kafka server on topic " + topic);
+ LOGGER.debug("{}: receiving events from Kafka server on topic {}",
+ KafkaEventSubscriber.class.getCanonicalName(), topic);
while (subscriberThread.isAlive() && !subscriberThread.isInterrupted()) {
try {
final ConsumerRecords<String, String> records = consumer.poll(POLL_DURATION);
for (final ConsumerRecord<String, String> record : records) {
eventsReceivedCount++;
- System.out.println("****** Received event No. " + eventsReceivedCount + " ******");
- System.out.println("offset=" + record.offset());
- System.out.println("key=" + record.key());
+ LOGGER.debug("****** Received event No. {} ******\noffset={}\nkey={}", eventsReceivedCount,
+ record.offset(), record.key());
}
} catch (final Exception e) {
// Thread interrupted
}
}
- System.out.println(KafkaEventSubscriber.class.getCanonicalName() + ": event reception completed");
+ LOGGER.debug("{}: event reception completed", KafkaEventSubscriber.class.getCanonicalName());
}
/**
}
consumer.close();
- System.out.println(KafkaEventSubscriber.class.getCanonicalName() + ": stopped");
+ LOGGER.debug("{} : stopped", KafkaEventSubscriber.class.getCanonicalName());
}
}
* 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.
- *
+ *
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageListener;
import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
import org.onap.policy.apex.testsuites.integration.uservice.adapt.events.EventGenerator;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* The Class WebSocketEventProducerClient.
*/
public class WebSocketEventProducerClient implements WsStringMessageListener {
+ private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketEventProducerClient.class);
+
private final String host;
private final int port;
private final int eventCount;
* @throws MessagingException the messaging exception
*/
public WebSocketEventProducerClient(final String host, final int port, final int eventCount,
- final boolean xmlEvents, final long eventInterval) throws MessagingException {
+ final boolean xmlEvents, final long eventInterval) throws MessagingException {
this.host = host;
this.port = port;
this.eventCount = eventCount;
client = new WsStringMessageClient(host, port);
client.start(this);
- System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": host " + host + ", port " + port
- + ", event count " + eventCount + ", xmlEvents " + xmlEvents);
+ LOGGER.debug("{}: host {}, port {}, event count {}, xmlEvents {}",
+ WebSocketEventProducerClient.class.getCanonicalName(), host, port, eventCount, xmlEvents);
}
/**
* Send events.
*/
public void sendEvents() {
- System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": sending events on host " + host
- + ", port " + port + ", event count " + eventCount + ", xmlEvents " + xmlEvents);
+ LOGGER.debug("{}: sending events on host {}, port {}, event count {}, xmlEvents {}",
+ WebSocketEventProducerClient.class.getCanonicalName(), host, port, eventCount, xmlEvents);
for (int i = 0; i < eventCount; i++) {
- System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": waiting " + eventInterval
- + " milliseconds before sending next event");
+ LOGGER.debug("{}: waiting {} milliseconds before sending next event",
+ WebSocketEventProducerClient.class.getCanonicalName(), eventInterval);
ThreadUtilities.sleep(eventInterval);
String eventString = null;
}
client.sendString(eventString);
eventsSentCount++;
- System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": host " + host + ", port "
- + port + ", sent event " + eventString);
+ LOGGER.debug("{}: host {}, port {}, sent event {}", WebSocketEventProducerClient.class.getCanonicalName(),
+ host, port, eventString);
}
- System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": completed");
+ LOGGER.debug("{}: completed", WebSocketEventProducerClient.class.getCanonicalName());
}
/**
*/
public void shutdown() {
client.stop();
- System.out.println(WebSocketEventProducerClient.class.getCanonicalName() + ": stopped");
+ LOGGER.debug("{}: stopped", WebSocketEventProducerClient.class.getCanonicalName());
}
/**
*/
@Override
public void receiveString(final String eventString) {
- System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": host " + host + ", port " + port
- + ", received event " + eventString);
+ LOGGER.debug("{}: host {}, port {}, received event {}", WebSocketEventProducerServer.class.getCanonicalName(),
+ host, port, eventString);
}
/**
*/
public static void main(final String[] args) throws MessagingException {
if (args.length != 5) {
- System.err.println("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
+ LOGGER.error("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
return;
}
try {
port = Integer.parseInt(args[1]);
} catch (final Exception e) {
- System.err.println("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
+ LOGGER.error("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
e.printStackTrace();
return;
}
try {
eventCount = Integer.parseInt(args[2]);
} catch (final Exception e) {
- System.err.println("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
+ LOGGER.error("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
e.printStackTrace();
return;
}
try {
eventInterval = Long.parseLong(args[4]);
} catch (final Exception e) {
- System.err.println("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
+ LOGGER.error("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
e.printStackTrace();
return;
}
if (args[3].equalsIgnoreCase("XML")) {
xmlEvents = true;
} else if (!args[3].equalsIgnoreCase("JSON")) {
- System.err.println("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
+ LOGGER.error("usage WebSocketEventProducerClient host port #events XML|JSON eventInterval");
return;
}
- final WebSocketEventProducerClient client =
- new WebSocketEventProducerClient(args[0], port, eventCount, xmlEvents, eventInterval);
+ final WebSocketEventProducerClient client = new WebSocketEventProducerClient(args[0], port, eventCount,
+ xmlEvents, eventInterval);
client.sendEvents();
client.shutdown();
* 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.
- *
+ *
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageServer;
import org.onap.policy.apex.core.infrastructure.threading.ThreadUtilities;
import org.onap.policy.apex.testsuites.integration.uservice.adapt.events.EventGenerator;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* The Class WebSocketEventProducerServer.
*/
public class WebSocketEventProducerServer implements WsStringMessageListener {
+ private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketEventProducerServer.class);
+
private final int port;
private final int eventCount;
private final boolean xmlEvents;
* @throws MessagingException the messaging exception
*/
public WebSocketEventProducerServer(final int port, final int eventCount, final boolean xmlEvents,
- final long eventInterval) throws MessagingException {
+ final long eventInterval) throws MessagingException {
this.port = port;
this.eventCount = eventCount;
this.xmlEvents = xmlEvents;
server = new WsStringMessageServer(port);
server.start(this);
- System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": port " + port + ", event count "
- + eventCount + ", xmlEvents " + xmlEvents);
+ LOGGER.debug("{}: port {}, event count {}, xmlEvents {}", WebSocketEventProducerServer.class.getCanonicalName(),
+ port, eventCount, xmlEvents);
}
/**
* Send events.
*/
public void sendEvents() {
- System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": sending events on port " + port
- + ", event count " + eventCount + ", xmlEvents " + xmlEvents);
+ LOGGER.debug("{}: sending events on port {}, event count {}, xmlEvents {}",
+ WebSocketEventProducerServer.class.getCanonicalName(), port, eventCount, xmlEvents);
for (int i = 0; i < eventCount; i++) {
- System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": waiting " + eventInterval
- + " milliseconds before sending next event");
+ LOGGER.debug("{}: waiting {} milliseconds before sending next event",
+ WebSocketEventProducerServer.class.getCanonicalName(), eventInterval);
ThreadUtilities.sleep(eventInterval);
String eventString = null;
}
server.sendString(eventString);
eventsSentCount++;
- System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": port " + port
- + ", sent event " + eventString);
+ LOGGER.debug("{}: port {}, sent event {}", WebSocketEventProducerServer.class.getCanonicalName(), port,
+ eventString);
}
- System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": event sending completed");
+ LOGGER.debug("{}: event sending completed", WebSocketEventProducerServer.class.getCanonicalName());
}
/**
*/
public void shutdown() {
server.stop();
- System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": stopped");
+ LOGGER.debug("{}: stopped", WebSocketEventProducerServer.class.getCanonicalName());
}
/**
*/
@Override
public void receiveString(final String eventString) {
- System.out.println(WebSocketEventProducerServer.class.getCanonicalName() + ": port " + port
- + ", received event " + eventString);
+ LOGGER.debug("{}: port {}, received event {}", WebSocketEventProducerServer.class.getCanonicalName(), port,
+ eventString);
}
/**
*/
public static void main(final String[] args) throws MessagingException {
if (args.length != 4) {
- System.err.println("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
+ LOGGER.error("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
return;
}
try {
port = Integer.parseInt(args[0]);
} catch (final Exception e) {
- System.err.println("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
+ LOGGER.error("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
e.printStackTrace();
return;
}
try {
eventCount = Integer.parseInt(args[1]);
} catch (final Exception e) {
- System.err.println("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
+ LOGGER.error("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
e.printStackTrace();
return;
}
try {
eventInterval = Long.parseLong(args[3]);
} catch (final Exception e) {
- System.err.println("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
+ LOGGER.error("usage WebSocketEventProducerServer port #events XML|JSON eventInterval");
e.printStackTrace();
return;
}
if (args[2].equalsIgnoreCase("XML")) {
xmlEvents = true;
} else if (!args[2].equalsIgnoreCase("JSON")) {
- System.err.println("usage WebSocketEventProducerServer port #events XML|JSON startDelay eventInterval");
+ LOGGER.error("usage WebSocketEventProducerServer port #events XML|JSON startDelay eventInterval");
return;
}
- final WebSocketEventProducerServer server =
- new WebSocketEventProducerServer(port, eventCount, xmlEvents, eventInterval);
+ final WebSocketEventProducerServer server = new WebSocketEventProducerServer(port, eventCount, xmlEvents,
+ eventInterval);
server.sendEvents();
server.shutdown();
* 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.
- *
+ *
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
import org.onap.policy.apex.core.infrastructure.messaging.MessagingException;
import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageClient;
import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageListener;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* The Class WebSocketEventSubscriberClient.
*/
public class WebSocketEventSubscriberClient implements WsStringMessageListener {
+ private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketEventSubscriberClient.class);
+
private final int port;
private long eventsReceivedCount = 0;
*/
@Override
public void receiveString(final String eventString) {
- System.out.println(WebSocketEventSubscriberClient.class.getCanonicalName() + ": port " + port
- + ", received event " + eventString);
+ LOGGER.debug("{}: port {}, received event {}", WebSocketEventSubscriberClient.class.getCanonicalName(), port,
+ eventString);
eventsReceivedCount++;
}
*/
public void shutdown() {
client.stop();
- System.out.println(WebSocketEventSubscriberServer.class.getCanonicalName() + ": stopped");
+ LOGGER.debug("{}: stopped", WebSocketEventSubscriberServer.class.getCanonicalName());
}
/**
*/
public static void main(final String[] args) throws MessagingException {
if (args.length != 2) {
- System.err.println("usage WebSocketEventSubscriberClient host port");
+ LOGGER.error("usage WebSocketEventSubscriberClient host port");
return;
}
try {
port = Integer.parseInt(args[0]);
} catch (final Exception e) {
- System.err.println("usage WebSocketEventSubscriberClient port");
+ LOGGER.error("usage WebSocketEventSubscriberClient port");
e.printStackTrace();
return;
}
* 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.
- *
+ *
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
import org.onap.policy.apex.core.infrastructure.messaging.MessagingException;
import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageListener;
import org.onap.policy.apex.core.infrastructure.messaging.stringmessaging.WsStringMessageServer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* The Class WebSocketEventSubscriberServer.
*/
public class WebSocketEventSubscriberServer implements WsStringMessageListener {
+ private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketEventSubscriberServer.class);
+
private final int port;
private long eventsReceivedCount = 0;
server = new WsStringMessageServer(port);
server.start(this);
- System.out.println(
- WebSocketEventSubscriberServer.class.getCanonicalName() + ": port " + port + ", waiting for events");
+ LOGGER.debug("{}: port {}, waiting for events", WebSocketEventSubscriberServer.class.getCanonicalName(), port);
}
/**
*/
@Override
public void receiveString(final String eventString) {
- System.out.println(WebSocketEventSubscriberServer.class.getCanonicalName() + ": port " + port
- + ", received event " + eventString);
+ LOGGER.debug("{}: port {}, received event {}", WebSocketEventSubscriberServer.class.getCanonicalName(), port,
+ eventString);
eventsReceivedCount++;
}
*/
public void shutdown() {
server.stop();
- System.out.println(WebSocketEventSubscriberServer.class.getCanonicalName() + ": stopped");
+ LOGGER.debug("{} : stopped", WebSocketEventSubscriberServer.class.getCanonicalName());
}
/**
*/
public static void main(final String[] args) throws MessagingException {
if (args.length != 1) {
- System.err.println("usage WebSocketEventSubscriberClient port");
+ LOGGER.error("usage WebSocketEventSubscriberClient port");
return;
}
try {
port = Integer.parseInt(args[0]);
} catch (final Exception e) {
- System.err.println("usage WebSocketEventSubscriberClient port");
+ LOGGER.error("usage WebSocketEventSubscriberClient port");
e.printStackTrace();
return;
}
* 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.
- *
+ *
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
parameters.getEngineParameters().getExecutorParameterMap().put("MVEL", new MvelExecutorParameters());
service = EngineServiceImpl.create(parameters);
-
LOGGER.debug("Running TestApexEngine. . .");
apexPolicyModel = new SampleDomainModelFactory().getSamplePolicyModel("JAVASCRIPT");
ParameterService.register(new LockManagerParameters());
ParameterService.register(new PersistorParameters());
ParameterService.register(new EngineServiceParameters());
-
+
EngineParameters engineParameters = new EngineParameters();
engineParameters.getExecutorParameterMap().put("JAVASCRIPT", new JavascriptExecutorParameters());
ParameterService.register(engineParameters);
}
-
+
/**
* Clear down parameters.
*/
ParameterService.deregister(ContextParameterConstants.MAIN_GROUP_NAME);
ParameterService.deregister(ContextParameterConstants.SCHEMA_GROUP_NAME);
}
-
+
/**
* Update the engine then test the engine with 2 sample events.
*
final long starttime = System.currentTimeMillis();
for (final AxArtifactKey engineKey : service.getEngineKeys()) {
- LOGGER.info("{}", service.getStatus(engineKey));
+ LOGGER.debug("{}", service.getStatus(engineKey));
}
while (!service.isStarted() && System.currentTimeMillis() - starttime < MAX_START_WAIT) {
ThreadUtilities.sleep(200);
eventDataMap.put("TestTimestamp", testStartTime.getTime());
eventDataMap.put("TestTemperature", 34.5445667);
- final ApexEvent event =
- new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+ final ApexEvent event = new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+ "test", "apex");
event.setExecutionId(System.nanoTime());
event.putAll(eventDataMap);
engineServiceEventInterface.sendEvent(event);
- final ApexEvent event2 =
- new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+ final ApexEvent event2 = new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+ "test", "apex");
event2.setExecutionId(System.nanoTime());
event2.putAll(eventDataMap);
engineServiceEventInterface.sendEvent(event2);
assertEquals(2, actionEventsReceived);
actionEventsReceived = 0;
-
// Stop all engines on this engine service
final long stoptime = System.currentTimeMillis();
service.stop();
final long starttime = System.currentTimeMillis();
for (final AxArtifactKey engineKey : service.getEngineKeys()) {
- LOGGER.info("{}", service.getStatus(engineKey));
+ LOGGER.debug("{}", service.getStatus(engineKey));
}
while (!service.isStarted() && System.currentTimeMillis() - starttime < MAX_START_WAIT) {
ThreadUtilities.sleep(200);
eventDataMap.put("TestTimestamp", testStartTime.getTime());
eventDataMap.put("TestTemperature", 34.5445667);
- final ApexEvent event1 =
- new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+ final ApexEvent event1 = new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+ "test", "apex");
event1.putAll(eventDataMap);
event1.setExecutionId(System.nanoTime());
ThreadUtilities.sleep(100);
}
- final ApexEvent event2 =
- new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+ final ApexEvent event2 = new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+ "test", "apex");
event2.setExecutionId(System.nanoTime());
event2.putAll(eventDataMap);
final long starttime = System.currentTimeMillis();
for (final AxArtifactKey engineKey : service.getEngineKeys()) {
- LOGGER.info("{}", service.getStatus(engineKey));
+ LOGGER.debug("{}", service.getStatus(engineKey));
}
while (!service.isStarted() && System.currentTimeMillis() - starttime < MAX_START_WAIT) {
ThreadUtilities.sleep(200);
eventDataMap.put("TestTimestamp", testStartTime.getTime());
eventDataMap.put("TestTemperature", 34.5445667);
- final ApexEvent event =
- new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+ final ApexEvent event = new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+ "test", "apex");
event.setExecutionId(System.nanoTime());
event.putAll(eventDataMap);
engineServiceEventInterface.sendEvent(event);
- final ApexEvent event2 =
- new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+ final ApexEvent event2 = new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+ "test", "apex");
event2.setExecutionId(System.nanoTime());
event2.putAll(eventDataMap);
engineServiceEventInterface.sendEvent(event2);
final long starttime = System.currentTimeMillis();
for (final AxArtifactKey engineKey : service.getEngineKeys()) {
- LOGGER.info("{}", service.getStatus(engineKey));
+ LOGGER.debug("{}", service.getStatus(engineKey));
}
while (!service.isStarted() && System.currentTimeMillis() - starttime < MAX_START_WAIT) {
ThreadUtilities.sleep(200);
eventDataMap.put("TestTimestamp", testStartTime.getTime());
eventDataMap.put("TestTemperature", 34.5445667);
- final ApexEvent event1 =
- new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+ final ApexEvent event1 = new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+ "test", "apex");
event1.putAll(eventDataMap);
final ApexEventListener myEventListener1 = new ApexEventListener() {
ThreadUtilities.sleep(100);
}
- final ApexEvent event2 =
- new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events", "test", "apex");
+ final ApexEvent event2 = new ApexEvent("Event0100", "0.0.1", "org.onap.policy.apex.domains.sample.events",
+ "test", "apex");
event2.putAll(eventDataMap);
final ApexEventListener myEventListener2 = new ApexEventListener() {
}
/**
- * The listener interface for receiving test events. The class that is interested in processing
- * a test event implements this interface, and the object created with that class is registered
- * with a component using the component's <code>addTestListener</code> method. When the test
- * event occurs, that object's appropriate method is invoked.
+ * The listener interface for receiving test events. The class that is interested in processing a test event
+ * implements this interface, and the object created with that class is registered with a component using the
+ * component's <code>addTestListener</code> method. When the test event occurs, that object's appropriate method is
+ * invoked.
*
* @see TestEvent
*/
final Date testStartTime = new Date((Long) event.get("TestTimestamp"));
final Date testEndTime = new Date();
- LOGGER.info("policy execution time: " + (testEndTime.getTime() - testStartTime.getTime()) + "ms");
+ LOGGER.debug("policy execution time: " + (testEndTime.getTime() - testStartTime.getTime()) + "ms");
}
/**
assertTrue(result.get("TestMatchCase").equals(new Byte((byte) 123)));
assertTrue(result.get("TestTemperature").equals(34.5445667));
assertTrue(((byte) result.get("TestMatchCaseSelected")) >= 0
- && ((byte) result.get("TestMatchCaseSelected") <= 3));
+ && ((byte) result.get("TestMatchCaseSelected") <= 3));
assertTrue(((byte) result.get("TestEstablishCaseSelected")) >= 0
- && ((byte) result.get("TestEstablishCaseSelected") <= 3));
+ && ((byte) result.get("TestEstablishCaseSelected") <= 3));
assertTrue(((byte) result.get("TestDecideCaseSelected")) >= 0
- && ((byte) result.get("TestDecideCaseSelected") <= 3));
- assertTrue(
- ((byte) result.get("TestActCaseSelected")) >= 0 && ((byte) result.get("TestActCaseSelected") <= 3));
+ && ((byte) result.get("TestDecideCaseSelected") <= 3));
+ assertTrue(((byte) result.get("TestActCaseSelected")) >= 0
+ && ((byte) result.get("TestActCaseSelected") <= 3));
}
}
Code Review / policy / apex-pdp.git / commitdiff