View Javadoc
1   /**
2    *
3    * Copyright 2004 The Apache Software Foundation
4    *
5    * Licensed under the Apache License, Version 2.0 (the "License");
6    * you may not use this file except in compliance with the License.
7    * You may obtain a copy of the License at
8    *
9    * http://www.apache.org/licenses/LICENSE-2.0
10   *
11   * Unless required by applicable law or agreed to in writing, software
12   * distributed under the License is distributed on an "AS IS" BASIS,
13   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14   * See the License for the specific language governing permissions and
15   * limitations under the License.
16   */
17  package org.codehaus.plexus.archiver.bzip2;
18  
19  import java.io.IOException;
20  
21  import org.apache.commons.compress.compressors.bzip2.BZip2CompressorOutputStream;
22  import org.codehaus.plexus.archiver.ArchiverException;
23  import org.codehaus.plexus.archiver.util.Compressor;
24  
25  import static org.codehaus.plexus.archiver.util.Streams.bufferedOutputStream;
26  import static org.codehaus.plexus.archiver.util.Streams.fileOutputStream;
27  
28  public class BZip2Compressor extends Compressor {
29  
30      private BZip2CompressorOutputStream zOut;
31  
32      /**
33       * perform the BZip2 compression operation.
34       */
35      @Override
36      public void compress() throws ArchiverException {
37          try {
38              zOut = new BZip2CompressorOutputStream(bufferedOutputStream(fileOutputStream(getDestFile())));
39              // BUffering of the source stream seems to have little/no impact
40              compress(getSource(), zOut);
41          } catch (IOException ioe) {
42              String msg = "Problem creating bzip2 " + ioe.getMessage();
43              throw new ArchiverException(msg, ioe);
44          }
45      }
46  
47      @Override
48      public void close() {
49          try {
50              if (this.zOut != null) {
51                  this.zOut.close();
52                  zOut = null;
53              }
54          } catch (final IOException e) {
55              throw new ArchiverException("Failure closing target.", e);
56          }
57      }
58  }