import com.googlecode.jsendnsca.encryption.Encryption; //导入依赖的package包/类
@Override
protected void collectorInit() {
	this.settings = new NagiosSettingsBuilder().withLargeMessageSupportEnabled().withNagiosHost(host.getFqdn()).withPort(host.getPort()).withEncryption(Encryption.XOR).create();

	// start thread if not already running
	if (t == null || !t.isAlive()) {
		// call hasChanged to prevent direct disconnect
		host.hasChanged();

		// start thread
		run = true;
		t = new Thread(this);
		t.setName("NSCAHost " + getCollectorEndpointName());
		t.start();
	}
}
 

import com.googlecode.jsendnsca.encryption.Encryption; //导入依赖的package包/类
public void trigger(Alarm alarm) throws AlarmCallbackException {
	String[] nsca_hosts = host.split(",");
	int limit = alarm.getStream().getAlarmMessageLimit();
	int current = alarm.getMessageCount();
	Level level = limit * 2 > current ? Level.WARNING : Level.CRITICAL;
	for (String nsca_host : nsca_hosts) {
		String[] nsca_host_parts = nsca_host.split(":");
		NscaHost nscaHost = new NscaHost(this.senderHostName,
				nsca_host_parts[0],
				nsca_host_parts.length > 1 ? Integer
						.parseInt(nsca_host_parts[0]) : 5667,
				Encryption.XOR);
		try {
			nscaHost.send(level, "Stream: " + alarm.getStream().getTitle(),
					alarm.getDescription());
		} catch (Exception e) {
			throw new AlarmCallbackException("Could not submit alert to "
					+ nsca_host + ". IOException");
		}
	}
}
 

import com.googlecode.jsendnsca.encryption.Encryption; //导入依赖的package包/类
private static Encryption toEncryption(String value) throws NagiosConfigurationException {
    try {
        return Encryption.valueOf(Encryption.class, value.toUpperCase());
    } catch (IllegalArgumentException e) {
        throw new NagiosConfigurationException("Key [%s] must be one of [%s], was [foobar]", PropertyKey.ENCRYPTION.name, Encryption
                .supportedList().toLowerCase(), value);
    }
}
 

import com.googlecode.jsendnsca.encryption.Encryption; //导入依赖的package包/类
public NscaHost(String senderHostName, String host, int port,
		Encryption encryption) {
	this.settings = new NagiosSettingsBuilder()
			.withLargeMessageSupportEnabled().withNagiosHost(host)
			.withPort(port).withEncryption(encryption).create();
	this.senderHostName = senderHostName;
	this.sender = new NagiosPassiveCheckSender(settings);
}
 

import com.googlecode.jsendnsca.encryption.Encryption; //导入依赖的package包/类
@Test
public void shouldSetEncryptionUsingEnum() throws Exception {
    nagiosSettings.setEncryption(Encryption.TRIPLE_DES);

    assertEquals(Encryption.TRIPLE_DES.getEncryptor(), nagiosSettings.getEncryptor());
}
 

import com.googlecode.jsendnsca.encryption.Encryption; //导入依赖的package包/类
/**
 * The {@link Encryption} to use to encrypt the passive check
 *
 * @param encryption
 *             encryption algorithm
 */
public void setEncryption(Encryption encryption) {
    setEncryptor(encryption.getEncryptor());
}
 

import com.googlecode.jsendnsca.encryption.Encryption; //导入依赖的package包/类
/**
 * The next {@link NagiosSettings} created will use the specified
 * {@link Encryption} constant
 *
 * @param encryption
 *            the {@link Encryption} to use
 * @return the {@link NagiosSettingsBuilder} instance
 */
public NagiosSettingsBuilder withEncryption(Encryption encryption) {
    nagiosSettings.setEncryption(encryption);
    return this;
}