Package 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	Description
ConnectorsService(Configuration configuration, StorageManager storageManager, ScheduledExecutorService scheduledPool, PostOffice postOffice, ServiceRegistry serviceRegistry)

Method Summary

Modifier and Type	Method	Description
void	createService(ConnectorServiceConfiguration info, ConnectorServiceFactory factory)
void	destroyService(String name)
Map<String,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

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Constructor Details

ConnectorsService

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

Method Details

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

createService

public void createService(ConnectorServiceConfiguration info,
 ConnectorServiceFactory factory)
                   throws Exception

Throws:

Exception

destroyService

public void destroyService(String name)
                    throws Exception

Throws:

Exception

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 Map<String,ConnectorService> getConnectors()