@Test public void getQueueDestination() { jmsDelegate.destinationType = QUEUE.name(); jmsDelegate.destinationName = "somename"; Destination dest = jmsProvider.getDestination( jmsDelegate, variableSpace ); assertTrue( dest instanceof Queue ); }
@Override public Destination getDestination( JmsDelegate meta, VariableSpace variableSpace ) { checkNotNull( meta.destinationName, getString( JmsConstants.PKG, "JmsWebsphereMQ.DestinationNameRequired" ) ); try { String destName = variableSpace.environmentSubstitute( meta.destinationName ); return isQueue( meta, variableSpace ) ? new MQQueue( destName ) : new MQTopic( destName ); } catch ( JMSException e ) { throw new RuntimeException( e ); } }
WebsphereMQProvider implements JmsProvider { @Override public Destination getDestination( JmsDelegate meta, VariableSpace variableSpace ) { checkNotNull( meta.destinationName, getString( JmsConstants.PKG, "JmsWebsphereMQ.DestinationNameRequired" ) ); try { String destName = variableSpace.environmentSubstitute( meta.destinationName ); return isQueue( meta, variableSpace ) ? new MQQueue( destName ) : new MQTopic( destName ); } catch ( JMSException e ) { throw new RuntimeException( e ); } } }
WebsphereMQProvider implements JmsProvider { @Override public Destination getDestination( JmsDelegate meta, VariableSpace variableSpace ) { checkNotNull( meta.destinationName, getString( JmsConstants.PKG, "JmsWebsphereMQ.DestinationNameRequired" ) ); try { String destName = variableSpace.environmentSubstitute( meta.destinationName ); return isQueue( meta, variableSpace ) ? new MQQueue( destName ) : new MQTopic( destName ); } catch ( JMSException e ) { throw new RuntimeException( e ); } }  }
WebsphereMQProvider implements JmsProvider { @Override public Destination getDestination( JmsDelegate meta, VariableSpace variableSpace ) { checkNotNull( meta.destinationName, getString( JmsConstants.PKG, "JmsWebsphereMQ.DestinationNameRequired" ) ); try { String destName = variableSpace.environmentSubstitute( meta.destinationName ); return isQueue( meta, variableSpace ) ? new MQQueue( destName ) : new MQTopic( destName ); } catch ( JMSException e ) { throw new RuntimeException( e ); } }  @Override boolean supports( ConnectionType type ); @Override JMSContext getContext( JmsDelegate meta, VariableSpace variableSpace ); @Override Destination getDestination( JmsDelegate meta,
                                               VariableSpace variableSpace ); }
WebsphereMQProvider implements JmsProvider { @Override public Destination getDestination( JmsDelegate meta, VariableSpace variableSpace ) { checkNotNull( meta.destinationName, getString( JmsConstants.PKG, "JmsWebsphereMQ.DestinationNameRequired" ) ); try { String destName = variableSpace.environmentSubstitute( meta.destinationName ); return isQueue( meta, variableSpace ) ? new MQQueue( destName ) : new MQTopic( destName ); } catch ( JMSException e ) { throw new RuntimeException( e ); } }  @Override boolean supports( ConnectionType type ); @Override JMSContext getContext( JmsDelegate meta, VariableSpace variableSpace ); @Override Destination getDestination( JmsDelegate meta,
                                               VariableSpace variableSpace );  }