199200201202203204205206207208209
delegate.setMessageListener(listener); } finally { tccc.restore(); } } public void run() {
227228229230231232233234235236237
ProducerDelegate producerDelegate = delegate.createProducerDelegate((JBossDestination)d); return new JBossMessageProducer(producerDelegate); } finally { tccc.restore(); } } public MessageConsumer createConsumer(Destination d) throws JMSException {
268269270271272273274275276277278
return new JBossMessageConsumer(cd); } finally { tccc.restore(); } } public Queue createQueue(String queueName) throws JMSException {
321322323324325326327328329330331
return new JBossMessageConsumer(cd); } finally { tccc.restore(); } } public TopicSubscriber createDurableSubscriber(Topic topic, String name,
393394395396397398399400401402403
return new JBossQueueBrowser(queue, messageSelector, del); } finally { tccc.restore(); } } public TemporaryQueue createTemporaryQueue() throws JMSException {
129130131132133134135136137138139
cons = sess.createConsumerDelegate(dest, messageSelector, false, subName, true); } finally { tccc.restore(); } ConsumerState state = (ConsumerState)((DelegateSupport)cons).getState(); this.consumerID = state.getConsumerID();
7677787980818283848586
tccc.set(getClass().getClassLoader()); delegate.reset(); } finally { tccc.restore(); } return new BrowserEnumeration(); }
170171172173174175176177178179180
delegate.send((JBossDestination)destination, m, deliveryMode, priority, timeToLive); } finally { tccc.restore(); } } // TopicPublisher Implementation ---------------------------------
213214215216217218219220221222223
return new JBossConnection(res.getDelegate(), type); } finally { tccc.restore(); } } // Private --------------------------------------------------------------------------------------
102103104105106107108109110111112
return delegate.getClientID(); } finally { tccc.restore(); } } public void setClientID(String clientID) throws JMSException {