java.lang.Object
- ejava.examples.jmsnotifier.Subscriber

All Implemented Interfaces:

Runnable
```
public class Subscriber
extends Object
implements Runnable
```
This is used to listen to messages on a destination. You can control the durability (topics only) and selector used using the properties.

Field Summary

Fields
Modifier and Type	Field	Description
`protected ConnectionFactory`	`connFactory`
`protected Destination`	`destination`
`protected boolean`	`durable`
`protected int`	`limitCount`
`private static org.slf4j.Logger`	`logger`
`protected int`	`maxCount`
`protected String`	`name`
`protected String`	`password`
`protected String`	`selector`
`protected long`	`sleepTime`
`protected boolean`	`started`
`protected boolean`	`stop`
`protected boolean`	`stopped`
`protected String`	`username`

Constructor Summary

Constructors
Constructor Description

Subscriber(String name)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`clearMessages()`
`private JMSConsumer`	`createConsumer(JMSContext context)`
`private JMSContext`	`createContext(Integer sessionMode)`
`void`	`execute()`
`int`	`getCount()`
`boolean`	`isStarted()`
`boolean`	`isStopped()`
`static void`	`main(String[] args)`
`void`	`run()`
`void`	`setConnFactory(ConnectionFactory connFactory)`
`void`	`setDestination(Destination destination)`
`void`	`setDurable(boolean durable)`
`void`	`setMaxCount(int maxCount)`
`void`	`setPassword(String password)`
`void`	`setSelector(String selector)`
`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

logger

private static final org.slf4j.Logger logger

connFactory

protected ConnectionFactory connFactory

destination
```
protected Destination destination
```

stop
```
protected boolean stop
```

stopped
```
protected boolean stopped
```

started
```
protected boolean started
```

name
```
protected String name
```

limitCount
```
protected int limitCount
```

sleepTime
```
protected long sleepTime
```

maxCount
```
protected int maxCount
```

durable
```
protected boolean durable
```

selector
```
protected String selector
```

username
```
protected String username
```

password
```
protected String password
```

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

Method Detail

setConnFactory

public void setConnFactory(ConnectionFactory connFactory)

setDestination

public void setDestination(Destination destination)

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

setSleepTime

public void setSleepTime(long sleepTime)

setMaxCount

public void setMaxCount(int maxCount)

setDurable

public void setDurable(boolean durable)

setSelector

public void setSelector(String selector)

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

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

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

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

setUsername

public void setUsername(String username)

setPassword

public void setPassword(String password)

createContext

private JMSContext createContext(Integer sessionMode)

createConsumer

private JMSConsumer createConsumer(JMSContext context)

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 Subscriber

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

logger

connFactory

destination

stop

stopped

started

name

limitCount

sleepTime

maxCount

durable

selector

username

password

Constructor Detail

Subscriber

Method Detail

setConnFactory

setDestination

getCount

setSleepTime

setMaxCount

setDurable

setSelector

clearMessages

stop

isStopped

isStarted

setUsername

setPassword

createContext

createConsumer

execute

run

main