@Override
  public void initListeners(TransactionListener[] newListeners) {
    synchronized (txListeners) {
      if (!txListeners.isEmpty()) {
        for (final TransactionListener txListener : txListeners) {
          closeListener(txListener);
        }
        txListeners.clear();
      }
      if (newListeners != null && newListeners.length > 0) {
        List<TransactionListener> nl = Arrays.asList(newListeners);
        if (nl.contains(null)) {
          throw new IllegalArgumentException(
              "initListeners parameter had a null element");
        }
        txListeners.addAll(nl);
      }
    }
  }
Get the TransactionWriter for the cache

@return the current TransactionWriter
@see TransactionWriter
geode-core/src/main/java/org/apache/geode/internal/cache/TXManagerImpl.java