public class AdminHelper extends Object
Modifier and Type | Field and Description |
---|---|
static String |
BUNDLE_JMS_PASS |
static String |
BUNDLE_JMS_USER |
static String |
BUNDLE_JNDI_FACTORY_HOST_PROP |
static String |
BUNDLE_JNDI_FACTORY_INITIAL_PROP |
static String |
BUNDLE_JNDI_FACTORY_PORT_PROP |
static String |
BUNDLE_REST_ADMIN_IP_ALLOWED |
static String |
BUNDLE_REST_ADMIN_PASS |
static String |
BUNDLE_REST_ADMIN_ROOT |
private org.osgi.framework.BundleContext |
bundleContext |
private Connection |
cnx |
private static AdminHelper |
helper |
private InitialContext |
ictx |
private IPFilter |
ipfilter |
(package private) String |
jmsRootPassword |
(package private) String |
jmsRootUser |
private Properties |
jndiProps |
private JoramAdmin |
joramAdmin |
static Logger |
logger |
private String |
restAdminIPAllowed |
private String |
restAdminPass |
private String |
restAdminRoot |
Modifier | Constructor and Description |
---|---|
private |
AdminHelper() |
public static Logger logger
public static final String BUNDLE_JNDI_FACTORY_INITIAL_PROP
public static final String BUNDLE_JNDI_FACTORY_HOST_PROP
public static final String BUNDLE_JNDI_FACTORY_PORT_PROP
public static final String BUNDLE_REST_ADMIN_ROOT
public static final String BUNDLE_REST_ADMIN_PASS
public static final String BUNDLE_REST_ADMIN_IP_ALLOWED
public static final String BUNDLE_JMS_USER
public static final String BUNDLE_JMS_PASS
private static AdminHelper helper
private InitialContext ictx
private org.osgi.framework.BundleContext bundleContext
private Properties jndiProps
private JoramAdmin joramAdmin
private Connection cnx
private String restAdminRoot
private String restAdminPass
private String restAdminIPAllowed
private IPFilter ipfilter
String jmsRootUser
String jmsRootPassword
public static AdminHelper getInstance()
public String getRestAdminRoot()
public String getRestAdminPass()
public String getRestAdminIPAllowed()
public boolean checkIpAllowed(String addr)
addr
- The ip address to checkUnknownHostException
SocketException
public boolean authenticationRequired()
public void startJoramAdmin(String name) throws ConnectException, AdminException, JMSException
public void stopJoramAdmin()
public JoramAdmin getJoramAdmin()
public void init(org.osgi.framework.BundleContext bundleContext) throws Exception
Exception
public ArrayList<Destination> getQueueNames(int serverId) throws ConnectException, AdminException
ConnectException
AdminException
public Destination createQueue(String name) throws ConnectException, AdminException
ConnectException
AdminException
public Destination createQueue(int serverId, String name) throws ConnectException, AdminException
ConnectException
AdminException
public Destination createQueue(int serverId, String name, String className, Properties props) throws ConnectException, AdminException
ConnectException
AdminException
public void deleteQueue(int serverId, String name) throws ConnectException, AdminException, JMSException
public ArrayList<Destination> getTopicNames(int serverId) throws ConnectException, AdminException
ConnectException
AdminException
public Destination createTopic(String name) throws ConnectException, AdminException
ConnectException
AdminException
public Destination createTopic(int serverId, String name) throws ConnectException, AdminException
ConnectException
AdminException
public Destination createTopic(int serverId, String name, String className, Properties props) throws ConnectException, AdminException
ConnectException
AdminException
public void deleteTopic(int serverId, String name) throws ConnectException, AdminException, JMSException
public User createUser(String name, String password) throws ConnectException, AdminException
ConnectException
AdminException
public User createUser(String name, String password, int serverId, String identityClassName, Properties props) throws ConnectException, AdminException
ConnectException
AdminException
public void deleteUser(String name, String password, int serverId) throws ConnectException, AdminException
ConnectException
AdminException
public ConnectionFactory createTcpConnectionFactory()
public ConnectionFactory createTcpConnectionFactory(String host, int port, String reliableClass)
public ConnectionFactory createlocalConnectionFactory()
public void rebind(String name, Destination dest) throws NamingException
NamingException
public void rebind(String name, ConnectionFactory cf) throws NamingException
NamingException
public void unbind(String name) throws NamingException
NamingException
public int getLocalServerId() throws ConnectException, AdminException
ConnectException
AdminException
Copyright © 2023 ScalAgent D.T.. All rights reserved.