org.hornetq.core.server.impl

Class ConnectorsService

java.lang.Object

org.hornetq.core.server.impl.ConnectorsService

All Implemented Interfaces:

HornetQComponent

public final class ConnectorsService
extends Object
implements HornetQComponent

ConnectorsService will pool some resource for updates, e.g. Twitter, then the changes are picked and converted into a ServerMessage for a given destination (queue).

It may also listen to a queue, and forward them (e.g. messages arriving at the queue are picked and tweeted to some Twitter account).

Author:

Andy Taylor Created Jun 29, 2010

Constructor Summary

Constructors

Constructor and Description
ConnectorsService(Configuration configuration, StorageManager storageManager, ScheduledExecutorService scheduledPool, PostOffice postOffice)

Method Summary

Methods

Modifier and Type	Method and Description
Set<ConnectorService>	getConnectors()
boolean	isStarted()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectorsService

public ConnectorsService(Configuration configuration,
                 StorageManager storageManager,
                 ScheduledExecutorService scheduledPool,
                 PostOffice postOffice)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

getConnectors

public Set<ConnectorService> getConnectors()