Requestor (Student Root 4.1.0-SNAPSHOT API)

java.lang.Object
- ejava.examples.jmsscheduler.Requestor

All Implemented Interfaces:

Runnable, MessageListener
```
public class Requestor
extends Object
implements Runnable, MessageListener
```
This is used to simulate work being tasked to a scheduling queue. Each request will be tracked for a result.

Author:

jcstaff

Field Summary

Fields
Modifier and Type	Field and Description
`protected ConnectionFactory`	`connFactory`
`protected int`	`count`
`private static org.apache.commons.logging.Log`	`log`
`protected int`	`maxCount`
`protected String`	`name`
`protected String`	`password`
`protected Destination`	`requestQueue`
`protected Map<String,Message>`	`requests`
`protected int`	`responseCount`
`protected long`	`sleepTime`
`protected boolean`	`started`
`protected long`	`startTime`
`protected boolean`	`stop`
`protected boolean`	`stopped`
`protected String`	`username`

Constructor Summary

Constructors
Constructor and Description

Requestor(String name)

Constructors
Constructor and Description
`Requestor(String name)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`clearMessages()`
`protected Connection`	`createConnection(ConnectionFactory connFactory)`
`void`	`execute()`
`int`	`getCount()`
`protected Destination`	`getReplyTo(Session session)`
`boolean`	`isStarted()`
`boolean`	`isStopped()`
`static void`	`main(String[] args)`
`void`	`onMessage(Message message)` This method is used to asynchronously receive the responses to requests sent by the main loop.
`void`	`run()`
`void`	`setConnFactory(ConnectionFactory connFactory)`
`void`	`setMaxCount(int maxCount)`
`void`	`setPassword(String password)`
`void`	`setRequestQueue(Destination requestQueue)`
`void`	`setSleepTime(long sleepTime)`
`void`	`setUsername(String username)`
`void`	`stop()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

private static final org.apache.commons.logging.Log log

connFactory

protected ConnectionFactory connFactory

requestQueue
```
protected Destination requestQueue
```

stop
```
protected boolean stop
```

stopped
```
protected boolean stopped
```

started
```
protected boolean started
```

count
```
protected int count
```

name
```
protected String name
```

sleepTime
```
protected long sleepTime
```

maxCount
```
protected int maxCount
```

requests
```
protected Map<String,Message> requests
```

responseCount
```
protected int responseCount
```

startTime
```
protected long startTime
```

username
```
protected String username
```

password
```
protected String password
```

Constructor Detail
- Requestor
```
public Requestor(String name)
```

Method Detail

setConnFactory

public void setConnFactory(ConnectionFactory connFactory)

setRequestQueue

public void setRequestQueue(Destination requestQueue)

getCount
```
public int getCount()
```

setSleepTime

public void setSleepTime(long sleepTime)

setMaxCount

public void setMaxCount(int maxCount)

clearMessages
```
public void clearMessages()
```

stop
```
public void stop()
```

isStopped
```
public boolean isStopped()
```

isStarted
```
public boolean isStarted()
```

createConnection

protected Connection createConnection(ConnectionFactory connFactory)
                               throws Exception

Throws:: Exception

getReplyTo

protected Destination getReplyTo(Session session)
                          throws Exception

Throws:: Exception

setUsername

public void setUsername(String username)

setPassword

public void setPassword(String password)

execute

public void execute()
             throws Exception

Throws:: Exception

run
```
public void run()
```
Specified by:

run in interface Runnable

onMessage
```
public void onMessage(Message message)
```
This method is used to asynchronously receive the responses to requests sent by the main loop.

Specified by:

onMessage in interface MessageListener

main

public static void main(String[] args)

Class Requestor

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

log

connFactory

requestQueue

stop

stopped

started

count

name

sleepTime

maxCount

requests

responseCount

startTime

username

password

Constructor Detail

Requestor

Method Detail

setConnFactory

setRequestQueue

getCount

setSleepTime

setMaxCount

clearMessages

stop

isStopped

isStarted

createConnection

getReplyTo

setUsername

setPassword

execute

run

onMessage

main