com.j_spaces.jms

Class DurableServiceWorkerImpl

java.lang.Object

com.j_spaces.jms.DurableServiceWorkerImpl

All Implemented Interfaces:

IPrivilegeWorker, IWorker, Runnable

public class DurableServiceWorkerImpl
extends Object
implements IPrivilegeWorker

Author:

yurak TODO To change the template for this generated type comment go to Window - Preferences - Java - Code Style - Code Templates

Field Summary

Fields

Modifier and Type	Field and Description
static String	NUMBER_OF_DURABLE_SUBSCRIBERS
static String	NUMBER_OF_MONITORED_TOPICS

Constructor Summary

Constructors

Constructor and Description
DurableServiceWorkerImpl()

Method Summary

Modifier and Type	Method and Description
void	close() This method should close by proper way the initialized worker, include all internal worker's Threads.
Properties	getInfo()
void	init(IJSpace proxy, String workerName, String arg) This method will be called on space initialization.
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NUMBER_OF_MONITORED_TOPICS

public static final String NUMBER_OF_MONITORED_TOPICS

See Also:

Constant Field Values

NUMBER_OF_DURABLE_SUBSCRIBERS

public static final String NUMBER_OF_DURABLE_SUBSCRIBERS

See Also:

Constant Field Values

Constructor Detail

DurableServiceWorkerImpl

public DurableServiceWorkerImpl()

Method Detail

init

public void init(IJSpace proxy,
                 String workerName,
                 String arg)
          throws Exception

Description copied from interface: IPrivilegeWorker

This method will be called on space initialization.

Specified by:

init in interface IPrivilegeWorker

Specified by:

init in interface IWorker

Parameters:

proxy - Space proxy.

workerName - Worker name.

arg - Any user defined argument.

Throws:

Exception - Failed to initialize worker.

getInfo

public Properties getInfo()

close

public void close()

Description copied from interface: IWorker

This method should close by proper way the initialized worker, include all internal worker's Threads.

Specified by:

close in interface IWorker

run

public void run()

Specified by:

run in interface Runnable