← Back to branch summary

~pbeaman/akiban-persistit/buffer-pool-warmup-sorted

« back to all changes in this revision

Viewing changes to src/main/java/com/persistit/encoding/SerialValueCoder.java

Merge from eclipse_canonical_format

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/main/java/com/persistit/encoding/SerialValueCoder.java
51
51
 * @version 1.1
52
52
 */
53
53
public final class SerialValueCoder implements ValueCoder {
54
 
    private ObjectStreamClass _classDescriptor;
 
54
    private final ObjectStreamClass _classDescriptor;
55
55
 
56
 
    public SerialValueCoder(Class<?> clazz) {
 
56
    public SerialValueCoder(final Class<?> clazz) {
57
57
        _classDescriptor = ObjectStreamClass.lookup(clazz);
58
58
        if (_classDescriptor == null) {
59
59
            throw new ConversionException("Not Serializable: " + clazz.getName());
92
92
     * @throws ConversionException
93
93
     */
94
94
    @Override
95
 
    public Object get(Value value, Class<?> clazz, CoderContext context) {
 
95
    public Object get(final Value value, final Class<?> clazz, final CoderContext context) {
96
96
        try {
97
 
            ObjectInputStream stream = value.oldValueInputStream(_classDescriptor);
98
 
            Object object = stream.readObject();
 
97
            final ObjectInputStream stream = value.oldValueInputStream(_classDescriptor);
 
98
            final Object object = stream.readObject();
99
99
            stream.close();
100
100
            return object;
101
 
        } catch (Exception e) {
 
101
        } catch (final Exception e) {
102
102
            throw new ConversionException(e);
103
103
        }
104
104
    }
138
138
     *            parameter is always ignored.
139
139
     */
140
140
    @Override
141
 
    public void put(Value value, Object object, CoderContext context) {
 
141
    public void put(final Value value, final Object object, final CoderContext context) {
142
142
        try {
143
 
            ObjectOutputStream stream = value.oldValueOutputStream(_classDescriptor);
 
143
            final ObjectOutputStream stream = value.oldValueOutputStream(_classDescriptor);
144
144
            stream.writeObject(object);
145
145
            stream.close();
146
 
        } catch (Exception e) {
 
146
        } catch (final Exception e) {
147
147
            throw new ConversionException(e);
148
148
        }
149
149
    }