• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java PostRecovery类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了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;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java TLSUtils类代码示例发布时间:2022-05-23
下一篇:
Java KryoCallback类代码示例发布时间:2022-05-23
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap