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

Queue.<init>介绍

[英]Constructs a Queue instance.
[中]构造一个Queue实例。

代码示例

代码示例来源：origin: org.ow2.joram/joram-mom-core

public void initialize(int key, OpenConnectionNot not) {
 this.key = key;
 queue = new Queue();
 closed = false;
}

代码示例来源：origin: org.objectweb.joram/joram-mom-core

StandardConnectionContext(int key) {
 this.key = key;
 queue = new Queue();
 closed = false;
}

代码示例来源：origin: org.ow2.joram/joram-mom-core

public DistributionDaemon(DistributionHandler distributionHandler, String destinationId, String destinationName, Destination dest) {
  super("DistributionDaemon_" + destinationName, logger);
  this.distributionHandler = distributionHandler;
 this.acklistTxName = destinationId + "AL";
  distributeQueue = new Queue();
  ackQueue = new Queue();
  this.dest = dest;
  if (logger.isLoggable(BasicLevel.DEBUG))
  logger.log(BasicLevel.DEBUG, "DistributionDaemon<> distributionHandler = " + distributionHandler + ", txDest = " + dest);
}

代码示例来源：origin: org.ow2.joram/a3-rt

/**
 * Initializes a new <code>Engine</code> object (can only be used by
 * subclasses).
 */
protected Engine() throws Exception {
 name = "Engine#" + AgentServer.getServerId();
 // Get the logging monitor from current server MonologLoggerFactory
 logmon = Debug.getLogger(Debug.A3Engine + ".#" + AgentServer.getServerId());
 if (logmon.isLoggable(BasicLevel.DEBUG))
  logmon.log(BasicLevel.DEBUG, getName() + " created [" + getClass().getName() + "].");
 NbMaxAgents = AgentServer.getInteger("NbMaxAgents", NbMaxAgents).intValue();
 qin = new MessageVector(name, AgentServer.getTransaction().isPersistent());
 mq = new Queue();
 agentProfiling = AgentServer.getBoolean("AgentProfiling");
 
 String noTxIfTransientValue = AgentServer.getProperty("NoTxIfTransient");
 if (noTxIfTransientValue != null) {
  noTxIfTransient = Boolean.parseBoolean(noTxIfTransientValue);
 } else {
  // Default value
  noTxIfTransient = true;
 }
 
 isRunning = false;
 canStop = false;
 thread = null;
 needToBeCommited = false;
 restore();
 if (modified) save();
}

代码示例来源：origin: org.objectweb.joram/a3-rt

/**
 * Initializes a new <code>Engine</code> object (can only be used by
 * subclasses).
 */
protected Engine() throws Exception {
 name = "Engine#" + AgentServer.getServerId();
 // Get the logging monitor from current server MonologLoggerFactory
 logmon = Debug.getLogger(Debug.A3Engine + ".#" + AgentServer.getServerId());
 if (logmon.isLoggable(BasicLevel.DEBUG))
  logmon.log(BasicLevel.DEBUG, getName() + " created [" + getClass().getName() + "].");
 NbMaxAgents = AgentServer.getInteger("NbMaxAgents", NbMaxAgents).intValue();
 qin = new MessageVector(name, AgentServer.getTransaction().isPersistent());
 mq = new Queue();
 agentProfiling = AgentServer.getBoolean("AgentProfiling");
 
 isRunning = false;
 canStop = false;
 thread = null;
 needToBeCommited = false;
 restore();
 if (modified) save();
}

代码示例来源：origin: org.ow2.joram/joram-client-jms

msgDispatcher = new MessageDispatcher(
  "MessageDispatcher[" + reqMultiplexer.getDemultiplexerDaemonName() + ']');
repliesIn = new Queue();
msgDispatcher.setDaemon(true);
msgDispatcher.start();

代码示例来源：origin: org.ow2.joram/joram-client-jms

producers = new Vector();
browsers = new Vector();
repliesIn = new fr.dyade.aaa.common.Queue();
sendings = new Hashtable();
deliveries = new Hashtable();