public class AdminHelper extends Object
Modifier and Type | Field and Description |
---|---|
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 javax.jms.Connection |
cnx |
private static AdminHelper |
helper |
private InitialContext |
ictx |
private IPFilter |
ipfilter |
private Properties |
jndiProps |
private JoramAdmin |
joramAdmin |
static org.objectweb.util.monolog.api.Logger |
logger |
private String |
restAdminIPAllowed |
private String |
restAdminPass |
private String |
restAdminRoot |
Modifier | Constructor and Description |
---|---|
private |
AdminHelper() |
Modifier and Type | Method and Description |
---|---|
boolean |
authenticationRequired() |
boolean |
checkIpAllowed(String addr)
Check if the addr is authorized (all local address is authorized).
|
javax.jms.ConnectionFactory |
createlocalConnectionFactory() |
Destination |
createQueue(int serverId,
String name) |
Destination |
createQueue(int serverId,
String name,
String className,
Properties props) |
Destination |
createQueue(String name) |
javax.jms.ConnectionFactory |
createTcpConnectionFactory() |
javax.jms.ConnectionFactory |
createTcpConnectionFactory(String host,
int port,
String reliableClass) |
Destination |
createTopic(int serverId,
String name) |
Destination |
createTopic(int serverId,
String name,
String className,
Properties props) |
Destination |
createTopic(String name) |
User |
createUser(String name,
String password) |
User |
createUser(String name,
String password,
int serverId,
String identityClassName,
Properties props) |
void |
deleteQueue(int serverId,
String name) |
void |
deleteTopic(int serverId,
String name) |
void |
deleteUser(String name,
String password,
int serverId) |
static AdminHelper |
getInstance() |
JoramAdmin |
getJoramAdmin() |
int |
getLocalServerId() |
ArrayList<Destination> |
getQueueNames(int serverId) |
String |
getRestAdminIPAllowed() |
String |
getRestAdminPass() |
String |
getRestAdminRoot() |
ArrayList<Destination> |
getTopicNames(int serverId) |
void |
init(org.osgi.framework.BundleContext bundleContext) |
void |
rebind(String name,
javax.jms.ConnectionFactory cf) |
void |
rebind(String name,
Destination dest) |
void |
startJoramAdmin(String name) |
void |
stopJoramAdmin() |
void |
unbind(String name) |
public static org.objectweb.util.monolog.api.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
private static AdminHelper helper
private InitialContext ictx
private org.osgi.framework.BundleContext bundleContext
private Properties jndiProps
private JoramAdmin joramAdmin
private javax.jms.Connection cnx
private String restAdminRoot
private String restAdminPass
private String restAdminIPAllowed
private IPFilter ipfilter
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, javax.jms.JMSException
ConnectException
AdminException
javax.jms.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, javax.jms.JMSException
ConnectException
AdminException
javax.jms.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, javax.jms.JMSException
ConnectException
AdminException
javax.jms.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 javax.jms.ConnectionFactory createTcpConnectionFactory()
public javax.jms.ConnectionFactory createTcpConnectionFactory(String host, int port, String reliableClass)
public javax.jms.ConnectionFactory createlocalConnectionFactory()
public void rebind(String name, Destination dest) throws NamingException
NamingException
public void rebind(String name, javax.jms.ConnectionFactory cf) throws NamingException
NamingException
public void unbind(String name) throws NamingException
NamingException
public int getLocalServerId() throws ConnectException, AdminException
ConnectException
AdminException
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.