public class QpidJMSDeliveryManager extends JMSDeliveryManager
Modifier and Type | Field and Description |
---|---|
static String |
CF_NAME |
static String |
CF_NAME_PREFIX |
static String |
MB_TYPE_LOCAL |
static String |
MB_TYPE_REMOTE |
static String |
QPID_ICF |
Constructor and Description |
---|
QpidJMSDeliveryManager(String type) |
Modifier and Type | Method and Description |
---|---|
String |
getAccessKey() |
String |
getClientID() |
String |
getHostName() |
protected Properties |
getInitialContextProperties(String userName,
String password)
Return initial context property object for given username and password
|
String |
getQpidPort() |
protected javax.jms.TopicConnectionFactory |
getTopicConnectionFactory(InitialContext initialContext)
Return topic connection factory for given initial context properties
|
protected String |
getTopicName(String topicName)
Return formatted topic name for given topic
|
String |
getType() |
String |
getVirtualHostName() |
void |
setAccessKey(String accessKey) |
void |
setClientID(String clientID) |
void |
setHostName(String hostName) |
void |
setQpidPort(String qpidPort) |
void |
setType(String type) |
void |
setVirtualHostName(String virtualHostName) |
cleanUp, getTopicConnection, initializeTenant, isDeactivated, publish, renewSubscription, setDeactivated, setNotificationManager, subscribe, unSubscribe
public static final String QPID_ICF
public static final String CF_NAME_PREFIX
public static final String CF_NAME
public static final String MB_TYPE_LOCAL
public static final String MB_TYPE_REMOTE
public QpidJMSDeliveryManager(String type)
protected Properties getInitialContextProperties(String userName, String password)
getInitialContextProperties
in class JMSDeliveryManager
userName
- usernamepassword
- passwordprotected javax.jms.TopicConnectionFactory getTopicConnectionFactory(InitialContext initialContext) throws EventBrokerException
getTopicConnectionFactory
in class JMSDeliveryManager
initialContext
- initial context proeprtiesEventBrokerException
protected String getTopicName(String topicName)
getTopicName
in class JMSDeliveryManager
topicName
- topic namepublic String getType()
public void setType(String type)
public String getHostName()
public void setHostName(String hostName)
public String getQpidPort()
public void setQpidPort(String qpidPort)
public String getClientID()
public void setClientID(String clientID)
public String getVirtualHostName()
public void setVirtualHostName(String virtualHostName)
public String getAccessKey()
public void setAccessKey(String accessKey)
Copyright © 2019 WSO2. All rights reserved.