jadex.commons.Tuple2.getSecondEntity()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(8.4k)|赞(0)|评价(0)|浏览(91)

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

Tuple2.getSecondEntity介绍

[英]Get the second entity.
[中]获取第二个实体。

代码示例

代码示例来源:origin: org.activecomponents.jadex/jadex-applications-bdiv3

public int compare(Tuple2<IBuyBookService, Integer> o1, Tuple2<IBuyBookService, Integer> o2)
  {
    return o1.getSecondEntity().compareTo(o2.getSecondEntity());
  }
});

代码示例来源:origin: org.activecomponents.jadex/jadex-applications-bdi

public int compare(Tuple2<IBuyBookService, Integer> o1, Tuple2<IBuyBookService, Integer> o2)
  {
    return o1.getSecondEntity().compareTo(o2.getSecondEntity());
  }
});

代码示例来源:origin: org.activecomponents.jadex/jadex-applications-micro

public IFuture<Void> execute(IInternalAccess ia)
  {
    for(Iterator<IComponentIdentifier> it=conversations.keySet().iterator(); it.hasNext(); )
    {
      Tuple2<ElizaParse, Long>    tup    = conversations.get(it.next());
      if(tup.getSecondEntity().longValue()+30000<System.currentTimeMillis())
      {
        it.remove();
      }
    }
    
    return IFuture.DONE;
  }
});

代码示例来源:origin: net.sourceforge.jadex/jadex-kernel-base

/**
 *  Gets result for a cached object based on model name.
 *  
 *  @param model The model.
 *  @param map The cache.
 *  @return A cache hit or null.
 */
protected Object getCacheResultForModel(String model, Map map)
{
  Tuple2<Object, Object> ret = getCacheKeyValueForModel(model, map);
  return ret != null? ret.getSecondEntity() : null;
}

代码示例来源:origin: net.sourceforge.jadex/jadex-bridge

/**
   *  Convert arguments to argument map.
   */
  public static Map<String, Object> convertArguments(Collection<Tuple2<String, Object>> results)
  {
    Map<String, Object> ret = new HashMap<String, Object>();

    for(Iterator<Tuple2<String, Object>> it=results.iterator(); it.hasNext(); )
    {
      Tuple2<String, Object> tup = it.next();
      ret.put(tup.getFirstEntity(), tup.getSecondEntity());
    }
    
    return ret;
  }
}

代码示例来源:origin: org.activecomponents.jadex/jadex-bridge

/**
   *  Convert arguments to argument map.
   */
  public static Map<String, Object> convertArguments(Collection<Tuple2<String, Object>> results)
  {
    Map<String, Object> ret = new HashMap<String, Object>();

    for(Iterator<Tuple2<String, Object>> it=results.iterator(); it.hasNext(); )
    {
      Tuple2<String, Object> tup = it.next();
      ret.put(tup.getFirstEntity(), tup.getSecondEntity());
    }
    
    return ret;
  }
}

代码示例来源:origin: org.activecomponents.jadex/jadex-bridge

/**
 *  Test if the current thread is the rescue thread of the platform.
 *  @param cid The id of a component of the platform.
 *  @return True, if is the rescue thread.
 */
public static synchronized boolean isRescueThread(IComponentIdentifier cid)
{
  boolean ret = false;
  Tuple2<BlockingQueue, Thread> tup = rescuethreads==null? null: rescuethreads.get(cid.getRoot());
  if(tup!=null)
  {
    ret = Thread.currentThread().equals(tup.getSecondEntity());
  }
  return ret;
}

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

/**
   *  Decode data with the codec.
   *  @param val The string value.
   *  @return The encoded object.
   */
  public Object decode(byte[] val, ClassLoader classloader, Map<Class<?>, Object[]> info)
  {
    Object[] infos = info==null? null: info.get(getClass());
    Tuple2<TypeInfoPathManager, IObjectReaderHandler>  tup = (Tuple2<TypeInfoPathManager, IObjectReaderHandler>)(infos!=null? infos[0]: null);
    Object ret = JavaReader.objectFromByteArray(val, classloader, tup==null? null: tup.getFirstEntity(), tup==null? null: tup.getSecondEntity());
    if(DEBUG)
      System.out.println("decode content: "+ret);
    return ret;
  }
}

代码示例来源:origin: org.activecomponents.jadex/jadex-commons

/**
   *  Clone this tuple.
   *  @return A shallow copy of this tuple.
   */
  public Object	clone()
  {
    return new Tuple2<T, E>(getFirstEntity(), getSecondEntity());
  }
}

代码示例来源:origin: org.activecomponents.jadex/jadex-applications-micro

/**
 * 
 */
public void addData(Collection<Tuple2<ICryptoService, Double>> res)
{
  for(Tuple2<ICryptoService, Double> tup: res)
  {
    ICryptoService ser = tup.getFirstEntity();
    Double val = tup.getSecondEntity();
    addValue(((IService)ser).getServiceIdentifier().toString(), System.currentTimeMillis(), val);
  }
}

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

public void customResultAvailable(Tuple2<IResourceIdentifier, Map<IResourceIdentifier, List<IResourceIdentifier>>> deps)
{
  createClassLoader(rid, deps.getSecondEntity(), support, workspace).addResultListener(new DelegationResultListener<DelegationURLClassLoader>(ret)
  {
    public void customResultAvailable(DelegationURLClassLoader result)
    {
      clfuts.remove(rid);
      super.customResultAvailable(result);
    }
    
    public void exceptionOccurred(Exception exception)
    {
      clfuts.remove(rid);
      super.exceptionOccurred(exception);
    }
  });
}

代码示例来源:origin: org.activecomponents.jadex/jadex-rules-eca

public void customResultAvailable(Tuple2<Boolean, Object> result)
  {
    if(invert)
    {
      Boolean b = result.getFirstEntity().booleanValue()? Boolean.FALSE: Boolean.TRUE;
      result = new Tuple2<Boolean, Object>(b, result.getSecondEntity());
    }
    
    super.customResultAvailable(result);
  }
});

代码示例来源:origin: org.activecomponents.jadex/jadex-platform-extension-webservice-desktop-jetty

/**
   *  Unpublish a service.
   *  @param sid The service identifier.
   */
  public IFuture<Void> unpublishService(IServiceIdentifier sid)
  {
    Tuple2<Server,ContextHandler> unpublish = unpublishinfos.remove(sid);
    if (unpublish != null)
      ((ContextHandlerCollection)unpublish.getFirstEntity().getHandler()).removeHandler(unpublish.getSecondEntity());
//        throw new UnsupportedOperationException();
    return IFuture.DONE;
  }

代码示例来源:origin: org.activecomponents.jadex/jadex-runtimetools-swing

public void customResultAvailable(Collection<Tuple2<String, IResourceIdentifier>> result)
  {
    for(Tuple2<String, IResourceIdentifier> tup: result)
    {
      addTest(tup.getFirstEntity(), tup.getSecondEntity());
    }
    ret.setResult(null);
  }
});

代码示例来源:origin: net.sourceforge.jadex/jadex-runtimetools-swing

public void customResultAvailable(Collection<Tuple2<String, IResourceIdentifier>> result)
  {
    for(Tuple2<String, IResourceIdentifier> tup: result)
    {
      addTest(tup.getFirstEntity(), tup.getSecondEntity());
    }
    ret.setResult(null);
  }
});

代码示例来源:origin: net.sourceforge.jadex/jadex-tools-base-swing

public void customResultAvailable(Tuple2<URL, IResourceIdentifier> tup) 
        {
          // Todo: remove entries on remove.
//					System.out.println("adding root: "+tup.getFirstEntity()+" "+tup.getSecondEntity());
          addRootEntry(SUtil.toURI0(tup.getFirstEntity()), filepath, tup.getSecondEntity());
          ModelTreePanel.super.addNode(node);
        }

代码示例来源:origin: org.activecomponents.jadex/jadex-platform

public void customResultAvailable(Tuple2<IResourceIdentifier, Map<IResourceIdentifier, List<IResourceIdentifier>>> deps)
{
  createClassLoader(deps.getFirstEntity(), deps.getSecondEntity(), support, workspace).addResultListener(new DelegationResultListener<DelegationURLClassLoader>(ret)
  {
    public void customResultAvailable(DelegationURLClassLoader result)
    {
      clfuts.remove(rid);
      super.customResultAvailable(result);
    }
    
    public void exceptionOccurred(Exception exception)
    {
      clfuts.remove(rid);
      super.exceptionOccurred(exception);
    }
  });
}

代码示例来源:origin: net.sourceforge.jadex/jadex-kernel-bdiv3

public void customResultAvailable(Void result)
  {
    injectParent(capa, caps[i].getSecondEntity())
      .addResultListener(new DelegationResultListener<Void>(ret)
    {
      public void customResultAvailable(Void result)
      {
        initCapabilities(agent, caps, i+1)
          .addResultListener(new DelegationResultListener<Void>(ret));
      }
    });
  }
});

代码示例来源:origin: net.sourceforge.jadex/jadex-runtimetools-swing

public void customResultAvailable(Object result)
  {
    IComponentManagementService    cms    = (IComponentManagementService)result;
    Map    args    = new HashMap();
    args.put("timeout", timeout);
    // Todo: Use remote component for parent if any
    CreationInfo ci = new CreationInfo(args, plugin.getJCC().getPlatformAccess().getComponentIdentifier());
    ci.setResourceIdentifier(name.getSecondEntity());
    cms.createComponent(null, name.getFirstEntity(), ci, res)
      .addResultListener(new SwingDelegationResultListener(ret));
    
    // Todo: timeout -> force destroy of component
  }
});

代码示例来源:origin: org.activecomponents.jadex/jadex-runtimetools-swing

public void customResultAvailable(Object result)
  {
    IComponentManagementService    cms    = (IComponentManagementService)result;
    Map    args    = new HashMap();
    args.put("timeout", timeout);
    // Todo: Use remote component for parent if any
    CreationInfo ci = new CreationInfo(args, plugin.getJCC().getPlatformAccess().getComponentIdentifier());
    ci.setResourceIdentifier(name.getSecondEntity());
    cms.createComponent(null, name.getFirstEntity(), ci, res)
      .addResultListener(new SwingDelegationResultListener(ret));
    
    // Todo: timeout -> force destroy of component
  }
});

相关文章

微信公众号

最新文章

更多