5859606162636465
return new JBossMQAdmin(this, hermes, jndiCF, jndiCF._getConnectionFactory()); } else { throw new HermesException("Provider is not JBossMQ"); } }
175176177178179180181182
try { FileMessageConsumer rval = new FileMessageConsumer(this, (FileQueue) arg0, arg1); onCommit.add(rval); return rval; } catch (IOException e) { throw new HermesException(e); } }
190191192193194195196197
try { FileMessageConsumer rval = new FileMessageConsumer(this, (FileQueue) arg0, null); onCommit.add(rval); return rval; } catch (IOException e) { throw new HermesException(e); } }
214215216217218219220221
*/ public TemporaryQueue createTemporaryQueue() throws JMSException { try { return new FileQueue(); } catch (IOException e) { throw new HermesException(e); } }
237238239240241242243244
253254255256257258259260
268269270271272273274275
80818283848586878889
admin = (Admin) context.lookup(factory.getAdminBinding()); } } catch (NamingException ex) { throw new HermesException(ex); } return admin ; }
9899100101102103104105
final Map stats = getAdmin().getDestinationStatistics(getRealDestinationName(dest)); return ((Integer) stats.get(StatisticalProperties.NUM_MESSAGES_OUTSTANDING)).intValue(); } catch (AdminException e) { throw new HermesException(e); } }
123124125126127128129130
{ return getAdmin().getDestinationStatistics(getRealDestinationName(destination)); } catch (Exception e) { throw new HermesException(e); } }