本文整理了Java中jadex.commons.Tuple2.getSecondEntity()
方法的一些代码示例,展示了Tuple2.getSecondEntity()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Tuple2.getSecondEntity()
方法的具体详情如下:
包路径:jadex.commons.Tuple2
类名称: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
}
});
内容来源于网络,如有侵权,请联系作者删除!