[patch] Proposed fix

FixedQueueExecutor.java (text/plain), 2.68 KB, created by Paul Woolley on 2007-12-27 06:43:51 UTC

(hide)

Description: Proposed fix

Filename:

MIME Type:

Creator: Paul Woolley

Created: 2007-12-27 06:43:51 UTC

Size: 2.68 KB

patch

obsolete

>/* > * 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. > * > */ > >package org.apache.jmeter.protocol.jms.sampler; > >import javax.jms.JMSException; >import javax.jms.Message; >import javax.jms.QueueSender; > >import org.apache.jorphan.logging.LoggingManager; >import org.apache.log.Logger; > >/** > * Request/reply executor with a fixed reply queue. <br> > * Created on: October 28, 2004 > * > * @author Martijn Blankestijn > * @version $Id: FixedQueueExecutor.java,v 1.3 2005/05/19 15:36:53 mblankestijn > * Exp $ > */ >public class FixedQueueExecutor implements QueueExecutor { > /** Sender. */ > private QueueSender producer; > > /** Timeout used for waiting on message. */ > private int timeout; > > static Logger log = LoggingManager.getLoggerForClass(); > > /** > * Constructor. > * > * @param producer > * the queue to send the message on > * @param timeout > * timeout to use for the return message > */ > public FixedQueueExecutor(QueueSender producer, int timeout) { > this.producer = producer; > this.timeout = timeout; > } > > /* > * (non-Javadoc) > * > * @see org.apache.jmeter.protocol.jms.sampler.QueueExecutor#sendAndReceive(javax.jms.Message) > */ > public Message sendAndReceive(Message request) throws JMSException { > String id = request.getJMSCorrelationID(); > if(id == null){ > log.error("correlation id is null. set the JMSCorrelationID header"); > return null; > } > producer.send(request); > MessageAdmin.getAdmin().putRequest(id, request); > try { > if (log.isDebugEnabled()) { > log.debug("wait for reply " + id + " started on " + System.currentTimeMillis()); > } > synchronized (request) { > request.wait(timeout); > } > if (log.isDebugEnabled()) { > log.debug("done waiting for " + id + " ended on " + System.currentTimeMillis()); > } > > } catch (InterruptedException e) { > log.warn("Interrupt exception caught", e); > } > return MessageAdmin.getAdmin().get(id); > } >} View Attachment As Diff View Attachment As Raw

This is ASF Bugzilla: the Apache Software Foundation bug system. In case of problems with the functioning of ASF Bugzilla, please contact bugzilla-admin@apache.org. Please Note: this e-mail address is only for reporting problems with ASF Bugzilla. Mail about any other subject will be silently ignored.

• • Home
  • | New
  • | Browse
  • | Search
  • |
    [?]
  • | Reports
  • | Help
  • | New Account
  • | Log In
    Remember [x]
  • | Forgot Password
    Login: [x]