Worker (Student Root 4.1.0-SNAPSHOT API)

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

All Implemented Interfaces:

Runnable
```
public class Worker
extends Object
implements Runnable
```
This class simulates the job of a worker. It will attempt to take a message off the queue, work on it, and issue a reply. The length of time taken on each message will vary per message based on a difficulty index. The worker will quite when it hits its max value; always failing to repond to the last request processed (on purpose).

Author:

jcstaff

Field Summary

Fields
Modifier and Type	Field and Description
`protected ConnectionFactory`	`connFactory`
`protected int`	`count`
`protected long[]`	`delay`
`protected Destination`	`dlq`
`private static org.apache.commons.logging.Log`	`log`
`protected int`	`maxCount`
`protected String`	`name`
`protected boolean`	`noFail`
`protected String`	`password`
`protected Destination`	`requestQueue`
`protected boolean`	`started`
`protected boolean`	`stop`
`protected boolean`	`stopped`
`protected String`	`username`

Constructor Summary

Constructors
Constructor and Description

Worker(String name)

Constructors
Constructor and Description
`Worker(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()`
`boolean`	`isStarted()`
`boolean`	`isStopped()`
`static void`	`main(String[] args)`
`void`	`run()`
`void`	`setConnFactory(ConnectionFactory connFactory)`
`void`	`setDLQ(Destination dlq)`
`void`	`setMaxCount(int maxCount)`
`void`	`setNoFail(boolean noFail)`
`void`	`setPassword(String password)`
`void`	`setRequestQueue(Destination requestQueue)`
`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
```

dlq
```
protected Destination dlq
```

stop
```
protected boolean stop
```

stopped
```
protected boolean stopped
```

started
```
protected boolean started
```

noFail
```
protected boolean noFail
```

name
```
protected String name
```

count
```
protected int count
```

maxCount
```
protected int maxCount
```

delay
```
protected long[] delay
```

username
```
protected String username
```

password
```
protected String password
```

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

Method Detail

setConnFactory

public void setConnFactory(ConnectionFactory connFactory)

setRequestQueue

public void setRequestQueue(Destination requestQueue)

setDLQ
```
public void setDLQ(Destination dlq)
```

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

setMaxCount

public void setMaxCount(int maxCount)

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

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

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

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

setNoFail

public void setNoFail(boolean noFail)

createConnection

protected Connection createConnection(ConnectionFactory connFactory)
                               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

main

public static void main(String[] args)

Class Worker

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

log

connFactory

requestQueue

dlq

stop

stopped

started

noFail

name

count

maxCount

delay

username

password

Constructor Detail

Worker

Method Detail

setConnFactory

setRequestQueue

setDLQ

getCount

setMaxCount

clearMessages

stop

isStopped

isStarted

setNoFail

createConnection

setUsername

setPassword

execute

run

main