-
Notifications
You must be signed in to change notification settings - Fork 145
TestCases
Kamil Baczkowicz edited this page Oct 9, 2016
·
1 revision
var TestCaseStepResult = Java.type("pl.baczkowicz.spy.testcases.TestCaseStepResult");
var TestCaseStatus = Java.type("pl.baczkowicz.spy.testcases.TestCaseStatus");
var getInfo = function ()
{
var TestCaseInfo = Java.type("pl.baczkowicz.spy.testcases.TestCaseInfo");
var info = new TestCaseInfo();
info.setName("Pub/sub test");
info.getSteps().add("Subscribe to test topic");
info.getSteps().add("Publish a sample message");
info.getSteps().add("Verify if received the correct message");
return info;
};
var step1 = function ()
{
// Subscribe to messages
mqttspy.subscribe("testcase/#", 0);
return new TestCaseStepResult(TestCaseStatus.ACTIONED, "Subscribed");
};
var step2 = function ()
{
mqttspy.publish("testcase/step2", "sample message 1", 0, false);
return new TestCaseStepResult(TestCaseStatus.ACTIONED, "Message published");
};
var step3 = function ()
{
// Wait up to a second to received the expected message
java.lang.Thread.sleep(1000);
// Check if received
var messages = mqttspy.getMessages("testcase/#");
var lastMessage = messages.size() > 0 ? messages.get(0).getPayload() : "";
if ("sample message 1".equals(lastMessage))
{
return new TestCaseStepResult(TestCaseStatus.PASSED, "Correct message received");
}
return new TestCaseStepResult(TestCaseStatus.FAILED, "Incorrect message received");
};
@Test
public void testSslWithMosquittoConfiguration()
{
final MqttSpyDaemon daemon = new MqttSpyDaemon();
assertTrue(daemon.start("src/test/resources/test_configurations/mosquitto-org.xml"));
while (!daemon.canPublish())
{
logger.debug("Client not connected yet - can't start test cases... [waiting another 1000ms]");
ThreadingUtils.sleep(1000);
}
final TestCaseResult result = daemon.runTestCase("src/test/resources/test_cases/test3/tc3.js");
assertTrue(result.getResult().equals(TestCaseStatus.PASSED));
assertTrue(result.getStepResults().size() >= 3);
logger.info("Steps = " + result.getStepResults().stream()
.map(Object::toString)
.collect(Collectors.joining(", ")));
daemon.stop();
}
mqtt-spy
- Getting started
- Overview
- Changelog
- Message search
- Charts
- Configuration
- Logging
- Dependencies
- Downloads
- FAQs
mqtt-spy-daemon
mqtt-spy & mqtt-spy-daemon