import org.md2k.datakitapi.source.application.ApplicationBuilder; //导入依赖的package包/类
@Override
public void run() {
    try {
        Log.d(TAG, "runnableSubscribeResponse...run()");
        Application application = new ApplicationBuilder().setId("org.md2k.notificationmanager").build();
        DataSourceBuilder dataSourceBuilder = new DataSourceBuilder().setType(DataSourceType.NOTIFICATION_RESPONSE).setApplication(application);
        dataSourceClientResponses = DataKitAPI.getInstance(context).find(dataSourceBuilder);
        Log.d(TAG, "DataSourceClients...size=" + dataSourceClientResponses.size());
        if (dataSourceClientResponses.size() == 0) {
            handlerSubscribeResponse.postDelayed(this, 1000);
        } else {
            subscribeNotificationResponse();
            handlerSubscribeAck.post(runnableSubscribeAcknowledge);
        }
    } catch (DataKitException e) {
        LocalBroadcastManager.getInstance(context).sendBroadcast(new Intent(Constants.INTENT_RESTART));
    }
}
 

import org.md2k.datakitapi.source.application.ApplicationBuilder; //导入依赖的package包/类
@Override
public void run() {
    Application application = new ApplicationBuilder().setId("org.md2k.notificationmanager").build();
    DataSourceBuilder dataSourceBuilder = new DataSourceBuilder().setType(DataSourceType.NOTIFICATION_REQUEST).setApplication(application);
    try {
        dataSourceClietNotificationRequests = DataKitAPI.getInstance(context).find(dataSourceBuilder);
        Log.d(TAG, "datasourceclient=" + dataSourceClietNotificationRequests.size());
        if (dataSourceClietNotificationRequests.size() == 0) {
            if (RERUN > 0) {
                RERUN--;
                handler.postDelayed(this, 1000);
            } else handler.postDelayed(this, 60000);
        } else {
            subscribe();
        }
    } catch (DataKitException e) {
        Intent intent = new Intent(Constants.INTENT_STOP);
        intent.putExtra("type", "NotificationManager.java...runnableSubscribe()");
        LocalBroadcastManager.getInstance(context).sendBroadcast(intent);
    }
}
 

import org.md2k.datakitapi.source.application.ApplicationBuilder; //导入依赖的package包/类
public DataSourceBuilder createDataSourceBuilder() {
    Platform platform = new PlatformBuilder().setType(PlatformType.PHONE).build();
    ApplicationBuilder applicationBuilder=new ApplicationBuilder();
    applicationBuilder.setId(context.getApplicationInfo().packageName);
    applicationBuilder.setType(context.getApplicationInfo().name);
    Application application=applicationBuilder.build();
    return new DataSourceBuilder().setId(null).setType(dataSourceType).setPlatform(platform).setApplication(application);
}
 

import org.md2k.datakitapi.source.application.ApplicationBuilder; //导入依赖的package包/类
private DataSource createDataSourcePrivacy() {
    Platform platform = new PlatformBuilder().setType(PlatformType.PHONE).build();
    Application application = new ApplicationBuilder().setId(context.getPackageName()).build();
    return new DataSourceBuilder().setType(DataSourceType.PRIVACY).setPlatform(platform).setApplication(application).build();
}