org.jboss.jbossts.xts.environment.XTSPropertyManager类的使用及代码示例-6ren

org.jboss.jbossts.xts.environment.XTSPropertyManager类的使用及代码示例

转载作者：知者更新时间：2024-03-24 08:05:05

本文整理了Java中org.jboss.jbossts.xts.environment.XTSPropertyManager类的一些代码示例，展示了XTSPropertyManager类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。XTSPropertyManager类的具体详情如下：
包路径：org.jboss.jbossts.xts.environment.XTSPropertyManager
类名称：XTSPropertyManager

XTSPropertyManager介绍

[英]class which ensures XTS properties are installed into the environment beans when they are created and provides access to those beans
[中]类，该类确保在创建XTS属性时将其安装到环境bean中，并提供对这些bean的访问

代码示例

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

public static void startup()
{
  final ServiceRegistry serviceRegistry = ServiceRegistry.getRegistry() ;
  WSCEnvironmentBean wscEnvironmentBean = XTSPropertyManager.getWSCEnvironmentBean();
  String bindAddress = wscEnvironmentBean.getBindAddress11();
  int bindPort = wscEnvironmentBean.getBindPort11();
  int secureBindPort = wscEnvironmentBean.getBindPortSecure11();
  WSTEnvironmentBean wstEnvironmentBean = XTSPropertyManager.getWSTEnvironmentBean();
  String participantServiceURLPath = wstEnvironmentBean.getParticipantServiceURLPath();
  if (participantServiceURLPath == null) {
    participantServiceURLPath = "/ws-t11-participant";
  }
  if (bindAddress == null) {
    bindAddress = "localhost";
  }
  if (bindPort == 0) {
    bindPort = 8080;
  }
  if (secureBindPort == 0) {
    secureBindPort = 8443;
  }
  final String baseUri = "http://" +  bindAddress + ":" + bindPort + participantServiceURLPath;
  final String uri = baseUri + "/" + BusinessActivityConstants.COORDINATOR_COMPLETION_PARTICIPANT_SERVICE_NAME;
  final String secureBaseUri = "https://" +  bindAddress + ":" + secureBindPort + participantServiceURLPath;
  final String secureUri = secureBaseUri + "/" + BusinessActivityConstants.COORDINATOR_COMPLETION_PARTICIPANT_SERVICE_NAME;
  serviceRegistry.registerServiceProvider(BusinessActivityConstants.COORDINATOR_COMPLETION_PARTICIPANT_SERVICE_NAME, uri) ;
  serviceRegistry.registerSecureServiceProvider(BusinessActivityConstants.COORDINATOR_COMPLETION_PARTICIPANT_SERVICE_NAME, secureUri) ;
}

代码示例来源：origin: org.jboss.jbossts/jbossxts

RecoveryEnvironmentBean recoveryEnvironmentBean = XTSPropertyManager.getRecoveryEnvironmentBean();

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

_initialised = true;
WSCFEnvironmentBean wscfEnvironmentBean = XTSPropertyManager.getWSCFEnvironmentBean();
List<String> protocolImplementations = wscfEnvironmentBean.getProtocolImplementations();
if (protocolImplementations == null) {

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

public UserBusinessActivityStandaloneImple()
{
  try
  {
    _activationCoordinatorService = XTSPropertyManager.getWSCEnvironmentBean().getCoordinatorURL11();
    /*
     * If the coordinator URL hasn't been specified via the
     * configuration file then assume we are using a locally registered
     * implementation.
     */
    if (_activationCoordinatorService == null)
    {
      final ServiceRegistry serviceRegistry = ServiceRegistry.getRegistry() ;
      _activationCoordinatorService = serviceRegistry.getServiceURI(CoordinationConstants.ACTIVATION_SERVICE_NAME) ;
    }
  }
  catch (Exception ex)
  {
    // TODO
    ex.printStackTrace();
  }
}

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

/**
 * Configure all configured WSTX client and participant implementations.
 *
 */
private static void configure()
  throws Exception
{
  WSTEnvironmentBean wstEnvironmentBean = XTSPropertyManager.getWSTEnvironmentBean();
  final String userTx = wstEnvironmentBean.getUserTransaction11();
  final String txManager = wstEnvironmentBean.getTransactionManager11();
  final String userBa = wstEnvironmentBean.getUserBusinessActivity11();
  final String baManager = wstEnvironmentBean.getBusinessActivityManager11();
  // we only load classes which have been configured
  
  if (userTx != null) {
    UserTransaction.setUserTransaction((UserTransaction)ClassLoaderHelper.forName(WSTXInitialisation.class, userTx).newInstance()) ;
  }
  if (txManager != null) {
    TransactionManager.setTransactionManager((TransactionManager)ClassLoaderHelper.forName(WSTXInitialisation.class, txManager).newInstance()) ;
  }
  if (userBa != null) {
    UserBusinessActivity.setUserBusinessActivity((UserBusinessActivity)ClassLoaderHelper.forName(WSTXInitialisation.class, userBa).newInstance()) ;
  }
  if (baManager != null) {
    BusinessActivityManager.setBusinessActivityManager((BusinessActivityManager)ClassLoaderHelper.forName(WSTXInitialisation.class, baManager).newInstance());
  }
}

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

XTSEnvironmentBean xtsEnvironmentBean = XTSPropertyManager.getXTSEnvironmentBean();
Iterator<String> iterator = xtsEnvironmentBean.getXtsInitialisations().iterator();

代码示例来源：origin: org.jboss.jbossts.xts/wstx11

public UserBusinessActivityStandaloneImple()
{
  try
  {
    _activationCoordinatorService = XTSPropertyManager.getWSCEnvironmentBean().getCoordinatorURL11();
    /*
     * If the coordinator URL hasn't been specified via the
     * configuration file then assume we are using a locally registered
     * implementation.
     */
    if (_activationCoordinatorService == null)
    {
      final ServiceRegistry serviceRegistry = ServiceRegistry.getRegistry() ;
      _activationCoordinatorService = serviceRegistry.getServiceURI(CoordinationConstants.ACTIVATION_SERVICE_NAME) ;
    }
  }
  catch (Exception ex)
  {
    // TODO
    ex.printStackTrace();
  }
}

代码示例来源：origin: org.jboss.jbossts.xts/wstx11

/**
 * Configure all configured WSTX client and participant implementations.
 *
 */
private static void configure()
  throws Exception
{
  WSTEnvironmentBean wstEnvironmentBean = XTSPropertyManager.getWSTEnvironmentBean();
  final String userTx = wstEnvironmentBean.getUserTransaction11();
  final String txManager = wstEnvironmentBean.getTransactionManager11();
  final String userBa = wstEnvironmentBean.getUserBusinessActivity11();
  final String baManager = wstEnvironmentBean.getBusinessActivityManager11();
  // we only load classes which have been configured
  
  if (userTx != null) {
    UserTransaction.setUserTransaction((UserTransaction)ClassLoaderHelper.forName(WSTXInitialisation.class, userTx).newInstance()) ;
  }
  if (txManager != null) {
    TransactionManager.setTransactionManager((TransactionManager)ClassLoaderHelper.forName(WSTXInitialisation.class, txManager).newInstance()) ;
  }
  if (userBa != null) {
    UserBusinessActivity.setUserBusinessActivity((UserBusinessActivity)ClassLoaderHelper.forName(WSTXInitialisation.class, userBa).newInstance()) ;
  }
  if (baManager != null) {
    BusinessActivityManager.setBusinessActivityManager((BusinessActivityManager)ClassLoaderHelper.forName(WSTXInitialisation.class, baManager).newInstance());
  }
}

代码示例来源：origin: org.jboss.jbossts/jbossxts

XTSEnvironmentBean xtsEnvironmentBean = XTSPropertyManager.getXTSEnvironmentBean();
Iterator<String> iterator = xtsEnvironmentBean.getXtsInitialisations().iterator();

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

public static void startup()
{
  final ServiceRegistry serviceRegistry = ServiceRegistry.getRegistry() ;
  WSCEnvironmentBean wscEnvironmentBean = XTSPropertyManager.getWSCEnvironmentBean();
  String bindAddress = wscEnvironmentBean.getBindAddress11();
  int bindPort = wscEnvironmentBean.getBindPort11();
  int secureBindPort = wscEnvironmentBean.getBindPortSecure11();
  WSTEnvironmentBean wstEnvironmentBean = XTSPropertyManager.getWSTEnvironmentBean();
  String clientServiceURLPath = wstEnvironmentBean.getClientServiceURLPath();
  if (clientServiceURLPath == null) {
    clientServiceURLPath = "/ws-t11-client";
  }
  if (bindAddress == null) {
    bindAddress = "localhost";
  }
  if (bindPort == 0) {
    bindPort = 8080;
  }
  if (secureBindPort == 0) {
    secureBindPort = 8443;
  }
  final String baseUri = "http://" +  bindAddress + ":" + bindPort + clientServiceURLPath;
  final String uri = baseUri + "/" + AtomicTransactionConstants.COMPLETION_INITIATOR_SERVICE_NAME;
  final String secureBaseUri = "https://" +  bindAddress + ":" + secureBindPort + clientServiceURLPath;
  final String secureUri = secureBaseUri + "/" + AtomicTransactionConstants.COMPLETION_INITIATOR_SERVICE_NAME;
  serviceRegistry.registerServiceProvider(AtomicTransactionConstants.COMPLETION_INITIATOR_SERVICE_NAME, uri) ;
  serviceRegistry.registerSecureServiceProvider(AtomicTransactionConstants.COMPLETION_INITIATOR_SERVICE_NAME, secureUri) ;
}

代码示例来源：origin: org.jboss.jbossts/jbossxts

public UserBusinessActivityStandaloneImple()
{
  try
  {
    _activationCoordinatorService = XTSPropertyManager.getWSCEnvironmentBean().getCoordinatorURL11();
    /*
     * If the coordinator URL hasn't been specified via the
     * configuration file then assume we are using a locally registered
     * implementation.
     */
    if (_activationCoordinatorService == null)
    {
      final ServiceRegistry serviceRegistry = ServiceRegistry.getRegistry() ;
      _activationCoordinatorService = serviceRegistry.getServiceURI(CoordinationConstants.ACTIVATION_SERVICE_NAME) ;
    }
  }
  catch (Exception ex)
  {
    // TODO
    ex.printStackTrace();
  }
}

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

RecoveryEnvironmentBean recoveryEnvironmentBean = XTSPropertyManager.getRecoveryEnvironmentBean();

代码示例来源：origin: org.jboss.jbossts/jbossxts

/**
 * Configure all configured WSTX client and participant implementations.
 *
 */
private static void configure()
  throws Exception
{
  WSTEnvironmentBean wstEnvironmentBean = XTSPropertyManager.getWSTEnvironmentBean();
  final String userTx = wstEnvironmentBean.getUserTransaction11();
  final String txManager = wstEnvironmentBean.getTransactionManager11();
  final String userBa = wstEnvironmentBean.getUserBusinessActivity11();
  final String baManager = wstEnvironmentBean.getBusinessActivityManager11();
  // we only load classes which have been configured
  
  if (userTx != null) {
    UserTransaction.setUserTransaction((UserTransaction)ClassLoaderHelper.forName(WSTXInitialisation.class, userTx).newInstance()) ;
  }
  if (txManager != null) {
    TransactionManager.setTransactionManager((TransactionManager)ClassLoaderHelper.forName(WSTXInitialisation.class, txManager).newInstance()) ;
  }
  if (userBa != null) {
    UserBusinessActivity.setUserBusinessActivity((UserBusinessActivity)ClassLoaderHelper.forName(WSTXInitialisation.class, userBa).newInstance()) ;
  }
  if (baManager != null) {
    BusinessActivityManager.setBusinessActivityManager((BusinessActivityManager)ClassLoaderHelper.forName(WSTXInitialisation.class, baManager).newInstance());
  }
}

代码示例来源：origin: org.jboss.jbossts/jbossxts

_initialised = true;
WSCFEnvironmentBean wscfEnvironmentBean = XTSPropertyManager.getWSCFEnvironmentBean();
List<String> protocolImplementations = wscfEnvironmentBean.getProtocolImplementations();
if (protocolImplementations == null) {

代码示例来源：origin: org.jboss.jbossts/jbossxts

public static void startup()
{
  final ServiceRegistry serviceRegistry = ServiceRegistry.getRegistry() ;
  WSCEnvironmentBean wscEnvironmentBean = XTSPropertyManager.getWSCEnvironmentBean();
  String bindAddress = wscEnvironmentBean.getBindAddress11();
  int bindPort = wscEnvironmentBean.getBindPort11();
  int secureBindPort = wscEnvironmentBean.getBindPortSecure11();
  WSTEnvironmentBean wstEnvironmentBean = XTSPropertyManager.getWSTEnvironmentBean();
  String participantServiceURLPath = wstEnvironmentBean.getParticipantServiceURLPath();
  if (participantServiceURLPath == null) {
    participantServiceURLPath = "/ws-t11-participant";
  }
  if (bindAddress == null) {
    bindAddress = "127.0.0.1";
  }
  if (bindPort == 0) {
    bindPort = 8080;
  }
  if (secureBindPort == 0) {
    secureBindPort = 8443;
  }
  final String baseUri = "http://" +  bindAddress + ":" + bindPort + participantServiceURLPath;
  final String uri = baseUri + "/" + BusinessActivityConstants.PARTICIPANT_COMPLETION_PARTICIPANT_SERVICE_NAME;
  final String secureBaseUri = "https://" +  bindAddress + ":" + secureBindPort + participantServiceURLPath;
  final String secureUri = secureBaseUri + "/" + BusinessActivityConstants.PARTICIPANT_COMPLETION_PARTICIPANT_SERVICE_NAME;
  serviceRegistry.registerServiceProvider(BusinessActivityConstants.PARTICIPANT_COMPLETION_PARTICIPANT_SERVICE_NAME, uri) ;
  serviceRegistry.registerSecureServiceProvider(BusinessActivityConstants.PARTICIPANT_COMPLETION_PARTICIPANT_SERVICE_NAME, secureUri) ;
}

代码示例来源：origin: org.jboss.jbossts/jbossxts

public UserTransactionStandaloneImple()
{
  try
  {
    _activationCoordinatorService = XTSPropertyManager.getWSCEnvironmentBean().getCoordinatorURL11();
    /*
     * If the coordinator URL hasn't been specified via the
     * configuration file then assume we are using a locally registered
     * implementation.
     */
    if (_activationCoordinatorService == null)
    {
      final ServiceRegistry serviceRegistry = ServiceRegistry.getRegistry() ;
      _activationCoordinatorService = serviceRegistry.getServiceURI(CoordinationConstants.ACTIVATION_SERVICE_NAME) ;
    }
  }
  catch (Exception ex)
  {
    // TODO
    ex.printStackTrace();
  }
  // this implementation cannot provide support for subordinate transactions
  _userSubordinateTransaction = null;
}

代码示例来源：origin: org.jboss.jbossts/jbossxts

RecoveryEnvironmentBean recoveryEnvironmentBean = XTSPropertyManager.getRecoveryEnvironmentBean();

代码示例来源：origin: org.jboss.jbossts/jbossxts

public static void startup()
{
  final ServiceRegistry serviceRegistry = ServiceRegistry.getRegistry() ;
  WSCEnvironmentBean wscEnvironmentBean = XTSPropertyManager.getWSCEnvironmentBean();
  String bindAddress = wscEnvironmentBean.getBindAddress11();
  int bindPort = wscEnvironmentBean.getBindPort11();
  int secureBindPort = wscEnvironmentBean.getBindPortSecure11();
  WSTEnvironmentBean wstEnvironmentBean = XTSPropertyManager.getWSTEnvironmentBean();
  String clientServiceURLPath = wstEnvironmentBean.getClientServiceURLPath();
  if (clientServiceURLPath == null) {
    clientServiceURLPath = "/ws-t11-client";
  }
  if (bindAddress == null) {
    bindAddress = "127.0.0.1";
  }
  if (bindPort == 0) {
    bindPort = 8080;
  }
  if (secureBindPort == 0) {
    secureBindPort = 8443;
  }
  final String baseUri = "http://" +  bindAddress + ":" + bindPort + clientServiceURLPath;
  final String uri = baseUri + "/" + ArjunaTX11Constants.TERMINATION_PARTICIPANT_SERVICE_NAME;
  final String secureBaseUri = "https://" +  bindAddress + ":" + secureBindPort + clientServiceURLPath;
  final String secureUri = secureBaseUri + "/" + ArjunaTX11Constants.TERMINATION_PARTICIPANT_SERVICE_NAME;
  serviceRegistry.registerServiceProvider(ArjunaTX11Constants.TERMINATION_PARTICIPANT_SERVICE_NAME, uri) ;
  serviceRegistry.registerSecureServiceProvider(ArjunaTX11Constants.TERMINATION_PARTICIPANT_SERVICE_NAME, secureUri) ;
}

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

public UserTransactionStandaloneImple()
{
  try
  {
    _activationCoordinatorService = XTSPropertyManager.getWSCEnvironmentBean().getCoordinatorURL11();
    /*
     * If the coordinator URL hasn't been specified via the
     * configuration file then assume we are using a locally registered
     * implementation.
     */
    if (_activationCoordinatorService == null)
    {
      final ServiceRegistry serviceRegistry = ServiceRegistry.getRegistry() ;
      _activationCoordinatorService = serviceRegistry.getServiceURI(CoordinationConstants.ACTIVATION_SERVICE_NAME) ;
    }
  }
  catch (Exception ex)
  {
    // TODO
    ex.printStackTrace();
  }
  // this implementation cannot provide support for subordinate transactions
  _userSubordinateTransaction = null;
}

代码示例来源：origin: org.jboss.jbossts.xts/jbossxts

RecoveryEnvironmentBean recoveryEnvironmentBean = XTSPropertyManager.getRecoveryEnvironmentBean();

r - XTS 应用系列和多列 XTS？
我如何使用 apply 系列函数，比如 apply.daily到多元 XTS？例如: 时间，a，b ... 2012-02-11 16:21:24 4.7258 7.7258 2012-02-11
xts 对象列表中的 rbind.xts
我有一个 xts 对象列表，这些对象具有共同的索引和列名。我想按索引进行 rbind 并对列进行平均: dts = seq.POSIXt(from = Sys.time() - days(2), t
R xts - 将不等时间步长 xts 重新采样为等距时间序列
我正在使用 xts 时间序列在 R 中工作。我有什么: 具有不等间隔时间步长的时间序列数据集。我想得到什么: 具有等距时间步长的时间序列，其值对应于与时间步长重叠的原始值的比例(请参见下面的示例)
r - xts 与另一个 xts 对象的比较不起作用
this = structure(c(-0.012, -0.028, -0.044, -0.033, -0.039, -0.042), .Dim = c(3L, 2L), .Dimnames
R xts 对象子集 xts 对象与特定时间的多天盘中数据
在 xts 对象中是否有一种方法可以执行与下面相同的操作，但对于具有多天盘中数据的 xts 对象？下面的工作就像一个时钟，但一天的数据。如果我从 22 日到 26 日通过 xts，它不会。似乎不可能一
r - 将 xts 对象中的所有列乘以另一个单列 xts 对象
library(xts) set.seed(1) x = xts( cbind(a=1:10,b=20:11) , Sys.Date()+1:10 ) y = xts( runif(10) , Sys
r - 从 xts 对象的子集中减去 xts 对象
con = gzcon(url('http://www.systematicportfolio.com/sit.gz', 'rb')) source(con) close(con) load.pack
r - 从列表的所有 xts 对象的所有列中减去一个公共(public) xts 对象
我有一个 list 。列表由 5 个 xts 对象组成。每个对象由 5 个 xts 系列组成。每个系列包含 183 个观察值。我想从所有这些系列中提取一个公共(public)系列。我要减去的系列名为
r - 在 xts 上使用 rowSums 时保留 xts 索引
在将 rowSums 传递给 xts 对象时，是否可以保留 xts 对象的索引？目前，我将结果重新转换为 xts 对象，但是如果 rowSums 能够简单地返回它的内容，这似乎并没有那么快已通过。
r - 为什么在未指定 TZ 的情况下从数据框创建 xts 对象时 xts 将日期后移一天？
首先让我说一下，我看了一下 ?xts，意识到这是一个与时区相关的问题，似乎已经解决了，但我不明白为什么它正在发生。所以:我有一个简单的价格数据数据框。当我将它转换为 xts 对象时，xts 对象的第
r - xts::apply 错误: "Error in coredata.xts(x) : currently unsupported data type"
当我尝试执行以下工作时发生错误: # generate random integrals # data <- xts(floor(runif(100, 1,101)),as.Date("1973-02
r - adf.test 使用 xts 返回 p > 0.99，但使用 coredata(xts) 返回 p < 0.01
这是输出: library(tseries) # for adf.test function adf.test(data) Augmented Dickey-Fuller Test data: da
删除 xts 图右上角的日期范围
如何删除 xts 图右上角的日期范围？例如，在下面 xts 图的右上角，我想删除文本“2007-01-02/2007-06-30”。 library(xts) data(sample_matrix)
r - xts 的每小时端点和夏令时
我有一个不规则的时间序列并且正在使用 xts的 endpoints 获取我的时间序列的每小时索引。 endpoints(data, on="hours") 我正在使用它以这种方式计算每小时 perio
r - xts 按周拆分函数将一周的第一天指定为星期日而不是默认的星期一
申请 split函数到 xts对象来自 weeks将行分组为每周块。组中的默认天数是 Monday至 Sunday .想要群里的天数来自Sunday怎么办？至 Saturday ? library(x
从 xts 对象中删除重复的行
我在删除 xts 对象中的重复行时遇到问题。我有一个 R 脚本，它将下载货币的刻度财务数据并将其转换为 OHLC 格式的 xts 对象。该脚本还会每 15 分钟提取一次新数据。新数据从今天的第一笔交易
r - XTS 指数和交易日问题
我真的很难在这里找到解决方案。如果您查看最后一行代码，您会明白我想在下次开盘时买入并在 5 天后卖出 (x = 5)。问题是 xts 索引正在计算周末。因此，例如，您会在 7 月 12 日星期五获得
r - xts 合并奇怪的行为
我有 3 个 xts 对象，它们的标记都是“日期”对象: > a a 1995-01-03 1.76 1995-01-04 1.69
从 XTS 中删除时间
我正在尝试按天比较不同的时间序列。目前典型的 XTS 对象如下所示: > vwap.crs QUANTITY QUANTITY.1 2014-03-03 13
将列表缩减为按时间排序的 xts 对象
我在列表中有一些数据，如下所示: > y $ABMD.Rank ABMD.Rank $ATVI.Rank ATVI.Rank $ADBE.Rank ADBE.Rank $

知者

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城