org.eclipse.smila.connectivity.queue.worker.internal.recycler
Class RecyclerImpl

java.lang.Object
  org.eclipse.smila.connectivity.queue.worker.internal.AbstractLoggedComponent
      org.eclipse.smila.connectivity.queue.worker.internal.AbstractQueueServicesAccessPoint
          org.eclipse.smila.connectivity.queue.worker.internal.AbstractQueueService<RecordRecyclerConfigType>
              org.eclipse.smila.connectivity.queue.worker.internal.recycler.RecyclerImpl

All Implemented Interfaces:

java.lang.Runnable, Recycler, ServicesAccessPoint

public class RecyclerImpl
extends AbstractQueueService<RecordRecyclerConfigType>
implements Recycler

The Class RecordRecyclerImpl.

Field Summary

Fields inherited from class org.eclipse.smila.connectivity.queue.worker.internal.AbstractQueueService

_config

Fields inherited from class org.eclipse.smila.connectivity.queue.worker.internal.AbstractQueueServicesAccessPoint

_brokerConnections

Fields inherited from class org.eclipse.smila.connectivity.queue.worker.internal.AbstractLoggedComponent

_id, _log

Constructor Summary

RecyclerImpl(java.lang.String configName, ServicesAccessPoint accessPoint, java.lang.String dataSourceId)
Instantiates a new recycler impl.

Method Summary

BrokerConnectionService	getBrokerConnections() Gets the broker connections.
java.lang.String	getConfigName() Gets the config name.
long	getRecordsRecycled() Gets the records recycled.
RecordStorage	getRecordStorage() (non-Javadoc).
RecordRecyclerStatus	getStatus() Gets the status.
TaskListExecutionService	getTaskListExecutionService() Gets the task list execution service.
WorkflowProcessor	getWorkflowProcessor() Gets the workflow processor.
void	recycle() Recycle.
void	run()
void	start() Start.
void	stop() Stop.
void	stopRecycle() Stop recycle.

Methods inherited from class org.eclipse.smila.connectivity.queue.worker.internal.AbstractQueueService

activate, deactivate

Methods inherited from class org.eclipse.smila.connectivity.queue.worker.internal.AbstractQueueServicesAccessPoint

getBlackboardService, getManagementLock, getProcessingLock, setBlackboardFactory, setBrokerConnections, setRecordStorage, setWorkflowProcessor, unsetBlackboardFactory, unsetBrokerConnections, unsetRecordStorage, unsetWorkflowProcessor

Methods inherited from class org.eclipse.smila.connectivity.queue.worker.internal.AbstractLoggedComponent

msg

Methods inherited from class java.lang.Object

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

Constructor Detail

RecyclerImpl

public RecyclerImpl(java.lang.String configName,
                    ServicesAccessPoint accessPoint,
                    java.lang.String dataSourceId)

Instantiates a new recycler impl.

Parameters:

configName - the config name

accessPoint - the access point

dataSourceId - the data source id

Method Detail

getConfigName

public java.lang.String getConfigName()

Gets the config name.

Specified by:

getConfigName in class AbstractQueueService<RecordRecyclerConfigType>

Returns:

the config name

See Also:

AbstractQueueService.getConfigName()

start

public void start()

Start.

Specified by:

start in interface Recycler

Overrides:

start in class AbstractQueueService<RecordRecyclerConfigType>

See Also:

AbstractQueueService.start()

stop

public void stop()

Stop.

Specified by:

stop in interface Recycler

Overrides:

stop in class AbstractQueueService<RecordRecyclerConfigType>

See Also:

AbstractQueueService.stop()

getRecordsRecycled

public long getRecordsRecycled()

Gets the records recycled.

Specified by:

getRecordsRecycled in interface Recycler

Returns:

the records recycled

See Also:

Recycler.getRecordsRecycled()

getStatus

public RecordRecyclerStatus getStatus()

Gets the status.

Specified by:

getStatus in interface Recycler

Returns:

the status

See Also:

Recycler.getStatus()

getRecordStorage

public RecordStorage getRecordStorage()

(non-Javadoc).

Specified by:

getRecordStorage in interface ServicesAccessPoint

Overrides:

getRecordStorage in class AbstractQueueServicesAccessPoint

Returns:

the record storage

See Also:

AbstractQueueServicesAccessPoint.getRecordStorage()

getWorkflowProcessor

public WorkflowProcessor getWorkflowProcessor()

Gets the workflow processor.

Specified by:

getWorkflowProcessor in interface ServicesAccessPoint

Overrides:

getWorkflowProcessor in class AbstractQueueServicesAccessPoint

Returns:

the workflow processor

See Also:

AbstractQueueServicesAccessPoint.getWorkflowProcessor()

getBrokerConnections

public BrokerConnectionService getBrokerConnections()

Gets the broker connections.

Specified by:

getBrokerConnections in interface ServicesAccessPoint

Overrides:

getBrokerConnections in class AbstractQueueServicesAccessPoint

Returns:

the broker connections

See Also:

AbstractQueueServicesAccessPoint.getBrokerConnections()

getTaskListExecutionService

public TaskListExecutionService getTaskListExecutionService()

Gets the task list execution service.

Specified by:

getTaskListExecutionService in interface ServicesAccessPoint

Overrides:

getTaskListExecutionService in class AbstractQueueServicesAccessPoint

Returns:

the task list execution service

See Also:

AbstractQueueServicesAccessPoint#getTaskListExecutionService()

recycle

public void recycle()
             throws RecordRecyclerException

Recycle.

Specified by:

recycle in interface Recycler

Throws:

RecordRecyclerException - the record recycler exception

See Also:

Recycler.recycle()

run

public void run()

Specified by:

run in interface java.lang.Runnable

See Also:

Runnable.run()

stopRecycle

public void stopRecycle()
                 throws RecordRecyclerException

Stop recycle.

Specified by:

stopRecycle in interface Recycler

Throws:

RecordRecyclerException - the record recycler exception

See Also:

Recycler.stopRecycle()