import com.owera.xaps.dbi.Users; //导入依赖的package包/类
public MessageListener() {
	try {
		cp = ConnectionProvider.getConnectionProperties("xaps-ws.properties", "db.xaps");
		Users users = new Users(cp);
		User user = users.getUnprotected(Users.USER_ADMIN);
		//		if (user == null)
		//			throw error("The user " + login.getUsername() + " is unknown");

		// At this stage we have a positivt authentication of the user
		id = new Identity(SyslogConstants.FACILITY_WEBSERVICE, XAPSWS.VERSION, user);
		syslog = new Syslog(ConnectionProvider.getConnectionProperties("xaps-ws.properties", "db.syslog"), id);
		dbi = new DBI(Integer.MAX_VALUE, cp, syslog);
		inbox.addFilter(new Message(null, Message.MTYPE_PUB_PS, null, null));
		dbi.registerInbox("publishSPVS", inbox);
		sleep = new Sleep(1000, 10000, false);
		started = true;
	} catch (Throwable t) {
		logger.error("MessageListener was unable to start because of an error, no messages will be transmitted to 3-party integrators", t);
	}
}
 

import com.owera.xaps.dbi.Users; //导入依赖的package包/类
private synchronized void init(Login login, int lifetimeSec) throws RemoteException {
	if (!initialized) {
		try {
			cp = ConnectionProvider.getConnectionProperties("xaps-ws.properties", "db.xaps");
			Users users = new Users(cp);
			User user = users.getUnprotected(login.getUsername());
			if (user == null)
				throw error("The user " + login.getUsername() + " is unknown");

			id = new Identity(SyslogConstants.FACILITY_WEBSERVICE, VERSION, user);
			syslog = new Syslog(ConnectionProvider.getConnectionProperties("xaps-ws.properties", "db.syslog"), id);
			dbi = new DBI(lifetimeSec + 30, cp, syslog);
			xaps = dbi.getXaps();
			if (!login.getPassword().equals(user.getSecret()) && !user.isCorrectSecret(login.getPassword()))
				throw error("The password is incorrect");
			// At this stage we have a positive authentication of the user
			initialized = true;
			OKServlet.setError(null);
		} catch (Throwable t) {
			OKServlet.setError(t);
			String msg = "An exception occured while initializing XAPSWS object: " + t;
			logger.error(msg, t);
			throw new RemoteException(msg, t);
		}
	}
}
 

import com.owera.xaps.dbi.Users; //导入依赖的package包/类
@Override
public void execute() {
	Log.error(SessionDataCacheCleanup.class, "SessionData for " + sessionData.getUnitId() + " (key:" + unitKey
			+ ") was removed from cache after timeout - indicate a session which did not terminate correctly");

	ProvisioningMessage pm = sessionData.getProvisioningMessage();
	if (pm != null) { // only available if run in a TR-069 server (not in SPP-server)
		pm.setErrorMessage("TR-069 session was aborted - most probably because the client did not respond");
		pm.setErrorResponsibility(ErrorResponsibility.CLIENT);
		pm.setProvStatus(ProvStatus.ERROR);
		if (pm.getProvOutput() == null)
			pm.setProvOutput(ProvOutput.EMPTY);
		if (sessionData.getStartupTmsForSession() != null)
			pm.setSessionLength((int) (System.currentTimeMillis() - sessionData.getStartupTmsForSession()));
		try {
			SyslogClient.send(pm.syslogMsg(16, null, Users.USER_ADMIN));
		} catch (Throwable t) {
			Log.error(SessionDataCacheCleanup.class, "Could not send/make syslog-message in SessionDataCacheCleanup");
		}
	}

}
 

import com.owera.xaps.dbi.Users; //导入依赖的package包/类
public static void log(HTTPReqResData reqRes) {
	try {
		SessionData sessionData = reqRes.getSessionData();
		// The old logging to eventlog
		String methodsUsed = abbreviate(sessionData.getReqResList());
		long diff = System.currentTimeMillis() - sessionData.getStartupTmsForSession().longValue();
		String eventMsg = makeEventMsg(reqRes, diff, methodsUsed);
		Log.event(sessionData, eventMsg);

		// The new logging to syslog
		ProvisioningMessage pm = sessionData.getProvisioningMessage();

		if (pm.getProvOutput() == null)
			pm.setProvOutput(ProvOutput.EMPTY);
		if (reqRes.getThrowable() != null) {
			pm.setProvStatus(ProvStatus.ERROR);
			pm.setErrorResponsibility(ErrorResponsibility.SERVER);
			pm.setErrorMessage(reqRes.getThrowable().getMessage());
		} else if (pm.getProvStatus() == null)
			pm.setProvStatus(ProvStatus.OK);
		if (pm.getProvMode() == null) {
			if (sessionData.getUnit() != null)
				pm.setProvMode(sessionData.getUnit().getProvisioningMode());
			else
				pm.setProvMode(ProvisioningMode.REGULAR);
		}
		pm.setSessionLength((int) diff);
		pm.setIpAddress(reqRes.getReq().getRemoteHost());
		// We're not sending the facility-version, since the message is used in a report - where
		// the version of the TR-069 is much more interesting (will be added automatically be the syslog server)
		SyslogClient.send(pm.syslogMsg(16, null, Users.USER_ADMIN));
	} catch (Throwable t) {
		Log.warn(Provisioning.class, "An error ocurred when logging at endOfSession. Does not affect provisioning", t);
	}
}
 

import com.owera.xaps.dbi.Users; //导入依赖的package包/类
public static Syslog getSyslog() throws SQLException {
	Users users = new Users(getXAPSProperties());
	Identity id = new Identity(facility, facilityVersion, users.getUnprotected(Users.USER_ADMIN));
	Syslog syslog = new Syslog(getSyslogProperties(), id);
	return syslog;
}