@Test public void testProcess() { System.out.println("process"); FifoPopPreProcessor instance = new FifoPopPreProcessor(); instance.setTimeout("1"); instance.process(); }
public void process() { String value = null; try { Object valueObj = FifoMap.getInstance().pop(getQueueName(), getTimeoutAsLong()); if (valueObj != null) { value = valueObj.toString(); } } catch (InterruptedException ex) { log.warn("Interrupted pop from queue " + getQueueName()); value = "INTERRUPTED"; } final JMeterVariables vars = JMeterContextService.getContext().getVariables(); if (vars != null) { vars.put(getVarName(), value); } }
FifoPopPreProcessor extends AbstractTestElement implements PreProcessor, TestStateListener { public void process() { String value = null; try { Object valueObj = FifoMap.getInstance().pop(getQueueName(), getTimeoutAsLong()); if (valueObj != null) { value = valueObj.toString(); } } catch (InterruptedException ex) { log.warn("Interrupted pop from queue " + getQueueName()); value = "INTERRUPTED"; } final JMeterVariables vars = JMeterContextService.getContext().getVariables(); if (vars != null) { vars.put(getVarName(), value); } } }
FifoPopPreProcessor extends AbstractTestElement implements PreProcessor, TestStateListener { public void process() { String value = null; try { Object valueObj = FifoMap.getInstance().pop(getQueueName(), getTimeoutAsLong()); if (valueObj != null) { value = valueObj.toString(); } } catch (InterruptedException ex) { log.warn("Interrupted pop from queue " + getQueueName()); value = "INTERRUPTED"; } final JMeterVariables vars = JMeterContextService.getContext().getVariables(); if (vars != null) { vars.put(getVarName(), value); } } FifoPopPreProcessor(); }
FifoPopPreProcessor extends AbstractTestElement implements PreProcessor, TestStateListener { public void process() { String value = null; try { Object valueObj = FifoMap.getInstance().pop(getQueueName(), getTimeoutAsLong()); if (valueObj != null) { value = valueObj.toString(); } } catch (InterruptedException ex) { log.warn("Interrupted pop from queue " + getQueueName()); value = "INTERRUPTED"; } final JMeterVariables vars = JMeterContextService.getContext().getVariables(); if (vars != null) { vars.put(getVarName(), value); } } FifoPopPreProcessor(); void testStarted(); void testStarted(String host); void testEnded(); void testEnded(String host); void process(); String getVarName(); String getTimeout(); String getQueueName(); final void setTimeout(String atimeout); void setVarName(String text); void setQueueName(String text); }
FifoPopPreProcessor extends AbstractTestElement implements PreProcessor, TestStateListener { public void process() { String value = null; try { Object valueObj = FifoMap.getInstance().pop(getQueueName(), getTimeoutAsLong()); if (valueObj != null) { value = valueObj.toString(); } } catch (InterruptedException ex) { log.warn("Interrupted pop from queue " + getQueueName()); value = "INTERRUPTED"; } final JMeterVariables vars = JMeterContextService.getContext().getVariables(); if (vars != null) { vars.put(getVarName(), value); } } FifoPopPreProcessor(); void testStarted(); void testStarted(String host); void testEnded(); void testEnded(String host); void process(); String getVarName(); String getTimeout(); String getQueueName(); final void setTimeout(String atimeout); void setVarName(String text); void setQueueName(String text); static final String queueName; static final String variableName; static final String TIMEOUT; }