Examples of ValueReader

com.rabbitmq.client.impl.ValueReader
Helper class to read AMQP wire-protocol encoded values.
org.elasticsearch.hadoop.serialization.builder.ValueReader
Translates a JSON field to an actual object. Implementations should only handle the conversion and not influence the parser outside the conversion.
org.skyscreamer.yoga.util.ValueReader

Examples of com.rabbitmq.client.impl.ValueReader

    public Map<String, Object> unmarshal(byte [] bytes) 
        throws IOException
    {
        MethodArgumentReader reader = 
            new MethodArgumentReader
            (new ValueReader
             (new DataInputStream
              (new ByteArrayInputStream(bytes))));
        
        return reader.readTable();
    }

View Full Code Here

Examples of com.rabbitmq.client.impl.ValueReader

        MethodArgumentWriter writer = new MethodArgumentWriter(new ValueWriter(new DataOutputStream(buffer)));
        writer.writeTable(message);
        writer.flush();
        byte[] reply = primitiveCall(buffer.toByteArray());
        MethodArgumentReader reader =
            new MethodArgumentReader(new ValueReader(new DataInputStream(new ByteArrayInputStream(reply))));
        return reader.readTable();
    }

View Full Code Here

Examples of com.rabbitmq.client.impl.ValueReader


    public static Map<String, Object> decode(byte[] requestBody)
        throws IOException
    {
        MethodArgumentReader reader =
            new MethodArgumentReader(new ValueReader
                                     (new DataInputStream
                                      (new ByteArrayInputStream(requestBody))));
        Map<String, Object> request = reader.readTable();
        return request;
    }

View Full Code Here

Examples of com.rabbitmq.client.impl.ValueReader

    public Map<String, Object> unmarshal(byte [] bytes) 
        throws IOException
    {
        MethodArgumentReader reader = 
            new MethodArgumentReader
            (new ValueReader
             (new DataInputStream
              (new ByteArrayInputStream(bytes))));
        
        return reader.readTable();
    }

View Full Code Here

Examples of com.rabbitmq.client.impl.ValueReader


    public static Map<String, Object> decode(byte[] requestBody)
        throws IOException
    {
        MethodArgumentReader reader =
            new MethodArgumentReader(new ValueReader
                                     (new DataInputStream
                                      (new ByteArrayInputStream(requestBody))));
        Map<String, Object> request = reader.readTable();
        return request;
    }

View Full Code Here

Examples of com.rabbitmq.client.impl.ValueReader

        MethodArgumentWriter writer = new MethodArgumentWriter(new ValueWriter(new DataOutputStream(buffer)));
        writer.writeTable(message);
        writer.flush();
        byte[] reply = primitiveCall(buffer.toByteArray());
        MethodArgumentReader reader =
            new MethodArgumentReader(new ValueReader(new DataInputStream(new ByteArrayInputStream(reply))));
        return reader.readTable();
    }

View Full Code Here

Examples of org.elasticsearch.hadoop.serialization.builder.ValueReader


        if (!SettingsUtils.hasPinnedNode(settings)) {
            SettingsUtils.pinNode(settings, partition.nodeIp, partition.nodePort);
        }


        ValueReader reader = ObjectUtils.instantiate(settings.getSerializerValueReaderClassName(), settings);


        Field fieldMapping = null;


        if (StringUtils.hasText(partition.serializedMapping)) {
            fieldMapping = IOUtils.deserializeFromBase64(partition.serializedMapping);

View Full Code Here

Examples of org.elasticsearch.hadoop.serialization.builder.ValueReader


            this.esSplit = esSplit;


            // initialize mapping/ scroll reader
            InitializationUtils.setValueReaderIfNotSet(settings, WritableValueReader.class, log);
            ValueReader reader = ObjectUtils.instantiate(settings.getSerializerValueReaderClassName(), settings);


            String mappingData = esSplit.mapping;


            Field mapping = null;

View Full Code Here

Examples of org.skyscreamer.yoga.util.ValueReader

        return event.getRequestContext().getResponse().encodeURL(url);
    }


    protected <T> String getUrlVal(String uriTemplate, final String suffix, final RenderingEvent<T> event)
    {
        ValueReader reader = new ValueReader()
        {
            @Override
            public Object getValue( String propertyName )
            {
                Property<T> property = event.getSelector().getProperty( event.getValueType(), propertyName );

View Full Code Here

Examples of org.skyscreamer.yoga.util.ValueReader


    @Test
    public void testSimple()
    {
        String href = URICreator.getHref( "/foo/{id}",
                new ValueReader()
                {


                    @Override
                    public Object getValue( String property )
                    {

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.