public final class ConnectorsService extends Object implements ActiveMQComponent
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 and Description |
---|
ConnectorsService(Configuration configuration,
StorageManager storageManager,
ScheduledExecutorService scheduledPool,
PostOffice postOffice,
ServiceRegistry serviceRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
createService(ConnectorServiceConfiguration info,
ConnectorServiceFactory factory) |
void |
destroyService(String name) |
Map<String,ConnectorService> |
getConnectors() |
boolean |
isStarted() |
void |
start() |
void |
stop() |
public ConnectorsService(Configuration configuration, StorageManager storageManager, ScheduledExecutorService scheduledPool, PostOffice postOffice, ServiceRegistry serviceRegistry)
public void start() throws Exception
start
in interface ActiveMQComponent
Exception
public void createService(ConnectorServiceConfiguration info, ConnectorServiceFactory factory) throws Exception
Exception
public void stop() throws Exception
stop
in interface ActiveMQComponent
Exception
public boolean isStarted()
isStarted
in interface ActiveMQComponent
public Map<String,ConnectorService> getConnectors()
Copyright © 2018 JBoss by Red Hat. All rights reserved.