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
TopicRequestor.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
TopicRequestor
{ private
TopicSession
session
; private
Topic
topic
; private
TemporaryTopic
temporaryTopic
; private
TopicPublisher
publisher
; private
TopicSubscriber
subscriber
; public
TopicRequestor
(
TopicSession
session
,
Topic
topic
) throws
JMSException
{ super();
setSession
(
session
);
setTopic
(
topic
);
setTemporaryTopic
(
session
.
createTemporaryTopic
());
setPublisher
(
session
.
createPublisher
(
topic
));
setSubscriber
(
session
.
createSubscriber
(
getTemporaryTopic
())); } public
Message
request
(
Message
message
) throws
JMSException
{
message
.
setJMSReplyTo
(
getTemporaryTopic
());
getPublisher
().
publish
(
message
); return (
getSubscriber
().
receive
()); } public void
close
() throws
JMSException
{
getSession
().
close
();
getTemporaryTopic
().
delete
(); } private void
setPublisher
(
TopicPublisher
publisher
) { this.
publisher
=
publisher
; } private
TopicPublisher
getPublisher
() { return
publisher
; } private void
setSession
(
TopicSession
session
) { this.
session
=
session
; } private
TopicSession
getSession
() { return
session
; } private void
setSubscriber
(
TopicSubscriber
subscriber
) { this.
subscriber
=
subscriber
; } private
TopicSubscriber
getSubscriber
() { return
subscriber
; } private void
setTemporaryTopic
(
TemporaryTopic
temporaryTopic
) { this.
temporaryTopic
=
temporaryTopic
; } private
TemporaryTopic
getTemporaryTopic
() { return
temporaryTopic
; } private void
setTopic
(
Topic
topic
) { this.
topic
=
topic
; } private
Topic
getTopic
() { return
topic
; } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口