本文整理汇总了Java中com.arjuna.databroker.data.jee.annotation.PostRecovery类的典型用法代码示例。如果您正苦于以下问题:Java PostRecovery类的具体用法?Java PostRecovery怎么用?Java PostRecovery使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
PostRecovery类属于com.arjuna.databroker.data.jee.annotation包,在下文中一共展示了PostRecovery类的15个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: config
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostCreated
@PostRecovery
@PostConfig
public void config()
{
try
{
_directory = new File(_properties.get(DIRECTORYNAME_PROPERYNAME));
_fileNamePrefix = _properties.get(FILENAMEPREFIX_PROPERYNAME);
_fileNamePostfix = _properties.get(FILENAMEPOSTFIX_PROPERYNAME);
}
catch (Throwable throwable)
{
logger.log(Level.WARNING, "Problem configuring: " + _properties, throwable);
}
}
开发者ID:arjuna-technologies,项目名称:FileSystem_DataBroker_PlugIn,代码行数:17,代码来源:DirectoryUpdateDataService.java
示例2: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostCreated
@PostRecovery
@PostConfig
public void setup()
{
_batchDataConsumer = new BatchDataConsumer(this);
_batchDataProvider = new BatchDataProvider(this);
BatchDataConsumerMap.getBatchDataConsumerMap().add(_batchDataConsumer);
BatchDataProviderMap.getBatchDataProviderMap().add(_batchDataProvider);
JobOperator jobOperator = BatchRuntime.getJobOperator();
Properties jobParameters = new Properties();
jobParameters.setProperty(BatchDataConsumerMap.ID_PROPERTYNAME, _batchDataConsumer.getId());
jobParameters.setProperty(BatchDataProviderMap.ID_PROPERTYNAME, _batchDataProvider.getId());
long execId = jobOperator.start(_properties.get(JOBID_PROPERTYNAME), jobParameters);
logger.log(Level.FINE, "BatchDataService: " + execId);
}
开发者ID:arjuna-technologies,项目名称:JEEBatch_DataBroker_Support,代码行数:22,代码来源:BatchDataService.java
示例3: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostCreated
@PostRecovery
@PostConfig
public void setup()
{
_batchDataConsumer = new BatchDataConsumer(this);
BatchDataConsumerMap.getBatchDataConsumerMap().add(_batchDataConsumer);
JobOperator jobOperator = BatchRuntime.getJobOperator();
Properties jobParameters = new Properties();
jobParameters.setProperty(BatchDataConsumerMap.ID_PROPERTYNAME, _batchDataConsumer.getId());
long execId = jobOperator.start(_properties.get(JOBID_PROPERTYNAME), jobParameters);
logger.log(Level.FINE, "BatchDataService: " + execId);
}
开发者ID:arjuna-technologies,项目名称:JEEBatch_DataBroker_Support,代码行数:19,代码来源:BatchDataSink.java
示例4: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostCreated
@PostRecovery
@PostConfig
public void setup()
{
_batchDataConsumer = new BatchDataConsumer(this);
_batchDataProvider = new BatchDataProvider(this);
BatchDataConsumerMap.getBatchDataConsumerMap().add(_batchDataConsumer);
BatchDataProviderMap.getBatchDataProviderMap().add(_batchDataProvider);
JobOperator jobOperator = BatchRuntime.getJobOperator();
Properties jobParameters = new Properties();
jobParameters.setProperty(BatchDataConsumerMap.ID_PROPERTYNAME, _batchDataConsumer.getId());
jobParameters.setProperty(BatchDataProviderMap.ID_PROPERTYNAME, _batchDataProvider.getId());
long execId = jobOperator.start(_properties.get(JOBID_PROPERTYNAME), jobParameters);
logger.log(Level.FINE, "BatchDataProcessor: " + execId);
}
开发者ID:arjuna-technologies,项目名称:JEEBatch_DataBroker_Support,代码行数:22,代码来源:BatchDataProcessor.java
示例5: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostCreated
@PostRecovery
@PostConfig
public void setup()
{
_batchDataProvider = new BatchDataProvider(this);
BatchDataProviderMap.getBatchDataProviderMap().add(_batchDataProvider);
JobOperator jobOperator = BatchRuntime.getJobOperator();
Properties jobParameters = new Properties();
jobParameters.setProperty(BatchDataProviderMap.ID_PROPERTYNAME, _batchDataProvider.getId());
long execId = jobOperator.start(_properties.get(JOBID_PROPERTYNAME), jobParameters);
logger.log(Level.FINE, "BatchDataSource: " + execId);
}
开发者ID:arjuna-technologies,项目名称:JEEBatch_DataBroker_Support,代码行数:19,代码来源:BatchDataSource.java
示例6: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostCreated
@PostRecovery
@PostConfig
public void setup()
{
try
{
_longitudeColumn = Integer.parseInt(LONGITUDECOLUMN_PROPERTYNAME_PREFIX);
_latitudeColumn = Integer.parseInt(LATITUDECOLUMN_PROPERTYNAME_PREFIX);
}
catch (Throwable throwable)
{
logger.log(Level.WARNING, "Problem during parsing of properties", throwable);
_longitudeColumn = -1;
_latitudeColumn = -1;
}
}
开发者ID:arjuna-technologies,项目名称:GeoTools_DataBroker_PlugIn,代码行数:19,代码来源:CSV2ShapeFileConverterDataProcessor.java
示例7: startup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostCreated
@PostRecovery
public void startup()
{
try
{
System.err.println("startup");
_fetcher = new Fetcher();
_fetcher.config();
_fetcher.start();
}
catch (Throwable throwable)
{
throwable.printStackTrace(System.err);
}
}
开发者ID:arjuna-technologies,项目名称:Twitter_DataBroker_PlugIn,代码行数:17,代码来源:TwitterDataSource.java
示例8: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostConfig
@PostCreated
@PostRecovery
public void setup()
{
_serverName = _properties.get(SERVERNAME_PROPERTYNAME);
_databaseName = _properties.get(DATABASENAME_PROPERTYNAME);
_user = _properties.get(USER_PROPERTYNAME);
_password = _properties.get(PASSWORD_PROPERTYNAME);
}
开发者ID:arjuna-technologies,项目名称:Azure_DataBroker_PlugIn,代码行数:12,代码来源:AzureSQLServerDataService.java
示例9: config
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostCreated
@PostRecovery
@PostConfig
public void config()
{
try
{
_file = new File(_properties.get(FILENAME_PROPERYNAME));
}
catch (Throwable throwable)
{
logger.log(Level.WARNING, "Problem configuring: " + _properties, throwable);
}
}
开发者ID:arjuna-technologies,项目名称:FileSystem_DataBroker_PlugIn,代码行数:15,代码来源:FileUpdateDataService.java
示例10: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostCreated
@PostRecovery
@PostConfig
public void setup()
{
logger.log(Level.FINER, "PullJSONWebServiceDataSource.setup");
_serviceURL = _properties.get(SERVICEURL_PROPERTYNAME);
_scheduleDelay = Long.parseLong(_properties.get(SCHEDULEDELAY_PROPERTYNAME));
_schedulePeriod = Long.parseLong(_properties.get(SCHEDULEPERIOD_PROPERTYNAME));
_username = _properties.get(USERNAME_PROPERTYNAME);
_password = _properties.get(PASSWORD_PROPERTYNAME);
}
开发者ID:arjuna-technologies,项目名称:WebService_DataBroker_PlugIn,代码行数:13,代码来源:PullJSONWebServiceDataSource.java
示例11: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostConfig
@PostCreated
@PostRecovery
public void setup()
{
_ckanRootURL = _properties.get(CKANROOTURL_PROPERTYNAME);
_packageId = _properties.get(PACKAGEID_PROPERTYNAME);
_apiKey = _properties.get(APIKEY_PROPERTYNAME);
}
开发者ID:arjuna-technologies,项目名称:CKAN_DataBroker_PlugIn,代码行数:10,代码来源:AppendFileStoreCKANDataService.java
示例12: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostConfig
@PostCreated
@PostRecovery
public void setup()
{
_dkanRootURL = _properties.get(DKANROOTURL_PROPERTYNAME);
_packageId = _properties.get(PACKAGEID_PROPERTYNAME);
_apiKey = _properties.get(APIKEY_PROPERTYNAME);
}
开发者ID:arjuna-technologies,项目名称:CKAN_DataBroker_PlugIn,代码行数:10,代码来源:FileStoreDKANDataService.java
示例13: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostCreated
@PostRecovery
@PostConfig
public void setup()
{
_endpointId = _properties.get(CSVFEEDID_PROPERTYNAME);
}
开发者ID:arjuna-technologies,项目名称:Drupal_DataBroker_PlugIn,代码行数:8,代码来源:ProviderCSVFeedDataService.java
示例14: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostCreated
@PostRecovery
@PostConfig
public void setup()
{
_endpointId = _properties.get(XMLFEEDID_PROPERTYNAME);
}
开发者ID:arjuna-technologies,项目名称:Drupal_DataBroker_PlugIn,代码行数:8,代码来源:ProviderXMLFeedDataService.java
示例15: setup
import com.arjuna.databroker.data.jee.annotation.PostRecovery; //导入依赖的package包/类
@PostConfig
@PostCreated
@PostRecovery
public void setup()
{
_serviceBaseURL = _properties.get(SERVICEBASEURL_PROPERTYNAME);
_containerName = _properties.get(CONTAINERNAME_PROPERTYNAME);
_storageConnection = _properties.get(STORAGECONNECTION_PROPERTYNAME);
_accountName = _properties.get(ACCOUNTNAME_PROPERTYNAME);
_accountKey = _properties.get(ACCOUNTKEY_PROPERTYNAME);
_containerSAS = _properties.get(CONTAINERSAS_PROPERTYNAME);
if ((_containerSAS == null) || "".equals(_containerSAS.trim()))
{
String storageConnection = null;
if ((_storageConnection != null) && (! "".equals(_storageConnection.trim())))
storageConnection = _storageConnection;
else if ((_accountName != null) && (! "".equals(_accountName.trim())) && (_accountKey != null) && (! "".equals(_accountKey.trim())))
storageConnection = "DefaultEndpointsProtocol=https;AccountName=" + _accountName + ";AccountKey=" + _accountKey;
if (storageConnection != null)
{
try
{
CloudStorageAccount storageAccount = CloudStorageAccount.parse(storageConnection);
CloudBlobClient blobClient = storageAccount.createCloudBlobClient();
CloudBlobContainer blobContainer = blobClient.getContainerReference(_containerName);
blobContainer.createIfNotExists();
SharedAccessBlobPolicy blobPolicy = new SharedAccessBlobPolicy();
GregorianCalendar calendar = new GregorianCalendar(TimeZone.getTimeZone("UTC"));
calendar.setTime(new Date());
blobPolicy.setSharedAccessStartTime(calendar.getTime());
calendar.add(Calendar.HOUR, 6);
blobPolicy.setSharedAccessExpiryTime(calendar.getTime());
blobPolicy.setPermissions(EnumSet.of(SharedAccessBlobPermissions.READ, SharedAccessBlobPermissions.WRITE));
BlobContainerPermissions containerPermissions = new BlobContainerPermissions();
containerPermissions.setPublicAccess(BlobContainerPublicAccessType.OFF);
containerPermissions.getSharedAccessPolicies().put("accesspolicy", blobPolicy);
blobContainer.uploadPermissions(containerPermissions);
_containerSAS = blobContainer.generateSharedAccessSignature(blobPolicy, null);
}
catch (Throwable throwable)
{
logger.log(Level.WARNING, "Problems with Azure blob store SAS", throwable);
}
}
}
}
开发者ID:arjuna-technologies,项目名称:Azure_DataBroker_PlugIn,代码行数:52,代码来源:AzureStorageDataService.java
注:本文中的com.arjuna.databroker.data.jee.annotation.PostRecovery类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论