public class QpidServiceImpl extends Object implements QpidService
Modifier and Type | Field and Description |
---|---|
static String |
QPID_CONF
The location for the qpid configuration file directory.
|
Constructor and Description |
---|
QpidServiceImpl(String accessKey)
Creates a new Qpid Service.
|
Modifier and Type | Method and Description |
---|---|
String |
getAccessKey()
Get the access key that should be used for internal authentication.
|
Integer |
getAMQPPort() |
Integer |
getAMQPSSLPort() |
String |
getClientID()
Get client id (machine name) that is used to connect to the broker
|
String |
getHostname()
Get hostname of the machine that broker (i.e.Carbon) runs on
|
boolean |
getIfSSLOnly()
Return if
|
String |
getInternalTCPConnectionURL(String username,
String password)
Get AMQP connection URL for internal applications
|
String |
getInternalTCPConnectionURL(String username,
String password,
String clientID)
Get AMQP connection URL for internal applications
|
String |
getInVMConnectionURL(String username)
Get In-VM AMQP connection URL for internal components
|
Integer |
getMqttPort() |
boolean |
getMQTTSSLOnly()
Returns true if SSL port enabled and default port disabled.
|
Integer |
getMqttSSLPort() |
String |
getQpidHome()
Get Qpid home directory
|
org.wso2.carbon.andes.commons.QueueDetails[] |
getQueues(boolean isDurable)
Get details about all queues (durable/non-durable) created in the broker
|
org.wso2.carbon.andes.commons.SubscriptionDetails[] |
getSubscriptions(String topic,
boolean isDurable)
Get details about all subscriptions (durable/non-durable) created in the broker
|
String |
getTCPConnectionURL(String username,
String password)
Get AMQP connection URL for external applications
|
String |
getTCPConnectionURL(String username,
String password,
String clientID)
Get AMQP connection URL for external applications
|
String |
getVirtualHostName()
Get default virtual host name of the broker
|
void |
loadConfigurations()
Read configuration files and set ports and host names
|
void |
registerBrokerLifecycleListener(BrokerLifecycleListener brokerLifecycleListener)
Register broker lifecycle listener.
|
void |
setAMQPPort(Integer amqpPort) |
void |
setAMQPSSLPort(Integer amqpSSLPort) |
void |
setMqttPort(Integer mqttPort) |
void |
setMqttSSLPort(Integer mqttSSLPort) |
public static final String QPID_CONF
public QpidServiceImpl(String accessKey)
accessKey
- The access key for in VM connection string.public void loadConfigurations()
public String getAccessKey()
getAccessKey
in interface QpidService
public String getClientID()
getClientID
in interface QpidService
public String getVirtualHostName()
getVirtualHostName
in interface QpidService
public String getHostname()
getHostname
in interface QpidService
public Integer getAMQPPort()
getAMQPPort
in interface QpidService
public void setAMQPPort(Integer amqpPort)
setAMQPPort
in interface QpidService
public Integer getAMQPSSLPort()
getAMQPSSLPort
in interface QpidService
public void setAMQPSSLPort(Integer amqpSSLPort)
setAMQPSSLPort
in interface QpidService
public Integer getMqttPort()
getMqttPort
in interface QpidService
public void setMqttPort(Integer mqttPort)
setMqttPort
in interface QpidService
public Integer getMqttSSLPort()
getMqttSSLPort
in interface QpidService
public void setMqttSSLPort(Integer mqttSSLPort)
setMqttSSLPort
in interface QpidService
public String getInVMConnectionURL(String username)
getInVMConnectionURL
in interface QpidService
username
- Authentication userpublic String getTCPConnectionURL(String username, String password)
getTCPConnectionURL
in interface QpidService
username
- Authentication usernamepassword
- Authentication passwordpublic String getTCPConnectionURL(String username, String password, String clientID)
getTCPConnectionURL
in interface QpidService
username
- Authentication usernamepassword
- Authentication passwordclientID
- Owner namepublic String getInternalTCPConnectionURL(String username, String password)
getInternalTCPConnectionURL
in interface QpidService
username
- Authentication usernamepassword
- Authentication passwordpublic String getInternalTCPConnectionURL(String username, String password, String clientID)
getInternalTCPConnectionURL
in interface QpidService
username
- Authentication usernamepassword
- Authentication passwordclientID
- Owner namepublic String getQpidHome()
getQpidHome
in interface QpidService
public org.wso2.carbon.andes.commons.QueueDetails[] getQueues(boolean isDurable)
getQueues
in interface QpidService
isDurable
- Durable queues?public org.wso2.carbon.andes.commons.SubscriptionDetails[] getSubscriptions(String topic, boolean isDurable)
getSubscriptions
in interface QpidService
topic
- Name of the topic that subscriptions bound toisDurable
- Durable subscriptions?public boolean getMQTTSSLOnly() throws ConfigurationException
ConfigurationException
public boolean getIfSSLOnly() throws ConfigurationException
getIfSSLOnly
in interface QpidService
ConfigurationException
public void registerBrokerLifecycleListener(BrokerLifecycleListener brokerLifecycleListener)
registerBrokerLifecycleListener
in interface QpidService
Copyright © 2017 WSO2. All rights reserved.