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

Queue.push介绍

[英]Pushes an item at the end of this queue.
[中]推送此队列末尾的项目。

代码示例

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

public void send(Object obj) {
 queue.push(obj);
}

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

public void pushReply(AbstractJmsReply reply) {
 queue.push(reply);
}

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

public void send(Object obj) {
 queue.push(obj);
}

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

public void pushReply(AbstractJmsReply reply) {
 queue.push(reply);
}

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

public void pushError(MomException exc) {
 queue.push(new MomExceptionReply(exc));
}

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

public void pushError(MomException exc) {
 queue.push(new MomExceptionReply(exc));
}

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

public void pushMessages(ConsumerMessages cm) throws JMSException {
 if (logger.isLoggable(BasicLevel.DEBUG))
  logger.log(BasicLevel.DEBUG, "MultiSessionConsumer.pushMessages(" + cm + ')');
 repliesIn.push(cm);
}

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

public void push(Message msg) {
   if (logger.isLoggable(BasicLevel.DEBUG))
  logger.log(BasicLevel.DEBUG, "DistributionDaemon.push(" + msg.id + ')');
   distributeQueue.push(msg);
}

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

/**
 * Called by ConnectionConsumer in order to distribute a message through the 
 * method run(). Session mode is APP_SERVER.
 */
void onMessage(org.objectweb.joram.shared.messages.Message msg) {
 if (logger.isLoggable(BasicLevel.DEBUG))
  logger.log(BasicLevel.DEBUG, "Session.onMessage(" + msg + ')');
 repliesIn.push(msg);
}

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

/**
 * Called by MessageConsumerListener (demultiplexer thread
 * from RequestMultiplexer) in order to distribute messages 
 * to a message consumer.
 * Not synchronized because a concurrent close
 * can be done.
 *
 * @exception 
 */
void pushMessages(SingleSessionConsumer consumerListener, ConsumerMessages messages) {
 if (logger.isLoggable(BasicLevel.DEBUG))
  logger.log(BasicLevel.DEBUG, "Session.pushMessages(" + consumerListener + ',' + messages + ')');
 repliesIn.push(new MessageListenerContext(consumerListener, messages));
}

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

synchronized void ackMessage(String id) {
 if (logger.isLoggable(BasicLevel.DEBUG))
  logger.log(BasicLevel.DEBUG, "DistributionDaemon run: distributeQueue.pop = " + id);
 
 // delete the message from the distributeQueue
 distributeQueue.pop();
 // add message id to the ackQueue
 ackQueue.push(id);
 
 if (logger.isLoggable(BasicLevel.DEBUG))
  logger.log(BasicLevel.DEBUG, "DistributionDaemon run: ackQueue.push : " + id);    
}

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

/**
 * Push a new message in temporary queue until the end of current reaction.
 * As this method is only  called by engine's thread it does not need to be
 * synchronized.
 */
final void push(AgentId from,
        AgentId to,
        Notification not) {
 if (logmon.isLoggable(BasicLevel.DEBUG))
  logmon.log(BasicLevel.DEBUG,
        getName() + ", push(" + from + ", " + to + ", " + not + ")");
 if ((to == null) || to.isNullId())
  return;
 mq.push(Message.alloc(from, to, not));
}

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

/**
 * Push a new message in temporary queue until the end of current reaction.
 * As this method is only  called by engine's thread it does not need to be
 * synchronized.
 */
public final void push(AgentId from,
        AgentId to,
        Notification not) {
 if (logmon.isLoggable(BasicLevel.DEBUG))
  logmon.log(BasicLevel.DEBUG,
        getName() + ", push(" + from + ", " + to + ", " + not + ")");
 if ((to == null) || to.isNullId())
  return;
 
 if (not.persistent) {
  persistentPush = true;
 }
 mq.push(Message.alloc(from, to, not));
}