javax.jms.QueueSession.createTemporaryQueue()方法的使用及代码示例

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

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

QueueSession.createTemporaryQueue介绍

[英]Creates a TemporaryQueue object. Its lifetime will be that of the QueueConnection unless it is deleted earlier.
[中]创建临时队列对象。它的生存期将是队列连接的生存期,除非它被提前删除。

代码示例

代码示例来源:origin: apache/activemq

@Override
public TemporaryQueue createTemporaryQueue() throws JMSException {
  return next.createTemporaryQueue();
}

代码示例来源:origin: wildfly/wildfly

/** Constructor for the {@code QueueRequestor} class.
 *  
 * <P>This implementation assumes the session parameter to be non-transacted,
 * with a delivery mode of either {@code AUTO_ACKNOWLEDGE} or 
 * {@code DUPS_OK_ACKNOWLEDGE}.
 *
 * @param session the {@code QueueSession} the queue belongs to
 * @param queue the queue to perform the request/reply call on
 *  
 * @exception JMSException if the JMS provider fails to create the
 *                         {@code QueueRequestor} due to some internal
 *                         error.
 * @exception InvalidDestinationException if an invalid queue is specified.
 */ 
public
QueueRequestor(QueueSession session, Queue queue) throws JMSException {
  
  if (queue==null) throw new InvalidDestinationException("queue==null");
  
  this.session = session;
  tempQueue    = session.createTemporaryQueue();
  sender       = session.createSender(queue);
  receiver     = session.createReceiver(tempQueue);
}

代码示例来源:origin: apache/activemq

QueueSession replyToConsumerSession = ((QueueConnection)replyToConsumerConnection)
  .createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue replyToConsumerQueue = replyToConsumerSession.createTemporaryQueue();
replyToConsumerSession.close();
bridge.setConsumerQueue(replyToConsumerQueue);
QueueSession replyToConsumerSession = ((QueueConnection)replyToConsumerConnection)
  .createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue replyToConsumerQueue = replyToConsumerSession.createTemporaryQueue();
replyToConsumerSession.close();
bridge.setConsumerQueue(replyToConsumerQueue);

代码示例来源:origin: org.apache.geronimo.specs/geronimo-jms_1.1_spec

public QueueRequestor(QueueSession session, Queue queue)
  throws JMSException
{
  super();
  if(queue == null) {
    throw new InvalidDestinationException("Invalid queue");
  }
  
  setSession(session);
  setTemporaryQueue(session.createTemporaryQueue());
  setSender(session.createSender(queue));
  setReceiver(session.createReceiver(getTemporaryQueue()));
}

代码示例来源:origin: org.apache.axis/axis

protected Destination createTemporaryDestination()
  throws JMSException
{
  return ((QueueSession)m_session).createTemporaryQueue();
}

代码示例来源:origin: axis/axis

protected Destination createTemporaryDestination()
  throws JMSException
{
  return ((QueueSession)m_session).createTemporaryQueue();
}

代码示例来源:origin: org.apache.axis/com.springsource.org.apache.axis

protected Destination createTemporaryDestination()
  throws JMSException
{
  return ((QueueSession)m_session).createTemporaryQueue();
}

代码示例来源:origin: pierre/meteo

/**
 * @return
 * @throws JMSException
 */
public TemporaryQueue createTemporaryQueue() throws JMSException {
  return next.createTemporaryQueue();
}

代码示例来源:origin: org.apache.activemq/activemq-all

@Override
public TemporaryQueue createTemporaryQueue() throws JMSException {
  return next.createTemporaryQueue();
}

代码示例来源:origin: org.apache.activemq/activemq-client

@Override
public TemporaryQueue createTemporaryQueue() throws JMSException {
  return next.createTemporaryQueue();
}

代码示例来源:origin: org.apache.activemq/activemq-osgi

@Override
public TemporaryQueue createTemporaryQueue() throws JMSException {
  return next.createTemporaryQueue();
}

代码示例来源:origin: org.jboss.javaee/jboss-jms-api

public QueueRequestor(QueueSession session, Queue queue) throws JMSException
{
 queueSession = session;
 requestSender = queueSession.createSender(queue);
 replyQueue = queueSession.createTemporaryQueue();
 replyReceiver = queueSession.createReceiver(replyQueue);
}

代码示例来源:origin: org.objectweb.jonas/jonas-jms-manager

/**
 *
 */
public TemporaryQueue createTemporaryQueue() throws JMSException {
TraceJms.logger.log(BasicLevel.DEBUG, "");
return getMOMQueueSession().createTemporaryQueue();
}

代码示例来源:origin: org.jboss.javaee/jboss-jms-api-1.1_spec

public QueueRequestor(QueueSession session, Queue queue) throws JMSException
{
 queueSession = session;
 requestSender = queueSession.createSender(queue);
 replyQueue = queueSession.createTemporaryQueue();
 replyReceiver = queueSession.createReceiver(replyQueue);
}

代码示例来源:origin: org.jboss.javaee/jboss-javaee

public QueueRequestor(QueueSession session, Queue queue) throws JMSException
{
 queueSession = session;
 requestSender = queueSession.createSender(queue);
 replyQueue = queueSession.createTemporaryQueue();
 replyReceiver = queueSession.createReceiver(replyQueue);
}

代码示例来源:origin: org.apache.activemq/activemq-all

public QueueRequestor(QueueSession session, Queue queue)
  throws JMSException
{
  super();
  if(queue == null) {
    throw new InvalidDestinationException("Invalid queue");
  }
  
  setSession(session);
  setTemporaryQueue(session.createTemporaryQueue());
  setSender(session.createSender(queue));
  setReceiver(session.createReceiver(getTemporaryQueue()));
}

代码示例来源:origin: apache/activemq-artemis

public QueueRequestor(QueueSession session, Queue queue)
  throws JMSException
{
  super();
  if(queue == null) {
    throw new InvalidDestinationException("Invalid queue");
  }
  
  setSession(session);
  setTemporaryQueue(session.createTemporaryQueue());
  setSender(session.createSender(queue));
  setReceiver(session.createReceiver(getTemporaryQueue()));
}

代码示例来源:origin: org.apache.openejb/javaee-api

public QueueRequestor(QueueSession session, Queue queue)
  throws JMSException
{
  super();
  if(queue == null) {
    throw new InvalidDestinationException("Invalid queue");
  }
  
  setSession(session);
  setTemporaryQueue(session.createTemporaryQueue());
  setSender(session.createSender(queue));
  setReceiver(session.createReceiver(getTemporaryQueue()));
}

代码示例来源:origin: org.apache.activemq/artemis-jms-client-all

public QueueRequestor(QueueSession session, Queue queue)
  throws JMSException
{
  super();
  if(queue == null) {
    throw new InvalidDestinationException("Invalid queue");
  }
  
  setSession(session);
  setTemporaryQueue(session.createTemporaryQueue());
  setSender(session.createSender(queue));
  setReceiver(session.createReceiver(getTemporaryQueue()));
}

代码示例来源:origin: org.apache.openjpa/openjpa-all

public QueueRequestor(QueueSession session, Queue queue)
  throws JMSException
{
  super();
  if(queue == null) {
    throw new InvalidDestinationException("Invalid queue");
  }
  
  setSession(session);
  setTemporaryQueue(session.createTemporaryQueue());
  setSender(session.createSender(queue));
  setReceiver(session.createReceiver(getTemporaryQueue()));
}

相关文章