Sha256: 42ae129d0956a2019375db4d105981e9df6d3680118f88f7a499227a32182cd6

Contents?: true

Size: 1.9 KB

Versions: 102

Compression:

Stored size: 1.9 KB

Contents

package com.jrjackson;

import com.fasterxml.jackson.core.JsonParser;

import org.jruby.Ruby;
import org.jruby.RubyClass;
import org.jruby.internal.runtime.methods.DynamicMethod;
import org.jruby.runtime.ThreadContext;
import org.jruby.runtime.builtin.IRubyObject;
import org.jruby.exceptions.RaiseException;

/**
 *
 * @author Guy Boertje
 */
public abstract class StreamParse {

    protected final ThreadContext _ctx;
    protected final Ruby _ruby;
    protected final IRubyObject _handler;
    protected final RubyClass _meta;
    protected final RubyStringConverter keyConverter = new RubyStringConverter();
    
    protected final DynamicMethod _hash_start;
    protected final boolean _no_hash_start;

    protected final DynamicMethod _hash_end;
    protected final boolean _no_hash_end;

    protected final DynamicMethod _array_start;
    protected final boolean _no_array_start;

    protected final DynamicMethod _array_end;
    protected final boolean _no_array_end;
    
    protected final DynamicMethod _add_value;
    protected final boolean _no_add_value;

    public StreamParse(ThreadContext ctx, IRubyObject handler)
            throws RaiseException {

        _ctx = ctx;
        _ruby = ctx.runtime;
        _handler = handler;
        _meta = _handler.getMetaClass();
        
        _add_value = _meta.searchMethod("add_value");
        _no_add_value = _add_value.isUndefined();

        _hash_start = _meta.searchMethod("hash_start");
        _no_hash_start = _hash_start.isUndefined();

        _hash_end = _meta.searchMethod("hash_end");
        _no_hash_end = _hash_end.isUndefined();

        _array_start = _meta.searchMethod("array_start");
        _no_array_start = _array_start.isUndefined();

        _array_end = _meta.searchMethod("array_end");
        _no_array_end = _array_end.isUndefined();

    }
    
    public abstract IRubyObject deserialize(JsonParser jp) 
            throws RaiseException;
}

Version data entries

102 entries across 90 versions & 17 rubygems

Version Path
logstash-output-scalyr-0.1.3 vendor/bundle/jruby/2.5.0/gems/jrjackson-0.4.8-java/src/main/java/com/jrjackson/StreamParse.java
logstash-output-scalyr-0.1.2 vendor/bundle/jruby/2.5.0/gems/jrjackson-0.4.8-java/src/main/java/com/jrjackson/StreamParse.java
logstash-output-scalyr-0.1.2 vendor/bundle/jruby/2.5.0/gems/jrjackson-0.4.12-java/src/main/java/com/jrjackson/StreamParse.java
jrjackson-0.4.12-java src/main/java/com/jrjackson/StreamParse.java
jrjackson-0.4.11-java src/main/java/com/jrjackson/StreamParse.java
jrjackson-0.4.10-java src/main/java/com/jrjackson/StreamParse.java
jrjackson-0.4.9-java src/main/java/com/jrjackson/StreamParse.java
jrjackson-0.4.8-java src/main/java/com/jrjackson/StreamParse.java
jrjackson-0.4.7-java src/main/java/com/jrjackson/StreamParse.java
logstash-filter-device_detection-1.0.7-java vendor/bundle/jruby/1.9/gems/jrjackson-0.4.6-java/src/main/java/com/jrjackson/StreamParse.java
mrcooper-logstash-output-azuresearch-0.2.2 vendor/jruby/2.5.0/gems/jrjackson-0.4.6-java/src/main/java/com/jrjackson/StreamParse.java
jrjackson-0.4.6-java src/main/java/com/jrjackson/StreamParse.java
jrjackson-0.4.5-java src/main/java/com/jrjackson/StreamParse.java
jrjackson-0.4.4-java src/main/java/com/jrjackson/StreamParse.java
logstash-output-icinga-1.1.0 vendor/jruby/1.9/gems/jrjackson-0.4.2-java/src/main/java/com/jrjackson/StreamParse.java
logstash-output-icinga-1.1.0 vendor/jruby/2.3.0/gems/jrjackson-0.4.2-java/src/main/java/com/jrjackson/StreamParse.java
jrjackson-0.4.3-java src/main/java/com/jrjackson/StreamParse.java
logstash-filter-cache-redis-0.3.1 vendor/bundle/jruby/1.9/gems/jrjackson-0.4.2-java/src/main/java/com/jrjackson/StreamParse.java
logstash-filter-cache-redis-0.3.0 vendor/bundle/jruby/1.9/gems/jrjackson-0.4.2-java/src/main/java/com/jrjackson/StreamParse.java
logstash-filter-cache-redis-0.2.0 vendor/bundle/jruby/1.9/gems/jrjackson-0.4.2-java/src/main/java/com/jrjackson/StreamParse.java