import com.googlecode.jsendnsca.builders.MessagePayloadBuilder; //导入依赖的package包/类
@Test
public void shouldSendPassiveCheck() throws Exception {
    final NagiosSettings nagiosSettings = new NagiosSettingsBuilder()
            .withPort(stub.getPort())
            .withNagiosHost(HOSTNAME)
            .withPassword(PASSWORD)
            .withEncryption(XOR)
            .create();

    final NagiosPassiveCheckSender passiveAlerter = new NagiosPassiveCheckSender(nagiosSettings);

    final MessagePayload payload = new MessagePayloadBuilder()
            .withHostname(HOSTNAME)
            .withLevel(CRITICAL)
            .withServiceName(SERVICE_NAME)
            .withMessage(MESSAGE)
            .create();

    passiveAlerter.send(payload);

    waitForStub();

    List<MessagePayload> passiveChecksList = stub.getMessagePayloadList();
    assertThat(passiveChecksList, hasItem(payload));
}
 

import com.googlecode.jsendnsca.builders.MessagePayloadBuilder; //导入依赖的package包/类
@Test
public void shouldSendPassiveCheckWithLargeMessageSupport() throws Exception {
    stub.turnOnLargeMessageSupportAsInNsca291();

    final NagiosSettings nagiosSettings = new NagiosSettingsBuilder()
            .withPort(stub.getPort())
            .withLargeMessageSupportEnabled()
            .withNagiosHost(HOSTNAME)
            .withPassword(PASSWORD)
            .withEncryption(XOR)
            .create();

    final NagiosPassiveCheckSender passiveAlerter = new NagiosPassiveCheckSender(nagiosSettings);

    final MessagePayload payload = new MessagePayloadBuilder()
            .withHostname(HOSTNAME)
            .withLevel(CRITICAL)
            .withServiceName(SERVICE_NAME)
            .withMessage(large())
            .create();

    passiveAlerter.send(payload);

    waitForStub();

    List<MessagePayload> passiveChecksList = stub.getMessagePayloadList();
    assertThat(passiveChecksList, hasItem(payload));
}
 

import com.googlecode.jsendnsca.builders.MessagePayloadBuilder; //导入依赖的package包/类
@Test
public void shouldTrimTooLongFields() throws Exception {
    final NagiosSettings nagiosSettings = new NagiosSettingsBuilder()
            .withPort(stub.getPort())
            .withNagiosHost(HOSTNAME)
            .withPassword(PASSWORD)
            .withEncryption(XOR)
            .create();

    final NagiosPassiveCheckSender passiveAlerter = new NagiosPassiveCheckSender(nagiosSettings);

    final MessagePayload payload = new MessagePayloadBuilder()
            .withHostname(containingChars(64))
            .withServiceName(containingChars(128))
            .withMessage(containingChars(512))
            .create();

    passiveAlerter.send(payload);

    waitForStub();

    MessagePayload messagePayload = stub.getMessagePayloadList().get(0);

    assertEquals(63L, (long) messagePayload.getHostname().length());
    assertEquals(127L, (long) messagePayload.getServiceName().length());
    assertEquals(511L, (long) messagePayload.getMessage().length());
}
 

import com.googlecode.jsendnsca.builders.MessagePayloadBuilder; //导入依赖的package包/类
@Override
public synchronized void sendImpl(NagiosServiceReport report) {
	String message = report.getMessageWithPerformancedata().replace("\n",
			"\\n");
	MessagePayload payload = new MessagePayloadBuilder().withHostname(report.getServiceHost()).withLevel(status2level.get(report.getStatus())).withMessage(message).create();
	String serviceName = report.getServiceName();
	if (serviceName != null) {
		payload.setServiceName(report.getServiceName());
	}
	messageQueue.add(payload);
	logger.trace(message);
}
 

import com.googlecode.jsendnsca.builders.MessagePayloadBuilder; //导入依赖的package包/类
public void send(Level level, String serviceName, String message)
		throws NagiosException, IOException {
	message = message.replace("\n", "\\n");
	MessagePayload payload = new MessagePayloadBuilder()
			.withHostname(senderHostName).withLevel(level)
			.withServiceName(serviceName).withMessage(message).create();

	sender.send(payload);
}
 

import com.googlecode.jsendnsca.builders.MessagePayloadBuilder; //导入依赖的package包/类
private MessagePayload parsePayload(InputStream inputStream, byte[] initVector) throws IOException {
            DataInputStream stream = new DataInputStream(inputStream);

            byte[] bytes = new byte[16 + 64 + 128 + maxMessageSizeInChars];
            stream.readFully(bytes);

            decrypt(bytes, initVector);

            stream = new DataInputStream(new ByteArrayInputStream(bytes));

            int amountToSkip = 12;
            skipBytes(stream, amountToSkip);

            short level = stream.readShort();
            byte[] hostNameBytes = new byte[64];
            stream.readFully(hostNameBytes);
            String hostName = new String(hostNameBytes).trim();
            byte[] serviceNameBytes = new byte[128];
            stream.readFully(serviceNameBytes);
            String serviceName = new String(serviceNameBytes).trim();

            byte[] messageBytes = new byte[maxMessageSizeInChars];
            stream.readFully(messageBytes);
            String message = new String(messageBytes).trim();
            return new MessagePayloadBuilder().withHostname(hostName).withLevel(level).withServiceName(serviceName).withMessage(message).create();
        }