-
Notifications
You must be signed in to change notification settings - Fork 33
/
JMSAdminFactoryImpl.java
231 lines (199 loc) · 8.25 KB
/
JMSAdminFactoryImpl.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
/*
* Copyright (c) 2000, 2020 Oracle and/or its affiliates. All rights reserved.
* Copyright (c) 2020, 2022 Contributors to the Eclipse Foundation
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Public License v. 2.0, which is available at
* http://www.eclipse.org/legal/epl-2.0.
*
* This Source Code may also be made available under the following Secondary
* Licenses when the conditions for such availability set forth in the
* Eclipse Public License v. 2.0 are satisfied: GNU General Public License,
* version 2 with the GNU Classpath Exception, which is available at
* https://www.gnu.org/software/classpath/license.html.
*
* SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0
*/
/*
* @(#)JMSAdminFactoryImpl.java 1.12 06/27/07
*/
package com.sun.messaging.jmq.admin.jmsspi;
import java.util.Properties;
import jakarta.jms.*;
import com.sun.messaging.ConnectionConfiguration;
import com.sun.messaging.jmq.jmsspi.JMSAdmin;
import com.sun.messaging.jmq.jmsspi.JMSAdminFactory;
import com.sun.messaging.jmq.jmsspi.PropertiesHolder;
import com.sun.messaging.jmq.admin.util.Globals;
import com.sun.messaging.jmq.admin.resources.AdminResources;
public class JMSAdminFactoryImpl implements JMSAdminFactory {
private static AdminResources ar = Globals.getAdminResources();
public final static String DEFAULT_ADMIN_USERNAME = "admin";
public final static String DEFAULT_ADMIN_PASSWD = "admin";
/**
* This constructor should only be used when no need to communicate with broker e.g. only create administered objects
*/
@Override
public JMSAdmin getJMSAdmin() throws JMSException {
return (getJMSAdmin(false));
}
/**
* This constructor should only be used when no need to communicate with broker e.g. only create administered objects
*
* @param secure Use secure transport
* @return Implementation of JMSAdmin.
*/
@Override
public JMSAdmin getJMSAdmin(boolean secure) throws JMSException {
Properties connectionProps = createProviderProperties(null, secure);
return new JMSAdminImpl(connectionProps, null, DEFAULT_ADMIN_USERNAME, DEFAULT_ADMIN_PASSWD);
}
/**
* Create/return an instance implementing JMSAdmin.
*
* @param jmsAdminURL JMSAdmin URL
* @param brokerPropertiesHolder holder of Properties to be passed to managed broker
* @param adminUserName Administrator username
* @param adminPassword Administrator password (needed for client connections and when starting broker if not specified in
* brokerProperties)
* @return Implementation of JMSAdmin.
* @exception JMSException thrown if JMSAdmin could not be created/returned.
*/
@Override
public JMSAdmin getJMSAdmin(String jmsAdminURL, PropertiesHolder brokerPropertiesHolder, String adminUserName, String adminPassword) throws JMSException {
return getJMSAdmin(jmsAdminURL, brokerPropertiesHolder, adminUserName, adminPassword, false);
}
/**
* Create/return an instance implementing JMSAdmin.
*
* @param jmsAdminURL JMSAdmin URL
* @param adminUserName Administrator username
* @param adminPassword Administrator password
* @return Implementation of JMSAdmin.
* @exception JMSException thrown if JMSAdmin could not be created/returned.
*/
@Override
public JMSAdmin getJMSAdmin(String jmsAdminURL, String adminUserName, String adminPassword) throws JMSException {
return getJMSAdmin(jmsAdminURL, null, adminUserName, adminPassword, false);
}
/**
* Create/return an instance implementing JMSAdmin.
*
* @param jmsAdminURL JMSAdmin URL
* @param brokerPropertiesHolder holder of Properties to be passed to managed broker
* @param userName Administrator username
* @param adminPassword Administrator password (needed for client connections and when starting broker if not specified in
* brokerProperties)
* @param secure Use secure transport
* @return Implementation of JMSAdmin.
* @exception JMSException thrown if JMSAdmin could not be created/returned.
*/
@Override
public JMSAdmin getJMSAdmin(String jmsAdminURL, PropertiesHolder brokerPropertiesHolder, String userName, String adminPassword, boolean secure)
throws JMSException {
Properties connectionProps = createProviderProperties(jmsAdminURL, secure);
JMSAdmin admin = new JMSAdminImpl(connectionProps, brokerPropertiesHolder, userName, adminPassword);
return admin;
}
/**
* Create/return an instance implementing JMSAdmin.
*
* @param jmsAdminURL JMSAdmin URL
* @param adminUserName Administrator username
* @param adminPassword Administrator password
* @param secure Use secure transport
* @return Implementation of JMSAdmin.
* @exception JMSException thrown if JMSAdmin could not be created/returned.
*/
@Override
public JMSAdmin getJMSAdmin(String jmsAdminURL, String adminUserName, String adminPassword, boolean secure) throws JMSException {
Properties connectionProps = createProviderProperties(jmsAdminURL, secure);
JMSAdmin admin = new JMSAdminImpl(connectionProps, null, adminUserName, adminPassword);
return admin;
}
/**
* Create/return an instance implementing JMSAdmin.
*
* @param jmsAdminURL JMSAdmin URL
* @return Implementation of JMSAdmin.
* @exception JMSException thrown if JMSAdmin could not be created/returned.
*/
@Override
public JMSAdmin getJMSAdmin(String jmsAdminURL) throws JMSException {
return getJMSAdmin(jmsAdminURL, false);
}
/**
* Create/return an instance implementing JMSAdmin.
*
* @param jmsAdminURL JMSAdmin URL
* @param secure Use secure transport
* @return Implementation of JMSAdmin.
* @exception JMSException thrown if JMSAdmin could not be created/returned.
*/
@Override
public JMSAdmin getJMSAdmin(String jmsAdminURL, boolean secure) throws JMSException {
Properties connectionProps = createProviderProperties(jmsAdminURL, secure);
JMSAdmin admin = new JMSAdminImpl(connectionProps, null, DEFAULT_ADMIN_USERNAME, DEFAULT_ADMIN_PASSWD);
return admin;
}
private Properties createProviderProperties(String jmsAdminURL, boolean secure) throws JMSException {
Properties tmpProps = new Properties();
String host = getBrokerHost(jmsAdminURL);
int port = getBrokerPort(jmsAdminURL);
if (host != null) {
tmpProps.setProperty(ConnectionConfiguration.imqBrokerHostName, host);
}
if (port > 0) {
tmpProps.setProperty(ConnectionConfiguration.imqBrokerHostPort, String.valueOf(port));
}
if (secure) {
tmpProps.setProperty(ConnectionConfiguration.imqConnectionType, "TLS");
}
return tmpProps;
}
/*
* Returns the broker host name. Returns null if not specified.
*
* @param brokerHostPort String in the form of host:port
*
* @return host value or null if not specified
*/
private String getBrokerHost(String brokerHostPort) {
String host = brokerHostPort;
if (brokerHostPort == null) {
return (null);
}
int i = brokerHostPort.indexOf(':');
if (i >= 0) {
host = brokerHostPort.substring(0, i);
}
if (host.equals("")) {
return null;
}
return host;
}
/*
* Returns the broker port number. Return -1 if not specified.
*
* @param brokerHostPort String in the form of host:port
*
* @return port value or -1 if not specified
*
* @throw BrokerAdminException if port value is not valid
*/
private int getBrokerPort(String brokerHostPort) throws JMSException {
int port = -1;
if (brokerHostPort == null) {
return (port);
}
int i = brokerHostPort.indexOf(':');
if (i >= 0) {
try {
port = Integer.parseInt(brokerHostPort.substring(i + 1));
} catch (Exception e) {
throw new JMSException(ar.getKString(AdminResources.X_JMSSPI_INVALID_PORT, brokerHostPort));
}
}
return port;
}
}