本文整理汇总了Java中com.arjuna.databroker.data.jee.annotation.PostCreated类的典型用法代码示例。如果您正苦于以下问题:Java PostCreated类的具体用法?Java PostCreated怎么用?Java PostCreated使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
PostCreated类属于com.arjuna.databroker.data.jee.annotation包,在下文中一共展示了PostCreated类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: config
import com.arjuna.databroker.data.jee.annotation.PostCreated; //导入依赖的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.PostCreated; //导入依赖的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.PostCreated; //导入依赖的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.PostCreated; //导入依赖的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.PostCreated; //导入依赖的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.PostCreated; //导入依赖的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.PostCreated; //导入依赖的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.PostCreated; //导入依赖的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.PostCreated; //导入依赖的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.PostCreated; //导入依赖的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.PostCreated; //导入依赖的package包/类
@PostCreated
@PostConfig
public void setup()
{
_serviceURL = _properties.get(SERVICEURL_PROPERTYNAME);
_operationNamespace = _properties.get(OPERATIONNAMESPACE_PROPERTYNAME);
_operationName = _properties.get(OPERATIONNAME_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,代码来源:PullSOAPWebServiceDataSource.java
示例12: completeCreationDataFlowNode
import com.arjuna.databroker.data.jee.annotation.PostCreated; //导入依赖的package包/类
public Boolean completeCreationDataFlowNode(String dataFlowNodeId, DataFlowNode dataFlowNode)
{
injectDataConnectors(dataFlowNodeId, dataFlowNode);
invokeLifeCycleOperation(dataFlowNode, PostCreated.class);
return Boolean.TRUE;
}
开发者ID:RISBIC,项目名称:DataBroker,代码行数:9,代码来源:JEEDataFlowNodeLifeCycleControl.java
示例13: completeCreationAndActivateDataFlowNode
import com.arjuna.databroker.data.jee.annotation.PostCreated; //导入依赖的package包/类
public Boolean completeCreationAndActivateDataFlowNode(String dataFlowNodeId, DataFlowNode dataFlowNode, DataFlow dataFlow)
{
injectDataConnectors(dataFlowNodeId, dataFlowNode);
invokeLifeCycleOperation(dataFlowNode, PostCreated.class);
invokeLifeCycleOperation(dataFlowNode, PreActivated.class);
if (dataFlow != null)
dataFlow.getDataFlowNodeInventory().addDataFlowNode(dataFlowNode);
invokeLifeCycleOperation(dataFlowNode, PostActivated.class);
return Boolean.TRUE;
}
开发者ID:RISBIC,项目名称:DataBroker,代码行数:15,代码来源:JEEDataFlowNodeLifeCycleControl.java
示例14: completeCreationDataFlowNode
import com.arjuna.databroker.data.jee.annotation.PostCreated; //导入依赖的package包/类
public Boolean completeCreationDataFlowNode(String dataFlowNodeId, DataFlowNode dataFlowNode, DataFlow dataFlow)
{
injectLoggers(dataFlowNode, dataFlow);
injectDataConnectors(dataFlowNodeId, dataFlowNode);
invokeLifeCycleOperation(dataFlowNode, PostCreated.class);
return Boolean.TRUE;
}
开发者ID:arjuna-technologies,项目名称:TestSupport_DataBroker_Utilities,代码行数:10,代码来源:TestJEEDataFlowNodeLifeCycleControl.java
示例15: completeCreationAndActivateDataFlowNode
import com.arjuna.databroker.data.jee.annotation.PostCreated; //导入依赖的package包/类
public Boolean completeCreationAndActivateDataFlowNode(String dataFlowNodeId, DataFlowNode dataFlowNode, DataFlow dataFlow)
{
injectLoggers(dataFlowNode, dataFlow);
injectDataConnectors(dataFlowNodeId, dataFlowNode);
invokeLifeCycleOperation(dataFlowNode, PostCreated.class);
invokeLifeCycleOperation(dataFlowNode, PreActivated.class);
if (dataFlow != null)
dataFlow.getDataFlowNodeInventory().addDataFlowNode(dataFlowNode);
invokeLifeCycleOperation(dataFlowNode, PostActivated.class);
return Boolean.TRUE;
}
开发者ID:arjuna-technologies,项目名称:TestSupport_DataBroker_Utilities,代码行数:16,代码来源:TestJEEDataFlowNodeLifeCycleControl.java
示例16: setup
import com.arjuna.databroker.data.jee.annotation.PostCreated; //导入依赖的package包/类
@PostCreated
public void setup()
{
if (_dataFlowNodeState != null)
_dataFlowNodeState.setState(new Integer(0));
else
logger.log(Level.WARNING, "SimpleDataSource.setup: no data flow node state available");
}
开发者ID:arjuna-technologies,项目名称:Simple_DataBroker_PlugIn,代码行数:9,代码来源:SimpleDataSource.java
示例17: setup
import com.arjuna.databroker.data.jee.annotation.PostCreated; //导入依赖的package包/类
@PostCreated
public void setup()
{
if (_dataFlowNodeState != null)
_dataFlowNodeState.setState(new Integer(0));
else
logger.log(Level.WARNING, "SimpleDataService.setup: no data flow node state available");
}
开发者ID:arjuna-technologies,项目名称:Simple_DataBroker_PlugIn,代码行数:9,代码来源:SimpleDataService.java
示例18: setup
import com.arjuna.databroker.data.jee.annotation.PostCreated; //导入依赖的package包/类
@PostCreated
public void setup()
{
if (_dataFlowNodeState != null)
_dataFlowNodeState.setState(new Integer(0));
else
logger.log(Level.WARNING, "SimpleDataStore.setup: no data flow node state available");
}
开发者ID:arjuna-technologies,项目名称:Simple_DataBroker_PlugIn,代码行数:9,代码来源:SimpleDataStore.java
示例19: setup
import com.arjuna.databroker.data.jee.annotation.PostCreated; //导入依赖的package包/类
@PostCreated
public void setup()
{
if (_dataFlowNodeState != null)
_dataFlowNodeState.setState(new Integer(0));
else
logger.log(Level.WARNING, "SimpleDataSink.setup: no data flow node state available");
}
开发者ID:arjuna-technologies,项目名称:Simple_DataBroker_PlugIn,代码行数:9,代码来源:SimpleDataSink.java
示例20: setup
import com.arjuna.databroker.data.jee.annotation.PostCreated; //导入依赖的package包/类
@PostCreated
public void setup()
{
if (_dataFlowNodeState != null)
_dataFlowNodeState.setState(new Integer(0));
else
logger.log(Level.WARNING, "SimpleDataProcessor.setup: no data flow node state available");
}
开发者ID:arjuna-technologies,项目名称:Simple_DataBroker_PlugIn,代码行数:9,代码来源:SimpleDataProcessor.java
注:本文中的com.arjuna.databroker.data.jee.annotation.PostCreated类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论