geronimo-jms_1.1_spec-1.1.1.jar
登录
|
org.apache.geronimo.specs:geronimo-jms_1.1_spec:1.1.1
META-INF
javax
jms
InvalidSelectorException.java
JMSException.java
Message.java
MessageEOFException.java
Destination.java
TemporaryTopic.java
QueueSession.java
IllegalStateException.java
ConnectionFactory.java
ObjectMessage.java
XATopicSession.java
ConnectionMetaData.java
XAConnectionFactory.java
Connection.java
Session.java
Queue.java
MessageProducer.java
ServerSessionPool.java
ResourceAllocationException.java
TemporaryQueue.java
TopicConnectionFactory.java
QueueConnectionFactory.java
QueueBrowser.java
TopicSubscriber.java
XAQueueSession.java
StreamMessage.java
QueueConnection.java
MessageNotReadableException.java
MessageConsumer.java
MessageFormatException.java
ExceptionListener.java
DeliveryMode.java
XATopicConnection.java
MessageListener.java
Topic.java
TopicConnection.java
JMSSecurityException.java
MapMessage.java
XAConnection.java
QueueReceiver.java
XAQueueConnectionFactory.java
TextMessage.java
InvalidClientIDException.java
TransactionInProgressException.java
TopicRequestor.java
QueueRequestor.java
TransactionRolledBackException.java
QueueSender.java
XAQueueConnection.java
TopicSession.java
MessageNotWriteableException.java
TopicPublisher.java
BytesMessage.java
InvalidDestinationException.java
ConnectionConsumer.java
XATopicConnectionFactory.java
ServerSession.java
XASession.java
QueueRequestor.java
清空
类结构
/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ // // This source code implements specifications defined by the Java // Community Process. In order to remain compliant with the specification // DO NOT add / change / or delete method signatures! // package javax.jms; /** * @version $Rev: 467553 $ $Date: 2006-10-25 06:01:51 +0200 (Wed, 25 Oct 2006) $ */ public class
QueueRequestor
{ private
QueueSession
session
; private
TemporaryQueue
temporaryQueue
; private
QueueSender
sender
; private
QueueReceiver
receiver
; 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
())); } public
Message
request
(
Message
message
) throws
JMSException
{
message
.
setJMSReplyTo
(
getTemporaryQueue
());
getSender
().
send
(
message
); return
getReceiver
().
receive
(); } public void
close
() throws
JMSException
{
getSession
().
close
();
getTemporaryQueue
().
delete
(); } private void
setReceiver
(
QueueReceiver
receiver
) { this.
receiver
=
receiver
; } private
QueueReceiver
getReceiver
() { return
receiver
; } private void
setSender
(
QueueSender
sender
) { this.
sender
=
sender
; } private
QueueSender
getSender
() { return
sender
; } private void
setSession
(
QueueSession
session
) { this.
session
=
session
; } private
QueueSession
getSession
() { return
session
; } private void
setTemporaryQueue
(
TemporaryQueue
temporaryQueue
) { this.
temporaryQueue
=
temporaryQueue
; } private
TemporaryQueue
getTemporaryQueue
() { return
temporaryQueue
; } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口