org.apache.activemq.artemis.core.server.impl

Class ConnectorsService

java.lang.Object

org.apache.activemq.artemis.core.server.impl.ConnectorsService

All Implemented Interfaces:

ActiveMQComponent

public final class ConnectorsService
extends Object
implements ActiveMQComponent

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).

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	createService(ConnectorServiceConfiguration info, ConnectorServiceFactory factory)
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,
                         ServiceRegistry serviceRegistry)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

createService

public void createService(ConnectorServiceConfiguration info,
                          ConnectorServiceFactory factory)

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

getConnectors

public Set<ConnectorService> getConnectors()