public interface QpidService
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 option is enabled for embedded-qpid
|
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() |
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 |
registerBrokerLifecycleListener(BrokerLifecycleListener brokerLifecycleListener)
Register broker lifecycle listener.
|
void |
setAMQPPort(Integer amqpPort) |
void |
setAMQPSSLPort(Integer amqpSSLPort) |
void |
setMqttPort(Integer mqttPort) |
void |
setMqttSSLPort(Integer mqttSSLPort) |
String getAccessKey()
String getClientID()
String getVirtualHostName()
String getHostname()
Integer getAMQPPort()
void setAMQPPort(Integer amqpPort)
Integer getAMQPSSLPort()
void setAMQPSSLPort(Integer amqpSSLPort)
Integer getMqttPort()
void setMqttPort(Integer mqttPort)
Integer getMqttSSLPort()
void setMqttSSLPort(Integer mqttSSLPort)
String getInVMConnectionURL(String username)
username
- Authentication userString getTCPConnectionURL(String username, String password)
username
- Authentication usernamepassword
- Authentication passwordString getTCPConnectionURL(String username, String password, String clientID)
username
- Authentication usernamepassword
- Authentication passwordclientID
- Owner nameString getInternalTCPConnectionURL(String username, String password)
username
- Authentication usernamepassword
- Authentication passwordString getInternalTCPConnectionURL(String username, String password, String clientID)
username
- Authentication usernamepassword
- Authentication passwordclientID
- Owner nameString getQpidHome()
org.wso2.carbon.andes.commons.QueueDetails[] getQueues(boolean isDurable)
isDurable
- Durable queues?org.wso2.carbon.andes.commons.SubscriptionDetails[] getSubscriptions(String topic, boolean isDurable)
topic
- Name of the topic that subscriptions bound toisDurable
- Durable subscriptions?boolean getIfSSLOnly() throws Exception
Exception
- Thrown when an error occurs while figuring out whether option is enabledvoid registerBrokerLifecycleListener(BrokerLifecycleListener brokerLifecycleListener)
brokerLifecycleListener
- The brokerLifecycleListener to be registered.Copyright © 2017 WSO2. All rights reserved.