196197198199200201202203
final Connection connection = getWriterConnection(); try { adapter.remove(connection, storeId); } catch (SQLException ex) { throw new HermesException(ex); } }
208209210211212213214215
return from; } else { return defaultFactory.getDestination(JMSUtils.getDestinationName(from), Domain.getDomain(from)); } } catch (NamingException ex) { throw new HermesException(ex); } }
236237238239240241242243
if (depths.containsKey(from)) { depths.put(from, depths.get(from) + 1); } } } catch (SQLException ex) { throw new HermesException(ex); } }
260261262263264265266267268269
depths.put(d, depth); } return depth; } catch (SQLException e) { throw new HermesException(e); } finally { DbUtils.closeQuietly(connection); } }
295296297298299300301302
for (final MessageStoreListener l : listeners) { l.onDestinationDeleted(destination); } } } catch (SQLException ex) { throw new HermesException(ex); } }
313314315316317318319320
depths.remove(d); destinations.remove(createStoreDestination(d)); } catch (SQLException ex) { throw new HermesException(ex); } }
324325326327328329330331332333
if (writerTL.get() != null) { writerTL.get().rollback(); writerTL.get().close(); } } catch (SQLException e) { throw new HermesException(e); } finally { writerTL.set(null); } }
337338339340341342343344345346
if (writerTL.get() != null) { writerTL.get().commit(); writerTL.get().close(); } } catch (SQLException e) { throw new HermesException(e); } finally { writerTL.set(null); } }
347348349350351352353354355356
public void close() throws JMSException { try { getWriterConnection().close(); } catch (SQLException e) { throw new HermesException(e); } finally { writerTL.set(null); } }
377378379380381382383384385
for (final MessageStoreListener l : listeners) { l.onMessageChanged(message); } } catch (SQLException ex) { throw new HermesException(ex) ; } }