Find Usages Diff Raw Download HTML Widget
Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions 
1
   /*
2
    * Licensed to the Apache Software Foundation (ASF) under one
3
    * or more contributor license agreements.  See the NOTICE file
4
    * distributed with this work for additional information
5
    * regarding copyright ownership.  The ASF licenses this file
6
    * to you under the Apache License, Version 2.0 (the
7
    * "License"); you may not use this file except in compliance
8
    * with the License.  You may obtain a copy of the License at
9
    * 
10
   *   http://www.apache.org/licenses/LICENSE-2.0
11
   * 
12
   * Unless required by applicable law or agreed to in writing,
13
   * software distributed under the License is distributed on an
14
   * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15
   * KIND, either express or implied.  See the License for the
16
   * specific language governing permissions and limitations
17
   * under the License.    
18
   */
19
  
20
  package org.apache.tuscany.sca.binding.jms;
21
  
22
  import static javax.xml.stream.XMLStreamConstants.END_ELEMENT;
23
  import static javax.xml.stream.XMLStreamConstants.START_ELEMENT;
24
  
25
  import java.util.HashMap;
26
  import java.util.HashSet;
28
  import java.util.List;
29
  import java.util.Map;
30
  import java.util.Set;
32
  
37
  
A processor to read the XML that describes the JMS binding... <binding.jms correlationScheme="string"? initialContextFactory="xs:anyURI"? jndiURL="xs:anyURI"? requestConnection="QName"? responseConnection="QName"? operationProperties="QName"? ...> <headers type="string"? deliveryMode="string"? timeToLive="int"? priority="string"?> <property name="NMTOKEN" type="NMTOKEN">* </headers>? <destination jndiName="xs:anyURI" type="string"? create="string"?> <property name="NMTOKEN" type="NMTOKEN">* </destination>? <connectionFactory jndiName="xs:anyURI" create="string"?> <property name="NMTOKEN" type="NMTOKEN">* </connectionFactory>? <activationSpec name="xs:anyURI" create="string"?> <property name="NMTOKEN" type="NMTOKEN">* </activationSpec>? <response> <destination jndiName="xs:anyURI" type="string"? create="string"?> <property name="NMTOKEN" type="NMTOKEN">* </destination>? <connectionFactory jndiName="xs:anyURI" create="string"?> <property name="NMTOKEN" type="NMTOKEN">* </connectionFactory>? <activationSpec name="xs:anyURI" create="string"?> <property name="NMTOKEN" type="NMTOKEN">* </activationSpec>? <wireFormat.someWireFormat/>? </response>? <complexType name="SubscriptionHeaders"> <attribute name="JMSSelector" type="string"/> </complexType> <resourceAdapter name="NMTOKEN">? <property name="NMTOKEN" type="NMTOKEN">* </resourceAdapter>? <operationProperties name="string" selectedOperation="string"?> <property name="NMTOKEN" type="NMTOKEN">* <headers type="string"? deliveryMode="string"? timeToLive="int"? priority="string"?> <property name="NMTOKEN" type="NMTOKEN">* </headers>? </operationProperties>* <wireFormat.someWireFormat/>? </binding.jms> Parsing error messages are recorded locally and reported as validation exceptions. Parsing warnings do not cause validation exceptions.

Version:
$Rev: 1025750 $ $Date: 2010-10-20 22:08:56 +0100 (Wed, 20 Oct 2010) $
136
 
137
 
139
     private PolicyFactory policyFactory;
143
 
144
     public JMSBindingProcessor(FactoryExtensionPoint modelFactories, StAXArtifactProcessor<Object> extensionProcessor) {
145
         this. = modelFactories.getFactory(PolicyFactory.class);
146
         this. = new PolicySubjectProcessor();
147
 
148
         this. = 
149
             new ConfiguredOperationProcessor(modelFactories);
150
         this. = extensionProcessor;
151
     }
    
    
Report a error.

Parameters:
problems
message
model
159
 
160
     private void warning(Monitor monitor, String message, Object model, Object... messageParameters) {
161
         if (monitor != null) {
162
             Problem problem = monitor.createProblem(this.getClass().getName(), "binding-jms-validation-messages", ., model, message, (Object[])messageParameters);
163
     	    monitor.problem(problem);
164
         }        
165
     }
     
    
Report an error. One side effect is that error messages are saved for future validation calls.

Parameters:
problems
message
model
174
 
175
     private void error(Monitor monitor, String message, Object model, Object... messageParameters) {
176
         if (monitor != null) {
177
             Problem problem = monitor.createProblem(this.getClass().getName(), "binding-jms-validation-messages", ., model, message, (Object[])messageParameters);
178
      	    monitor.problem(problem);
179
         }        
180
     }
181
 
182
     public QName getArtifactType() {
183
         return .;
184
     }
185
 
186
     public Class<JMSBinding> getModelType() {
187
         return JMSBinding.class;
188
     }
189
 
191
         Monitor monitor = context.getMonitor();
192
         JMSBinding jmsBinding = new JMSBinding();
193
         // Reset validation message to keep track of validation issues.
194
 
195
         // Read policies
196
         .readPolicies(jmsBinding, reader);
197
 
198
         // Read binding name
199
         String name = reader.getAttributeValue(null, "name");
200
         if (name != null) {
201
             jmsBinding.setName(name);
202
         }
203
 
204
         // Read binding URI
205
         String uri = reader.getAttributeValue(null, "uri");
206
         if (uri != null && uri.length() > 0) {
207
             parseURI(uri, jmsBinding, monitor);
208
         }
209
 
210
         // Read correlation scheme
211
         QName correlationScheme = StAXHelper.getAttributeAsQName(reader, "correlationScheme");
212
         if (correlationScheme != null) {
213
             if (..equals(correlationScheme.getNamespaceURI()) && ..contains(correlationScheme.getLocalPart())) {
214
                 jmsBinding.setCorrelationScheme(correlationScheme.getLocalPart());
215
             } else {
216
             	error(monitor, "InvalidCorrelationScheme", reader, correlationScheme);
217
             }
218
         }
219
 
220
         // Read initial context factory
221
         String initialContextFactory = getURIString(reader, "initialContextFactory");
222
         if (initialContextFactory != null && initialContextFactory.length() > 0) {
223
             jmsBinding.setInitialContextFactoryName(initialContextFactory);
224
         }
225
 
226
         // Read JNDI URL
227
         String jndiURL = getURIString(reader, "jndiURL");
228
         if (jndiURL != null && jndiURL.length() > 0) {
229
             jmsBinding.setJndiURL(jndiURL);
230
         }
231
 
232
         // Read message processor class name
233
         // TODO - maintain this for the time being but move over to 
234
         //        configuring wire formats instead of message processors
235
         String messageProcessorName = reader.getAttributeValue(null, "messageProcessor");
236
         if (messageProcessorName != null && messageProcessorName.length() > 0) {
237
             if ("XMLTextMessage".equalsIgnoreCase(messageProcessorName)) {
238
                 // may be overwritten be real wire format later
239
                 jmsBinding.setRequestWireFormat(new WireFormatJMSTextXML());
240
                 jmsBinding.setResponseWireFormat(jmsBinding.getRequestWireFormat());
241
             } else if ("TextMessage".equalsIgnoreCase(messageProcessorName)) {
242
                 // may be overwritten be real wire format later
243
                 jmsBinding.setRequestWireFormat(new WireFormatJMSText());
244
                 jmsBinding.setResponseWireFormat(jmsBinding.getRequestWireFormat());
245
             } else if ("ObjectMessage".equalsIgnoreCase(messageProcessorName)) {
246
                 // may be overwritten be real wire format later
247
                 jmsBinding.setRequestWireFormat(new WireFormatJMSObject());
248
                 jmsBinding.setResponseWireFormat(jmsBinding.getRequestWireFormat());
249
             } else {
250
                 jmsBinding.setRequestMessageProcessorName(messageProcessorName);
251
                 jmsBinding.setResponseMessageProcessorName(messageProcessorName);
252
                 // exploit the text wire format code to drive the user selected 
253
                 // message processor
254
                 jmsBinding.setRequestWireFormat(new WireFormatJMSText());
255
                 jmsBinding.setResponseWireFormat(jmsBinding.getRequestWireFormat());
256
             }
257
         }
258
 
259
         String requestConnectionName = reader.getAttributeValue(null, "requestConnection");
260
         if (requestConnectionName != null && requestConnectionName.length() > 0) {
261
             jmsBinding.setRequestConnectionName(getQNameValue(reader, requestConnectionName));
262
         }
263
         String responseConnectionName = reader.getAttributeValue(null, "responseConnection");
264
         if (responseConnectionName != null && responseConnectionName.length() > 0) {
265
             jmsBinding.setResponseConnectionName(getQNameValue(reader, responseConnectionName));
266
         }
267
 
268
         String operationPropertiesName = reader.getAttributeValue(null, "operationProperties");
269
         if (operationPropertiesName != null && operationPropertiesName.length() > 0) {
270
             jmsBinding.setOperationPropertiesName(getQNameValue(reader, operationPropertiesName));
271
         }
272
 
273
         // Read sub-elements of binding.jms
274
         boolean endFound = false;
275
         while (!endFound) {
276
             int fg = reader.next();
277
             switch (fg) {
278
                 case :
279
                     String elementName = reader.getName().getLocalPart();
280
                     if ("destination".equals(elementName)) {
281
                         parseDestination(reader, jmsBinding, monitor);
282
                     } else if ("connectionFactory".equals(elementName)) {
283
                         parseConnectionFactory(reader, jmsBinding, monitor);
284
                     } else if ("activationSpec".equals(elementName)) {
285
                         parseActivationSpec(reader, jmsBinding, monitor);
286
                     } else if ("response".equals(elementName)) {
287
                         parseResponse(reader, jmsBinding, context);
288
                     } else if ("resourceAdapter".equals(elementName)) {
289
                         parseResourceAdapter(reader, jmsBinding, monitor);
290
                     } else if ("headers".equals(elementName)) {
291
                         parseHeaders(reader, jmsBinding, monitor);
292
                     } else if ("operationProperties".equals(elementName)) {
293
                         parseOperationProperties(reader, jmsBinding, monitor);
294
                     } else if ("messageSelection".equals(elementName)) {
295
                         parseSubscriptionHeaders(reader, jmsBinding);
296
                     } else if (..equals(reader.getName())) {
297
                         ConfiguredOperation confOp = .read(reader, context);
298
                         if (confOp != null) {
299
                             ((OperationsConfigurator)jmsBinding).getConfiguredOperations().add(confOp);
300
                         }
301
                     } else {
302
                         Object extension = .read(reader, context);
303
                         if (extension != null) {
304
                             if (extension instanceof WireFormat) {
305
                                 if (jmsBinding.getRequestWireFormat() == null) {
306
                                     jmsBinding.setRequestWireFormat((WireFormat) extension);
307
                                 } else {
308
                                     error(monitor, "WireFormatAlreadyDefined", reader, extension.toString());
309
                                 }
310
                             } else if (extension instanceof OperationSelector) {
311
                                 if (jmsBinding.getOperationSelector() == null) {
312
                                     jmsBinding.setOperationSelector((OperationSelector) extension);
313
                                 } else {
314
                                     error(monitor, "OpSelectorAlreadyDefined", reader, extension.toString());
315
                                 }
316
 
317
                             } else {
318
                                 error(monitor, "UnexpectedElement", reader, extension.toString());
319
                             }
320
                         }
321
                     }
322
                     //reader.next();
323
                     break;
324
                 case :
325
                     QName x = reader.getName();
326
                     if (..equals(x.getLocalPart())) break;
327
                     // This assumption is not captured in schema, which isn't good, but will probably be fine for now.
328
                     // A better solution might be to require each processor to advance to its own END_ELEMENT.
329
                     if (x.getLocalPart().startsWith("wireFormat.") || x.getLocalPart().startsWith("operationSelector.")) {                         
330
                         break;
331
                     }
332
                     if (x.equals(.)) {
333
                         endFound = true;
334
                     } else {
335
                     	error(monitor, "UnexpectedElement: expected " + . + ", found " + x.toString(), 
336
                     	      reader, x.toString());
337
                     }
338
             }
339
         }
340
         
341
         // if no operation selector is specified then assume the default
342
         if (jmsBinding.getOperationSelector() == null){
343
             jmsBinding.setOperationSelector(new OperationSelectorJMSDefault());
344
         }
345
         
346
         // if no request wire format specified then assume the default
347
         if (jmsBinding.getRequestWireFormat() == null){
348
             jmsBinding.setRequestWireFormat(new WireFormatJMSDefault());
349
         }
350
         
351
         // if no response wire format specific then assume the same as the request
352
         if (jmsBinding.getResponseWireFormat() == null){
353
             jmsBinding.setResponseWireFormat(jmsBinding.getRequestWireFormat());
354
          }
355
 
356
         validate( jmsBinding, monitor );
357
 
358
         return jmsBinding;
359
     }
360
 
361
     protected void parseURI(String uri, JMSBinding jmsBinding, Monitor monitor) {
362
         if (!(uri.startsWith("jms:jndi:") || uri.startsWith("jms:queue:") || uri.startsWith("jms:topic:"))) {
363
             error(monitor, "MustStartWithSchema", jmsBinding, uri);
364
             return;
365
         }
366
         int i = uri.indexOf('?');            
367
         if (i >= 0) {
368
         	StringTokenizer st = new StringTokenizer(uri.substring(i+1),"&");
369
         	while (st.hasMoreTokens()) {
370
         	    String s = st.nextToken();
371
         	    if (s.startsWith("jndiConnectionFactoryName=")) {
372
         	        jmsBinding.setConnectionFactoryName(s.substring(26));
373
                     } else if (s.startsWith("deliveryMode=")) {
374
                         jmsBinding.setURIJMSDeliveryMode("persistent".equals(s.substring(13)));
375
                     } else if (s.startsWith("priority=")) {
376
                         jmsBinding.setURIJMSPriority(Integer.parseInt(s.substring(9)));
377
                     } else if (s.startsWith("timeToLive=")) {
378
                         jmsBinding.setURIJMSTimeToLive(Long.parseLong(s.substring(11)));
379
                     } else if (s.startsWith("selector='")) {
380
                         String selector = s.substring(10);
381
                         if (selector.startsWith("\"") || selector.startsWith("'")) {
382
                             selector = selector.substring(1, selector.length());
383
                         }
384
                         if (selector.endsWith("\"") || selector.endsWith("'")) {
385
                             selector = selector.substring(0, selector.length() - 1);
386
                         }
387
                         jmsBinding.setURIJMSSelector(selector);
388
                     } else if (s.startsWith("type")) {
389
                     	String type = s.substring(5);
390
                     	jmsBinding.setJMSURIType(type);                    	
391
                     } else {
392
                     	error(monitor, "UnknownTokenInURI", jmsBinding, s, uri);
393
                     	return;
394
                     }
395
         		}
396
         	int j=uri.indexOf(':', 4);
397
         	jmsBinding.setDestinationName(uri.substring(j+1, i));
398
         	jmsBinding.setDestinationType(uri.substring(4, j));
399
         } else {
400
            int j=uri.indexOf(':', 4);
401
            jmsBinding.setDestinationName(uri.substring(j+1));
402
            jmsBinding.setDestinationType(uri.substring(4, j));
403
         }
404
         jmsBinding.setJMSURI(uri);
405
     }
406
 
407
     public void resolve(JMSBinding model, ModelResolver resolver, ProcessorContext context) throws ContributionResolveException {
408
         if (model.getRequestConnectionName() != null) {
409
             model.setRequestConnectionBinding(getConnectionBinding(model, "requestConnection", model.getRequestConnectionName(), resolver, context));
410
         }
411
         if (model.getResponseConnectionName() != null) {
412
             model.setResponseConnectionBinding(getConnectionBinding(model, "responseConnection", model.getResponseConnectionName(), resolver, context));
413
         }
414
         if (model.getOperationPropertiesName() != null) {
415
             model.setOperationPropertiesBinding(getConnectionBinding(model, "operationProperties", model.getOperationPropertiesName(), resolver, context));
416
         }
417
     }
418
 
419
     private JMSBinding getConnectionBinding(JMSBinding model, String attrName, QName bindingName, ModelResolver resolver, ProcessorContext context) {
420
         JMSBinding binding = new JMSBinding();
421
         binding.setTargetNamespace(bindingName.getNamespaceURI());
422
         binding.setName(bindingName.getLocalPart());
423
         binding.setUnresolved(true);
424
         binding = resolver.resolveModel(JMSBinding.class, binding, context);
425
         if (binding.isUnresolved())
426
             error(context.getMonitor(), "BindingNotFound", model, attrName, bindingName);
427
         return binding;
428
     }
429
 
430
     private void parseDestination(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
431
     	jmsBinding.setIsDestinationSpecified(true);
432
         String name = getURIString(reader, "jndiName");
433
         if (name != null && name.length() > 0) {
434
             jmsBinding.setDestinationName(name);
435
         }
436
 
437
         String type = reader.getAttributeValue(null, "type");                
438
         if (type != null && type.length() > 0) {
439
             if (..equalsIgnoreCase(type)) {
440
                 jmsBinding.setDestinationType(.);
441
             } else if (..equalsIgnoreCase(type)) {
442
                 jmsBinding.setDestinationType(.);
443
             } else {
444
             	error(monitor, "InvalidDestinationType", reader, type);
445
             }            
446
         }
447
 
448
         String create = reader.getAttributeValue(null, "create");
449
         if (create != null && create.length() > 0) {
450
         	validateCreate(create, reader, monitor);
451
             jmsBinding.setDestinationCreate(create);
452
         }
453
 
454
         jmsBinding.getDestinationProperties().putAll(parseBindingProperties(reader, monitor));
455
         
457
             if (name == null || name.length() < 1) {
458
                 error(monitor, "MissingNameForCREATE_IF_NOT_EXIST", reader);
459
             }
460
         }
461
         if (jmsBinding.getDestinationCreate().equals(.)) {
462
             if (name == null || name.length() < 1) {
463
                 error(monitor, "MissingNameForCREATE_NEVER", reader);
464
             }
465
         }
466
     }
467
 
468
     private void parseConnectionFactory(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
469
         String name = getURIString(reader, "jndiName");
470
         if (name != null && name.length() > 0) {
471
             jmsBinding.setConnectionFactoryName(name);
472
         } else {
473
             error(monitor, "MissingConnectionFactoryName", reader);
474
         }
475
 
476
         String create = reader.getAttributeValue(null, "create");
477
         if (create != null && create.length() > 0) {
478
         	validateCreate(create, reader, monitor);
479
             jmsBinding.setConnectionFactoryCreate(create);
480
         }
482
             if (name == null || name.length() < 1) {
483
                 error(monitor, "MissingNameForCREATE_IF_NOT_EXIST", reader);
484
             }
485
         }
486
         if (jmsBinding.getConnectionFactoryCreate().equals(.)) {
487
             if (name == null || name.length() < 1) {
488
                 error(monitor, "MissingNameForCREATE_NEVER", reader);
489
             }
490
         }
491
         
492
         jmsBinding.getConnectionFactoryProperties().putAll(parseBindingProperties(reader, monitor));
493
     }
494
 
495
     private void parseActivationSpec(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
496
         String name = reader.getAttributeValue(null, "jndiName");        
497
         if (name != null && name.length() > 0) {
498
             jmsBinding.setActivationSpecName(name);            
499
         }
500
 
501
         String create = reader.getAttributeValue(null, "create");
502
         if (create != null && create.length() > 0) {
503
         	validateCreate(create, reader, monitor);
504
             jmsBinding.setActivationSpecCreate(create);
505
         }
507
             if (name == null || name.length() < 1) {
508
                 error(monitor, "MissingNameForCREATE_IF_NOT_EXIST", reader);
509
             }
510
         }
511
         if (jmsBinding.getActivationSpecCreate().equals(.)) {
512
             if (name == null || name.length() < 1) {
513
                 error(monitor, "MissingNameForCREATE_NEVER", reader);
514
             }
515
         }
516
 
517
         jmsBinding.getActivationSpecProperties().putAll(parseBindingProperties(reader, monitor));
518
     }
519
 
520
     private void parseResponseDestination(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
521
         String name = getURIString(reader, "jndiName");
522
         if (name != null && name.length() > 0) {
523
             jmsBinding.setResponseDestinationName(name);
524
         }
525
 
526
         String type = reader.getAttributeValue(null, "type");        
527
         if (type != null && type.length() > 0) {
528
             warning(monitor, "DoesntProcessResponseDestinationType", jmsBinding);
529
             if (..equalsIgnoreCase(type)) {
530
                 jmsBinding.setResponseDestinationType(.);
531
             } else if (..equalsIgnoreCase(type)) {
532
                 jmsBinding.setResponseDestinationType(.);
533
             } else {
534
                 error(monitor, "InvalidResponseDestinationType", reader, type);
535
             }
536
         }
537
 
538
         String create = reader.getAttributeValue(null, "create");
539
         if (create != null && create.length() > 0) {
540
         	validateCreate(create, reader, monitor);
541
             jmsBinding.setResponseDestinationCreate(create);
542
         }
544
             if (name == null || name.length() < 1) {
545
                 error(monitor, "MissingNameForCREATE_IF_NOT_EXIST", reader);
546
             }
547
         }
549
             if (name == null || name.length() < 1) {
550
                 error(monitor, "MissingNameForCREATE_NEVER", reader);
551
             }
552
         }
553
 
554
         jmsBinding.getResponseDestinationProperties().putAll(parseBindingProperties(reader, monitor));
555
     }
556
 
557
 	private void parseResponseConnectionFactory(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
558
         String name = getURIString(reader, "jndiName");
559
         if (name != null && name.length() > 0) {
560
             jmsBinding.setResponseConnectionFactoryName(name);            
561
         } else {
562
             warning(monitor, "MissingResponseConnectionFactory", reader);
563
         }
564
         String create = reader.getAttributeValue(null, "create");
565
         if (create != null && create.length() > 0) {
566
         	validateCreate(create, reader, monitor);
567
             jmsBinding.setResponseConnectionFactoryCreate(create);
568
         }
570
             if (name == null || name.length() < 1) {
571
                 error(monitor, "MissingNameForCREATE_IF_NOT_EXIST", reader);
572
             }
573
         }
575
             if (name == null || name.length() < 1) {
576
                 error(monitor, "MissingNameForCREATE_NEVER", reader);
577
             }
578
         }
579
         jmsBinding.getResponseConnectionFactoryProperties().putAll(parseBindingProperties(reader, monitor));
580
     }
581
 
582
     private void parseResponseActivationSpec(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
583
         String name = reader.getAttributeValue(null, "jndiName");
584
         if (name != null && name.length() > 0) {
585
             jmsBinding.setResponseActivationSpecName(name);            
586
         }
587
         String create = reader.getAttributeValue(null, "create");
588
         if (create != null && create.length() > 0) {
589
         	validateCreate(create, reader, monitor);
590
             jmsBinding.setResponseActivationSpecCreate(create);
591
         }
593
             if (name == null || name.length() < 1) {
594
                 error(monitor, "MissingNameForCREATE_IF_NOT_EXIST", reader);
595
             }
596
         }
598
             if (name == null || name.length() < 1) {
599
                 error(monitor, "MissingNameForCREATE_NEVER", reader);
600
             }
601
         }
602
         jmsBinding.getResponseActivationSpecProperties().putAll(parseBindingProperties(reader, monitor));
603
     }
604
 
605
     private void validateCreate(String create, XMLStreamReader reader, Monitor monitor) {
606
     	if (..equals(create)) {
607
     		return;
608
     	}
609
     	if (..equals(create)) {
610
     		return;
611
     	}
613
     		return;
614
     	}
615
     	error(monitor, "InvalidCreate", reader, create);
616
 	}
617
 
618
     private void parseResponse(XMLStreamReader reader, JMSBinding jmsBinding, ProcessorContext context) throws ContributionReadException, XMLStreamException {
619
         // Read sub-elements of response
620
         Monitor monitor = context.getMonitor();
621
         while (true) {
622
             switch (reader.next()) {
623
                 case :
624
                     String elementName = reader.getName().getLocalPart();
625
                     if ("destination".equals(elementName)) {
626
                         parseResponseDestination(reader, jmsBinding, context.getMonitor());
627
                     } else if ("connectionFactory".equals(elementName)) {
628
                         parseResponseConnectionFactory(reader, jmsBinding, monitor);
629
                     } else if ("activationSpec".equals(elementName)) {
630
                         parseResponseActivationSpec(reader, jmsBinding, monitor);
631
                     } else {
632
                         Object extension = .read(reader, context);
633
                         if (extension != null) {
634
                             if (extension instanceof WireFormat) {
635
                                 if (jmsBinding.getResponseWireFormat() == null) {
636
                                     jmsBinding.setResponseWireFormat((WireFormat)extension);
637
                                 } else {
638
                                     error(context.getMonitor(), "ResponseWireformatAlreadyDefined", reader, extension.toString());
639
                                 }
640
                             } else {
641
                                 error(context.getMonitor(), "UnexpectedElement", reader, extension.toString());
642
                             }
643
                         }
644
                         reader.next();
645
                     }
646
                     //reader.next();
647
                     break;
648
                 case :
649
                     QName x = reader.getName();
650
                     if (x.getLocalPart().equals("response")) {
651
                         return;
652
                     } else {
653
                     	error(context.getMonitor(), "UnexpectedResponseElement", reader, x.toString());
654
                     }
655
             }
656
         }
657
     }
658
 
659
     private void parseResourceAdapter(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
660
         String name = reader.getAttributeValue(null, "name");        
661
         if (name != null && name.length() > 0) {
662
             jmsBinding.setResourceAdapterName(name);            
663
         } else {
664
             error(monitor, "MissingResourceAdapterName", reader);
665
         }
666
         jmsBinding.getResourceAdapterProperties().putAll(parseBindingProperties(reader, monitor));
667
     }

    
<headers JMSType="string"? JMSCorrelationID="string"? JMSDeliveryMode="PERSISTENT or NON_PERSISTENT"? timeToLive="long"? JMSPriority="0 .. 9"?> <property name="NMTOKEN" type="NMTOKEN"?>* </headers>? 
677
 
678
     private void parseHeaders(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
679
         String jmsType = reader.getAttributeValue(null, "type");
680
         if (jmsType != null && jmsType.length() > 0) {
681
             jmsBinding.setJMSHeaderType(jmsType);
682
         }
683
 
684
         String jmsDeliveryMode = reader.getAttributeValue(null, "deliveryMode");
685
         if (jmsDeliveryMode != null && jmsDeliveryMode.length() > 0) {
686
             if ("persistent".equalsIgnoreCase(jmsDeliveryMode)) {
687
                 jmsBinding.setJMSHeaderDeliveryMode(true);
688
             } else if ("nonpersistent".equalsIgnoreCase(jmsDeliveryMode)) {
689
                 jmsBinding.setJMSHeaderDeliveryMode(false);
690
             } else {
691
                 error(monitor, "InvalidJMSDeliveryMode", jmsBinding, jmsDeliveryMode);
692
             }
693
         }
694
 
695
         String jmsTimeToLive = reader.getAttributeValue(null, "timeToLive");
696
         if (jmsTimeToLive != null && jmsTimeToLive.length() > 0) {
697
             jmsBinding.setJMSHeaderTimeToLive(Long.parseLong(jmsTimeToLive));
698
         }
699
 
700
         String jmsPriority = reader.getAttributeValue(null, "priority");
701
         if (jmsPriority != null && jmsPriority.length() > 0) {
702
             try {
703
                 int p = Integer.parseInt(jmsPriority);
704
                 if (p >= 0 && p <= 9) {
705
                     jmsBinding.setJMSHeaderPriority(p);
706
                 } else {
707
                     warning(monitor, "InvalidJMSPriority", jmsBinding, jmsPriority);
708
                 }
709
             } catch (NumberFormatException ex) {
710
                 error(monitor, "InvalidJMSPriority", jmsBinding, jmsPriority);
711
             }
712
         }
713
 
714
         while (true) {
715
             switch (reader.next()) {
716
                 case :
717
                     if (reader.getName().getLocalPart().equals("property")) {
718
                         parseProperty(reader, jmsBinding);
719
                     }
720
                     break;
721
                 case :
722
                     QName x = reader.getName();
723
                     if (x.getLocalPart().equals("headers")) {
724
                         return;
725
                     } else {
726
                         error(monitor, "UnexpectedResponseElement", reader, x.toString());
727
                     }
728
             }
729
         }
730
     }
731
     
732
     private void parseProperty(XMLStreamReader reader, JMSBinding jmsBinding) throws XMLStreamException {
733
         jmsBinding.setHeaders( true );
734
         String name = reader.getAttributeValue(null, "name");
735
         QName typeName = StAXHelper.getAttributeAsQName(reader, "type");
736
         String type = typeName == null ? null : typeName.getLocalPart(); 
737
         
738
         if (name != null && name.length() > 0) {
739
             Object value = reader.getElementText();
740
            
741
             if ("boolean".equalsIgnoreCase(type)) {
742
                 value = Boolean.parseBoolean((String)value);
743
             } else if ("byte".equalsIgnoreCase(type)) {
744
                 value = Byte.parseByte(((String)value));
745
             } else if ("short".equalsIgnoreCase(type)) {
746
                 value = Short.parseShort((String)value);
747
             } else if ("int".equalsIgnoreCase(type)) {
748
                 value = Integer.parseInt((String)value);
749
             } else if ("long".equalsIgnoreCase(type)) {
750
                 value = Long.parseLong((String)value);
751
             } else if ("float".equalsIgnoreCase(type)) {
752
                 value = Float.parseFloat((String)value);
753
             } else if ("double".equalsIgnoreCase(type)) {
754
                 value = Double.parseDouble((String)value);
755
             } else if ("String".equalsIgnoreCase(type)) {
756
                 // its already a string
757
             }
758
             jmsBinding.setProperty(name, value);
759
         }
760
     }

    
<operationProperties name="string" selectedOperation="string"?> <property name="NMTOKEN" type="NMTOKEN"?>* <headers JMSType="string"? JMSCorrelationID="string"? JMSDeliveryMode="PERSISTENT or NON_PERSISTENT"? timeToLive="long"? JMSPriority="0 .. 9"?> <property name="NMTOKEN" type="NMTOKEN"?>* </headers>? </operationProperties>* 
773
 
774
     private void parseOperationProperties(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
775
         
776
         if (jmsBinding.getOperationPropertiesName() != null) {
777
             error(monitor, "DuplicateOperationProperties", jmsBinding);
778
         }
779
         
780
         String opName = reader.getAttributeValue(null, "name");
781
         if (opName == null || opName.length() < 1) {
782
             error(monitor, "MissingJMSOperationPropertyName", jmsBinding);
783
             return;
784
         }
785
         // Since nativeOpName, headers, and property elements are optional, must add opName.
786
         jmsBinding.addOperationName(opName);
787
         String nativeOpName = reader.getAttributeValue(null, "selectedOperation"); // optional
788
         if (nativeOpName != null && nativeOpName.length() > 0) {
789
             jmsBinding.setNativeOperationName(opName, nativeOpName);
790
         }
791
 
792
         Map<String, BindingProperty> props = new HashMap<String, BindingProperty>();
793
         while (true) {
794
             switch (reader.next()) {
795
                 case :
796
                     if (reader.getName().getLocalPart().equals("headers")) { // optional
797
                         parseOperationHeaders(reader, jmsBinding, opName, monitor);
798
                     } else if (reader.getName().getLocalPart().equals("property")) { // optional
799
                     	processProperty(reader, props, monitor);
800
                     }
801
                 break;
802
                 case :
803
                     if (reader.isEndElement()) {
804
                         QName x = reader.getName();
805
                         if (x.getLocalPart().equals("headers")) {
806
                             break;
807
                         }
808
                         if (x.getLocalPart().equals("property")) {
809
                             break;
810
                         }
811
                         if (x.getLocalPart().equals("operationProperties")) {
812
                         	jmsBinding.getOperationPropertiesProperties(opName).putAll(props);
813
                             return;
814
                         } else {
815
                             error(monitor, "UnexpectedResponseElement", reader, x.toString());
816
                         }
817
                     }
818
             }
819
         }
820
     }
821
 
822
     private void parseOperationHeaders(XMLStreamReader reader, JMSBinding jmsBinding, String opName, Monitor monitor) throws XMLStreamException {
823
         String jmsType = reader.getAttributeValue(null, "type");
824
         if (jmsType != null && jmsType.length() > 0) {
825
             jmsBinding.setOperationJMSType(opName, jmsType);
826
         }
827
 
828
         String jmsDeliveryMode = reader.getAttributeValue(null, "deliveryMode");
829
         if (jmsDeliveryMode != null && jmsDeliveryMode.length() > 0) {
830
             if ("persistent".equalsIgnoreCase(jmsDeliveryMode)) {
831
                 jmsBinding.setOperationJMSDeliveryMode(opName, true);
832
             } else if ("nonpersistent".equalsIgnoreCase(jmsDeliveryMode)) {
833
                 jmsBinding.setOperationJMSDeliveryMode(opName, false);
834
             } else {
835
                 error(monitor, "InvalidOPJMSDeliveryMode", jmsBinding, jmsDeliveryMode);
836
             }
837
         }
838
 
839
         String jmsTimeToLive = reader.getAttributeValue(null, "timeToLive");
840
         if (jmsTimeToLive != null && jmsTimeToLive.length() > 0) {
841
             jmsBinding.setOperationJMSTimeToLive(opName, Long.parseLong(jmsTimeToLive));
842
         }
843
 
844
         String jmsPriority = reader.getAttributeValue(null, "priority");
845
         if (jmsPriority != null && jmsPriority.length() > 0) {
846
             try {
847
                 int p = Integer.parseInt(jmsPriority);
848
                 if (p >= 0 && p <= 9) {
849
                     jmsBinding.setOperationJMSPriority(opName, p);
850
                 } else {
851
                     warning(monitor, "InvalidOPJMSPriority", jmsBinding, jmsPriority);
852
                 }
853
             } catch (NumberFormatException ex) {
854
                 error(monitor, "InvalidOPJMSPriority", jmsBinding, jmsPriority);
855
             }
856
         }
857
 
858
         while (true) {
859
             switch (reader.next()) {
860
                 case :
861
                     if (reader.getName().getLocalPart().equals("property")) {
862
                         parseOperationPropertyProperties(reader, jmsBinding, opName);
863
                     }
864
                     break;
865
                 case :
866
                     QName x = reader.getName();
867
                     if (x.getLocalPart().equals("headers")) {
868
                         return;
869
                     } else {
870
                         error(monitor, "UnexpectedResponseElement", reader, x.toString());
871
                     }
872
             }
873
         }
874
     }
875
 
876
     private void parseOperationPropertyProperties(XMLStreamReader reader, JMSBinding jmsBinding, String opName) throws XMLStreamException {
877
         String propName = reader.getAttributeValue(null, "name");
878
         QName typeName = StAXHelper.getAttributeAsQName(reader, "type");
879
         String type = typeName == null ? null : typeName.getLocalPart(); 
880
         if (propName != null && propName.length() > 0) {
881
             Object value = reader.getElementText();
882
             if ("boolean".equalsIgnoreCase(type)) {
883
                 value = Boolean.parseBoolean((String)value);
884
             } else if ("byte".equalsIgnoreCase(type)) {
885
                 value = Byte.parseByte(((String)value));
886
             } else if ("short".equalsIgnoreCase(type)) {
887
                 value = Short.parseShort((String)value);
888
             } else if ("int".equalsIgnoreCase(type)) {
889
                 value = Integer.parseInt((String)value);
890
             } else if ("long".equalsIgnoreCase(type)) {
891
                 value = Long.parseLong((String)value);
892
             } else if ("float".equalsIgnoreCase(type)) {
893
                 value = Float.parseFloat((String)value);
894
             } else if ("double".equalsIgnoreCase(type)) {
895
                 value = Double.parseDouble((String)value);
896
             } else if ("String".equalsIgnoreCase(type)) {
897
                 // its already a string
898
             }
899
             jmsBinding.setOperationProperty(opName, propName, value);
900
         }
901
     }
902
 
903
     private void parseSubscriptionHeaders(XMLStreamReader reader, JMSBinding jmsBinding) throws XMLStreamException {
904
         String jmsSelector = reader.getAttributeValue(null, "selector");
905
         if (jmsSelector != null && jmsSelector.length() > 0 && jmsBinding.getJMSSelector() == null) {
906
             jmsBinding.setJMSSelector(jmsSelector);
907
         }
908
         
909
         // Skip to end element
910
         while (reader.hasNext()) {
911
             if (reader.next() ==  && "messageSelection".equals(reader.getName().getLocalPart())) {
912
                 break;
913
             }
914
         } // end while
915
     }
916
 
917
     private Map<String, BindingProperty> parseBindingProperties(XMLStreamReader reader, Monitor monitor) throws XMLStreamException {
918
     	Map<String, BindingProperty> props = new HashMap<String, BindingProperty>();
919
     	String parentName = reader.getName().getLocalPart();        
920
         // Parse for all the properties within this element, until the end of
921
         // the element is reached.
922
     	boolean completed = false;
923
         while (!completed) {
924
             switch (reader.next()) {
925
                 case :
926
                     String elementName = reader.getName().getLocalPart();
927
                     if ("property".equals(elementName)) {
928
                     	processProperty(reader, props, monitor);
929
                     }
930
                     break;
931
                 case :
932
                 	String endName = reader.getName().getLocalPart();
933
                 	if (parentName.equals(endName)) {
934
                 		completed = true;
935
                         break;
936
                 	}
937
             }
938
         }        
939
         return props;
940
     }
941
 
942
     private void processProperty(XMLStreamReader reader, Map<String, BindingProperty> props, Monitor monitor) throws XMLStreamException {
943
         String name = reader.getAttributeValue(null, "name");
944
         if (name == null || name.length() < 1) {
945
             error(monitor, "InvalidPropertyElement", reader);
946
         }
947
         String type = reader.getAttributeValue(null, "type");
948
         String value = reader.getElementText();
949
         props.put(name, new BindingProperty(name, type, value));
950
     }

    
Preserve an existing public method. The method validate() is a legacy method that was called from reading am XML stream via the read(XMLStreamReader) method above. However read(XMLStreamReader) now calls validate(JMSBinding jmsBinding) and passes in the jmsBinding model. The older validate() now calls validate(JMSBinding jmsBinding) with a null model. 
958
 
959
     public void validate() {
960
         validate( null, null );
961
     }
    
    
Validates JMS parsing and JMSBinding model. Validation rules are taken from the binding schema and the OSOA and OASIS specs: http://www.oasis-open.org/committees/documents.php?wg_abbrev=sca-bindings (sca-binding-jms-1.1-spec-cd01-rev4.pdf) http://www.osoa.org/display/Main/Service+Component+Architecture+Specifications (SCA JMS Binding V1.00 )

Parameters:
jmsBinding an optional JMS binding model to check for validity.
Since:
1.4
972
 
973
     protected void validate( JMSBinding jmsBinding, Monitor monitor ) {        
974
         // If no JMSBinding model is provided, that is all the validation we can do.
975
         if ( jmsBinding == null ) {
976
             return;
977
         }
978
 
979
         // Connection factory should not contradict destination type.
980
         String connectionFactoryName = jmsBinding.getConnectionFactoryName();
981
         if (( connectionFactoryName != null ) && ( connectionFactoryName.length() > 0 )) {
982
             if (. == jmsBinding.getDestinationType()) {
983
                 if ( connectionFactoryName.contains( "topic" )) {
984
                     error(monitor, "DestinationQueueContradiction", jmsBinding, connectionFactoryName );
985
                 }
986
             }
987
             if (. == jmsBinding.getDestinationType()) {
988
                 if ( connectionFactoryName.contains( "queue" )) {
989
                     error(monitor, "DestinationTopicContradiction", jmsBinding, connectionFactoryName );
990
                 }
991
             }
992
         }
993
         
994
         // Connection factory and activation Specification are mutually exclusive.
995
         if (( connectionFactoryName != null ) && ( connectionFactoryName.length() > 0 )) {
996
             String activationSpecName = jmsBinding.getActivationSpecName();
997
             if ((activationSpecName != null) && (activationSpecName.length() > 0 )) {
998
                 error(monitor, "ConnectionFactoryActivationSpecContradiction", jmsBinding, connectionFactoryName, activationSpecName );                
999
             }
1000
        }
1001
        
1002
        // If URI is specified, destination should not be present
1003
        if ( ( jmsBinding.getJMSURI() != null ) && ( jmsBinding.getJMSURI().length() > 0) &&
1004
        		(jmsBinding.isDestinationSpecified())) {
1005
        	error(monitor, "DestinationURIContradiction", jmsBinding, jmsBinding.getJMSURI(), jmsBinding.getDestinationName());
1006
        }
1007
        
1008
        // If activation spec and destination are both specified, they have to match
1009
        if ( ( jmsBinding.getActivationSpecName() != null ) && (jmsBinding.getActivationSpecName().length() > 0 ) &&
1010
        		(jmsBinding.getDestinationName() != null) && (jmsBinding.getDestinationName().length() > 0 ) ) {
1011
        	if ( !jmsBinding.getActivationSpecName().equals(jmsBinding.getDestinationName())) {
1012
        		error(monitor, "ActivationSpecAndDestinationMismatch", jmsBinding, jmsBinding.getActivationSpecName(), jmsBinding.getDestinationName());
1013
        	}
1014
        }
1016
        if ( ( jmsBinding.getResponseActivationSpecName() != null ) && (jmsBinding.getResponseActivationSpecName().length() > 0 ) &&
1017
        		(jmsBinding.getResponseDestinationName() != null ) && (jmsBinding.getResponseDestinationName().length() > 0 ) ) {
1018
        	if ( !jmsBinding.getResponseActivationSpecName().equals(jmsBinding.getResponseDestinationName())) {
1019
        		error(monitor, "ActivationSpecAndDestinationMismatch", jmsBinding, jmsBinding.getResponseActivationSpecName(), jmsBinding.getResponseDestinationName());
1020
        	}
1021
        }
1022
        // If activation spec exists with create=always, a jndiName must be specified
1024
        		(jmsBinding.getActivationSpecName() == null)) {
1025
        	error(monitor, "ActivationSpecNameRequiredForCreateAlways", jmsBinding);
1026
        }
1027
        // If Connection factory specified then destination name must also be
1028
        if (( connectionFactoryName != null ) && ( connectionFactoryName.length() > 0 )) {