org.jpos.q2.QFactory.newInstance()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(10.7k)|赞(0)|评价(0)|浏览(77)

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

QFactory.newInstance介绍

暂无

代码示例

代码示例来源：origin: jpos/jPOS

public Object newInstance (String clazz) throws Exception {
    return getFactory().newInstance (clazz);
  }
}

代码示例来源：origin: jpos/jPOS

protected void initStatusListeners (Element config)  throws ConfigurationException{
  final Iterator iter = config.getChildren ("status-listener").iterator();
  while (iter.hasNext()) {
    final Element e = (Element) iter.next();
    final QFactory factory = getFactory();
    final TransactionStatusListener listener = (TransactionStatusListener) factory.newInstance (e.getAttributeValue ("class"));
    factory.setConfiguration (listener, config);
    addListener(listener);
  }
}

代码示例来源：origin: jpos/jPOS-EE

private Collection<ISORequestListener> getListeners(QServer server) throws ConfigurationException {
  QFactory factory = server.getFactory();
  @SuppressWarnings("rawtypes")
  Iterator iter = server.getPersist().getChildren("request-listener").iterator();
  Collection<ISORequestListener> listeners = new ArrayList<ISORequestListener>();
  while (iter.hasNext()) {
    Element l = (Element) iter.next();
    ISORequestListener listener = (ISORequestListener) factory.newInstance(l.getAttributeValue("class"));
    factory.setLogger(listener, l);
    factory.setConfiguration(listener, l);
    listeners.add(listener);
  }
  return listeners;
}

代码示例来源：origin: jpos/jPOS

public TransactionParticipant createParticipant (Element e) 
  throws ConfigurationException
{
  QFactory factory = getFactory();
  TransactionParticipant participant = (TransactionParticipant) 
    factory.newInstance (e.getAttributeValue ("class")
  );
  factory.setLogger (participant, e);
  QFactory.invoke (participant, "setTransactionManager", this, TransactionManager.class);
  factory.setConfiguration (participant, e);
  String realm = e.getAttributeValue("realm");
  if (realm != null && realm.trim().length() > 0)
    realm = ":" + realm;
  else
    realm = "";
  names.put(participant, Caller.shortClassName(participant.getClass().getName())+realm);
  if (participant instanceof Destroyable) {
    destroyables.add((Destroyable) participant);
  }
  return participant;
}

代码示例来源：origin: jpos/jPOS

private void addListeners ()
  throws ConfigurationException
{
  QFactory factory = getFactory ();
  Iterator iter = getPersist().getChildren (
    "request-listener"
  ).iterator();
  while (iter.hasNext()) {
    Element l = (Element) iter.next();
    ISORequestListener listener = (ISORequestListener)
      factory.newInstance (l.getAttributeValue ("class"));
    factory.setLogger        (listener, l);
    factory.setConfiguration (listener, l);
    server.addISORequestListener (listener);
  }
}

代码示例来源：origin: jpos/jPOS

private void addISOServerConnectionListeners()
   throws ConfigurationException
{
  QFactory factory = getFactory ();
  Iterator iter = getPersist().getChildren (
    "connection-listener"
  ).iterator();
  while (iter.hasNext()) {
    Element l = (Element) iter.next();
    ISOServerEventListener listener = (ISOServerEventListener)
      factory.newInstance (l.getAttributeValue ("class"));
    factory.setLogger        (listener, l);
    factory.setConfiguration (listener, l);
    server.addServerEventListener(listener);
  }
}

代码示例来源：origin: jpos/jPOS

private void addListeners () 
  throws ConfigurationException
{
  QFactory factory = getFactory ();
  Iterator iter = getPersist().getChildren (
    "request-listener"
  ).iterator();
  while (iter.hasNext()) {
    Element l = (Element) iter.next();
    ISORequestListener listener = (ISORequestListener) 
      factory.newInstance (l.getAttributeValue ("class"));
    factory.setLogger        (listener, l);
    factory.setConfiguration (listener, l);
    addISORequestListener (listener);
  }
}
public void addISORequestListener(ISORequestListener l) {

代码示例来源：origin: jpos/jPOS

protected void initService () throws Exception {
  QFactory factory = getServer().getFactory();
  Element e = getPersist ();
  task = (Runnable) factory.newInstance (e.getChildTextTrim ("class"));
  factory.setLogger (task, e);
}
protected void startService () throws Exception {

代码示例来源：origin: jpos/jPOS

protected void initService () throws Exception {
  QFactory factory = getServer().getFactory();
  Element e = getPersist ();
  task = factory.newInstance (e.getChildTextTrim ("class"));
  factory.setLogger (task, e);
}
protected void startService () throws Exception {

代码示例来源：origin: jpos/jPOS

protected void initService () throws Exception {
  Element e = getPersist ();
  QFactory factory = getServer().getFactory();
  sm = (SMAdapter) factory.newInstance (getImpl ());
  factory.setLogger  (sm, e);
  factory.setConfiguration (sm, e);
}

代码示例来源：origin: jpos/jPOS

private void addFilters (FilteredChannel channel, Element e, QFactory fact) 
  throws ConfigurationException
{
  for (Object o : e.getChildren("filter")) {
    Element f = (Element) o;
    String clazz = f.getAttributeValue("class");
    ISOFilter filter = (ISOFilter) fact.newInstance(clazz);
    fact.setLogger(filter, f);
    fact.setConfiguration(filter, f);
    String direction = f.getAttributeValue("direction");
    if (direction == null)
      channel.addFilter(filter);
    else if ("incoming".equalsIgnoreCase(direction))
      channel.addIncomingFilter(filter);
    else if ("outgoing".equalsIgnoreCase(direction))
      channel.addOutgoingFilter(filter);
    else if ("both".equalsIgnoreCase(direction)) {
      channel.addIncomingFilter(filter);
      channel.addOutgoingFilter(filter);
    }
  }
}

代码示例来源：origin: jpos/jPOS

protected void addFilters (FilteredChannel channel, Element e, QFactory fact)
  throws ConfigurationException
{
  for (Object o : e.getChildren("filter")) {
    Element f = (Element) o;
    String clazz = f.getAttributeValue("class");
    ISOFilter filter = (ISOFilter) fact.newInstance(clazz);
    fact.setLogger(filter, f);
    fact.setConfiguration(filter, f);
    String direction = f.getAttributeValue("direction");
    if (direction == null)
      channel.addFilter(filter);
    else if ("incoming".equalsIgnoreCase(direction))
      channel.addIncomingFilter(filter);
    else if ("outgoing".equalsIgnoreCase(direction))
      channel.addOutgoingFilter(filter);
    else if ("both".equalsIgnoreCase(direction)) {
      channel.addIncomingFilter(filter);
      channel.addOutgoingFilter(filter);
    }
  }
}

代码示例来源：origin: jpos/jPOS

private void addServerSocketFactory () throws ConfigurationException {
  QFactory factory = getFactory ();
  Element persist = getPersist ();
  Element serverSocketFactoryElement = persist.getChild ("server-socket-factory");
  if (serverSocketFactoryElement != null) {
    ISOServerSocketFactory serverSocketFactory = (ISOServerSocketFactory) factory.newInstance (serverSocketFactoryElement.getAttributeValue ("class"));
    factory.setLogger        (serverSocketFactory, serverSocketFactoryElement);
    factory.setConfiguration (serverSocketFactory, serverSocketFactoryElement);
    server.setSocketFactory(serverSocketFactory);
  }
}

代码示例来源：origin: jpos/jPOS

default void addExceptionHandlers(ExceptionHandlerAware receiver, Element elem, QFactory fact)
      throws ConfigurationException
  {
    for (Element o : elem.getChildren("exception-handler")) {
      String clazz = o.getAttributeValue("class");
      ExceptionHandler handler = (ExceptionHandler) fact.newInstance(clazz);
      fact.setLogger(handler, o);
      fact.setConfiguration(handler, o);
      String exception = o.getAttributeValue("exception");
      if (exception == null) {
        receiver.addHandler(handler);
      } else {
        Class<? extends Exception> exceptionClass;
        try {
          exceptionClass = (Class<? extends Exception>) Class.forName(exception);
        } catch (Exception e) {
          throw new ConfigurationException(exception, e);
        }
        receiver.addHandler(handler, exceptionClass);
      }
    }
  }
}

代码示例来源：origin: jpos/jPOS

protected void initService () throws Exception {
  Element e = getPersist ();
  QFactory factory = getServer().getFactory();
  ks = (SecureKeyStore) factory.newInstance (getImpl ());
  factory.setLogger  (ks, e);
  factory.setConfiguration (ks, e);
  NameRegistrar.register (getName (), ks);
}

代码示例来源：origin: jpos/jPOS-EE

private void registerTask (Element e) 
  throws ConfigurationException
{
  QFactory qf = getServer().getFactory();
  Object obj  = qf.newInstance (e.getChildTextTrim ("class"));
  if (!(obj instanceof MonitorTask)) {
    throw new ConfigurationException (
      obj.toString() + " is not an instance of MonitorTask"
    );
  }
  qf.setLogger (obj, e);
  qf.setConfiguration (obj, e);
  timer.schedule (
    new MonitorTimerTask (
      e.getAttributeValue("id"),
      (MonitorTask) obj), 
      getLong (e.getAttributeValue ("delay")),
      getLong (e.getAttributeValue ("period"))
  );
}
private long getLong (String l)

代码示例来源：origin: jpos/jPOS

public void startService () throws Exception {
  Element config = getPersist ();
  String provider = 
    config.getAttributeValue ("provider", "org.jpos.ui.UI");
  ui = (org.jpos.ui.UI) getFactory().newInstance (provider);
  ui.setConfig (config);
  ui.setLog (getLog ());
  ui.setObjectFactory (this);
  ui.configure ();
  NameRegistrar.register (getName(), ui);
}

代码示例来源：origin: jpos/jPOS

public void initChannel () throws ConfigurationException {
  Element persist = getPersist ();
  Element e = persist.getChild ("channel");
  if (e == null)
    throw new ConfigurationException ("channel element missing");
  channel = newChannel (e, getFactory());
  
  String socketFactoryString = getSocketFactory();
  if (socketFactoryString != null && channel instanceof FactoryChannel) {
    ISOClientSocketFactory sFac = (ISOClientSocketFactory) getFactory().newInstance(socketFactoryString);
    if (sFac != null && sFac instanceof LogSource) {
      ((LogSource) sFac).setLogger(log.getLogger(),getName() + ".socket-factory");
    }
    getFactory().setConfiguration (sFac, e);
    ((FactoryChannel)channel).setSocketFactory(sFac);
  }
}
private ISOChannel newChannel (Element e, QFactory f)

代码示例来源：origin: jpos/jPOS

protected ISOChannel initChannel () throws ConfigurationException {
  Element persist = getPersist ();
  Element e = persist.getChild ("channel");
  if (e == null)
    throw new ConfigurationException ("channel element missing");
  ISOChannel c = newChannel (e, getFactory());
  String socketFactoryString = getSocketFactory();
  if (socketFactoryString != null && c instanceof FactoryChannel) {
    ISOClientSocketFactory sFac = (ISOClientSocketFactory) getFactory().newInstance(socketFactoryString);
    if (sFac != null && sFac instanceof LogSource) {
      ((LogSource) sFac).setLogger(log.getLogger(),getName() + ".socket-factory");
    }
    getFactory().setConfiguration (sFac, e);
    ((FactoryChannel)c).setSocketFactory(sFac);
  }
  return c;
}
protected void initSpaceAndQueues () throws ConfigurationException {

代码示例来源：origin: jpos/jPOS

protected void initService () throws Exception {
  QFactory factory = getServer().getFactory();
  dirPoll  = createDirPoll();
  dirPoll.setPath (getPath ());
  dirPoll.setThreadPool (new ThreadPool (1, poolSize));
  dirPoll.setPollInterval (pollInterval);
  if (priorities != null)
    dirPoll.setPriorities (priorities);
  dirPoll.setLogger (getLog().getLogger(), getLog().getRealm ());
  Configuration cfg = factory.getConfiguration (getPersist());
  dirPoll.setConfiguration (cfg);
  dirPoll.createDirs ();
  Object dpp = factory.newInstance (getProcessor());
  if (dpp instanceof LogSource) {
    ((LogSource) dpp).setLogger (
      getLog().getLogger(), getLog().getRealm ()
    );
  }
  if (dpp instanceof Configurable) {
    ((Configurable) dpp).setConfiguration (cfg);
  }
  dirPoll.setProcessor (dpp);
}

内容来源于网络，如有侵权，请联系作者删除！

QFactory

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com