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