@@ -66,12 +66,14 @@ public BridgeContextImpl(BridgeBaseContext bc, String name) {
66
66
*
67
67
* @return true if it's embeded in a broker process
68
68
*/
69
+ @ Override
69
70
public boolean isEmbeded () {
70
71
return _bc .isEmbeded ();
71
72
}
72
73
73
74
/**
74
75
*/
76
+ @ Override
75
77
public boolean doBind () {
76
78
return _bc .doBind ();
77
79
}
@@ -80,6 +82,7 @@ public boolean doBind() {
80
82
*
81
83
* @return true if the broker does not have its own JVM
82
84
*/
85
+ @ Override
83
86
public boolean isEmbededBroker () {
84
87
return _bc .isEmbededBroker ();
85
88
}
@@ -88,20 +91,23 @@ public boolean isEmbededBroker() {
88
91
*
89
92
* @return true if running on nucleus
90
93
*/
94
+ @ Override
91
95
public boolean isRunningOnNucleus () {
92
96
return _bc .isRunningOnNucleus ();
93
97
}
94
98
95
99
/**
96
100
* @return true if should disable console logging
97
101
*/
102
+ @ Override
98
103
public boolean isSilentMode () {
99
104
return _bc .isSilentMode ();
100
105
}
101
106
102
107
/**
103
108
* @return null if PUService not enabled
104
109
*/
110
+ @ Override
105
111
public Object getPUService () {
106
112
return _bc .getPUService ();
107
113
}
@@ -110,18 +116,22 @@ public Object getPUService() {
110
116
*
111
117
* @return the runtime configuration for a bridge service
112
118
*/
119
+ @ Override
113
120
public Properties getConfig () {
114
121
return _config ;
115
122
}
116
123
124
+ @ Override
117
125
public String getRootDir () {
118
126
return _config .getProperty (_config .getProperty (BRIDGE_PROP_PREFIX ) + ".varhome" );
119
127
}
120
128
129
+ @ Override
121
130
public String getLibDir () {
122
131
return _config .getProperty (_config .getProperty (BRIDGE_PROP_PREFIX ) + ".libhome" );
123
132
}
124
133
134
+ @ Override
125
135
public String getProperty (String suffix ) {
126
136
return _config .getProperty (_config .getProperty (BRIDGE_PROP_PREFIX ) + "." + suffix );
127
137
@@ -133,6 +143,7 @@ public String getProperty(String suffix) {
133
143
*
134
144
* @return a JMS connection factory for the bridge service
135
145
*/
146
+ @ Override
136
147
public javax .jms .ConnectionFactory getConnectionFactory (Properties props ) throws Exception {
137
148
138
149
com .sun .messaging .ConnectionFactory cf = new com .sun .messaging .ConnectionFactory ();
@@ -143,7 +154,7 @@ public javax.jms.ConnectionFactory getConnectionFactory(Properties props) throws
143
154
while (en .hasMoreElements ()) {
144
155
name = (String ) en .nextElement ();
145
156
if (!name .equals (com .sun .messaging .ConnectionConfiguration .imqAddressList )) {
146
- cf .setProperty (name , ( String ) props .getProperty (name ));
157
+ cf .setProperty (name , props .getProperty (name ));
147
158
}
148
159
}
149
160
}
@@ -160,6 +171,7 @@ public javax.jms.ConnectionFactory getConnectionFactory(Properties props) throws
160
171
*
161
172
* @return a JMS XA connection factory for the bridge service
162
173
*/
174
+ @ Override
163
175
public javax .jms .XAConnectionFactory getXAConnectionFactory (Properties props ) throws Exception {
164
176
165
177
com .sun .messaging .XAConnectionFactory cf = new com .sun .messaging .XAConnectionFactory ();
@@ -170,7 +182,7 @@ public javax.jms.XAConnectionFactory getXAConnectionFactory(Properties props) th
170
182
while (en .hasMoreElements ()) {
171
183
name = (String ) en .nextElement ();
172
184
if (!name .equals (com .sun .messaging .ConnectionConfiguration .imqAddressList )) {
173
- cf .setProperty (name , ( String ) props .getProperty (name ));
185
+ cf .setProperty (name , props .getProperty (name ));
174
186
}
175
187
}
176
188
}
@@ -185,6 +197,7 @@ public javax.jms.XAConnectionFactory getXAConnectionFactory(Properties props) th
185
197
*
186
198
* @return a JMS connection factory for the bridge service
187
199
*/
200
+ @ Override
188
201
public javax .jms .ConnectionFactory getAdminConnectionFactory (Properties props ) throws Exception {
189
202
190
203
com .sun .messaging .ConnectionFactory cf = new com .sun .messaging .ConnectionFactory ();
@@ -195,7 +208,7 @@ public javax.jms.ConnectionFactory getAdminConnectionFactory(Properties props) t
195
208
while (en .hasMoreElements ()) {
196
209
name = (String ) en .nextElement ();
197
210
if (!name .equals (com .sun .messaging .ConnectionConfiguration .imqAddressList )) {
198
- cf .setProperty (name , ( String ) props .getProperty (name ));
211
+ cf .setProperty (name , props .getProperty (name ));
199
212
}
200
213
}
201
214
}
@@ -218,13 +231,15 @@ public javax.jms.ConnectionFactory getAdminConnectionFactory(Properties props) t
218
231
*
219
232
* @return true if the method actually did something with the error
220
233
*/
234
+ @ Override
221
235
public boolean handleGlobalError (Throwable ex , String reason ) {
222
236
return _bc .handleGlobalError (ex , reason );
223
237
}
224
238
225
239
/**
226
240
* Register (optional) a service with host
227
241
*/
242
+ @ Override
228
243
public void registerService (String protocol , String type , int port , HashMap props ) {
229
244
230
245
_bc .registerService (_name , protocol , type , port , props );
@@ -235,6 +250,7 @@ public void registerService(String protocol, String type, int port, HashMap prop
235
250
*
236
251
* @return the default configuration properties for SSLContext
237
252
*/
253
+ @ Override
238
254
public Properties getDefaultSSLContextConfig () throws Exception {
239
255
return _bc .getDefaultSSLContextConfig (_name );
240
256
}
@@ -244,21 +260,25 @@ public Properties getDefaultSSLContextConfig() throws Exception {
244
260
*
245
261
* @return an unique identifier for this instance
246
262
*/
263
+ @ Override
247
264
public String getIdentityName () throws Exception {
248
265
return _bc .getIdentityName ();
249
266
}
250
267
268
+ @ Override
251
269
public String getBrokerHostName () {
252
270
return _bc .getBrokerHostName ();
253
271
}
254
272
273
+ @ Override
255
274
public String getTransactionManagerClass () throws Exception {
256
275
Properties props = _bc .getBridgeConfig ();
257
276
258
277
String key = props .getProperty (BridgeBaseContext .PROP_PREFIX ) + "." + _name + ".tm.class" ;
259
278
String value = props .getProperty (key );
260
- if (value != null )
279
+ if (value != null ) {
261
280
return value ;
281
+ }
262
282
263
283
key = BridgeBaseContext .PROP_PREFIX + ".tm.class" ;
264
284
return props .getProperty (key );
@@ -267,6 +287,7 @@ public String getTransactionManagerClass() throws Exception {
267
287
/**
268
288
* return an empty Properties object if no property set
269
289
*/
290
+ @ Override
270
291
public Properties getTransactionManagerProps () throws Exception {
271
292
Properties tmp = new Properties ();
272
293
Properties props = _bc .getBridgeConfig ();
@@ -277,8 +298,9 @@ public Properties getTransactionManagerProps() throws Exception {
277
298
key = props .getProperty (BridgeBaseContext .PROP_PREFIX ) + "." + _name + ".tm.props" ;
278
299
List <String > plist1 = BridgeUtil .getListProperty (key , props );
279
300
280
- if (plist0 == null && plist1 == null )
301
+ if (plist0 == null && plist1 == null ) {
281
302
return tmp ;
303
+ }
282
304
283
305
if (plist0 != null ) {
284
306
for (String value : plist0 ) {
@@ -301,56 +323,65 @@ public Properties getTransactionManagerProps() throws Exception {
301
323
return tmp ;
302
324
}
303
325
326
+ @ Override
304
327
public boolean isJDBCStoreType () throws Exception {
305
328
return _bc .isJDBCStoreType ();
306
329
}
307
330
331
+ @ Override
308
332
public Object getJDBCStore (String type ) throws Exception {
309
333
if (type .toUpperCase (Locale .getDefault ()).equals ("JMS" )) {
310
- return ( JMSBridgeStore ) _bc .getJDBCStore ();
334
+ return _bc .getJDBCStore ();
311
335
}
312
336
return null ;
313
337
}
314
338
315
339
/**
316
340
* @return true if ok to allocate size bytes of mem
317
341
*/
342
+ @ Override
318
343
public boolean allocateMemCheck (long size ) {
319
344
return _bc .allocateMemCheck (size );
320
345
}
321
346
347
+ @ Override
322
348
public boolean getPoodleFixEnabled () {
323
349
return _bc .getPoodleFixEnabled ();
324
350
}
325
351
352
+ @ Override
326
353
public String [] getKnownSSLEnabledProtocols () {
327
354
return _bc .getKnownSSLEnabledProtocols ();
328
355
}
329
356
330
357
/**
331
358
* Logging method for Bridge Service Manager
332
359
*/
360
+ @ Override
333
361
public void logError (String message , Throwable t ) {
334
362
_bc .logError (message , t );
335
363
}
336
364
337
365
/**
338
366
* Logging method for Bridge Service Manager
339
367
*/
368
+ @ Override
340
369
public void logWarn (String message , Throwable t ) {
341
370
_bc .logWarn (message , t );
342
371
}
343
372
344
373
/**
345
374
* Logging method for Bridge Service Manager
346
375
*/
376
+ @ Override
347
377
public void logInfo (String message , Throwable t ) {
348
378
_bc .logInfo (message , t );
349
379
}
350
380
351
381
/**
352
382
* Logging method for Bridge Service Manager
353
383
*/
384
+ @ Override
354
385
public void logDebug (String message , Throwable t ) {
355
386
_bc .logDebug (message , t );
356
387
}
0 commit comments