Package com.caucho.hessian.io

Examples of com.caucho.hessian.io.HessianInput

72
73
74
75
76
77
78
79
80
81
82
                serverResolver));
        out.writeObject(object);

        byte[] data = bytes.toByteArray();

        HessianInput in = new HessianInput(new ByteArrayInputStream(data));
        in.setSerializerFactory(HessianConfig.createFactory(
                HessianConnection.CLIENT_SERIALIZER_FACTORIES,
                null));
        return in.readObject();
    }
View Full Code Here
287
288
289
290
291
292
293
294
295
296
297
298
299
        try {
            InputStream is = request.getInputStream();
            OutputStream os = response.getOutputStream();

            // ***** Hessian 3.0.13 bug: the following line was missing.
            HessianInput in = new HessianInput();
            in.setSerializerFactory(getSerializerFactory());
            in.init(is);

            HessianOutput out = new HessianOutput();
            out.setSerializerFactory(getSerializerFactory());
            out.init(os);

View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
      throw new IllegalStateException("Hessian 1 (version 3.0.19-) not present");
    }
  }

  public void invoke(InputStream inputStream, OutputStream outputStream) throws Throwable {
    HessianInput in = new HessianInput(inputStream);
    HessianOutput out = new HessianOutput(outputStream);
    if (this.serializerFactory != null) {
      in.setSerializerFactory(this.serializerFactory);
      if (applySerializerFactoryToOutput) {
        out.setSerializerFactory(this.serializerFactory);
      }
    }
    try {
      invokeMethod.invoke(this.skeleton, new Object[] {in, out});
    }
    finally {
      try {
        in.close();
        inputStream.close();
      }
      catch (IOException ex) {
      }
      try {
View Full Code Here
197
198
199
200
201
202
203
204
205
206
207
      }
      else if (code == 'c') {
        // Hessian 1.0 call
        major = isToUse.read();
        minor = isToUse.read();
        in = new HessianInput(isToUse);
        if (major >= 2) {
          out = new Hessian2Output(osToUse);
        }
        else {
          out = new HessianOutput(osToUse);
View Full Code Here
175
176
177
178
179
180
181
182
183
184
185
      }
      else if (code == 'c') {
        // Hessian 1.0 call
        major = isToUse.read();
        minor = isToUse.read();
        in = new HessianInput(isToUse);
        if (major >= 2) {
          out = new Hessian2Output(osToUse);
        }
        else {
          out = new HessianOutput(osToUse);
View Full Code Here
19
20
21
22
23
24
25
26
27
28
29
        hessionOutput.writeObject(data);
        hessionOutput.close();
    }

    public Object deserialize(Class clazz, InputStream inputStream) throws IOException {
        HessianInput hession2Input = new HessianInput(inputStream);

        Object result = hession2Input.readObject();
        hession2Input.close();
        return result;
    }
View Full Code Here
468
469
470
471
472
473
474
475
476
477
478
    AbstractHessianInput in;

    if (_isDebug)
      is = new HessianDebugInputStream(is, new PrintWriter(System.out));

    in = new HessianInput(is);

    in.setRemoteResolver(getRemoteResolver());

    in.setSerializerFactory(getSerializerFactory());
View Full Code Here
66
67
68
69
70
71
72
73
74
  }

  protected Object readResponse(InputStream in)
    throws IOException, RestException
  {
    HessianInput hessianIn = new HessianInput(in);

    return hessianIn.readObject(null);
  }
View Full Code Here
70
71
72
73
74
75
76
77
78
  }
 
  protected Object readPostData(InputStream in)
    throws IOException, RestException
  {
    HessianInput hessianIn = new HessianInput(in);

    return hessianIn.readObject(null);
  }
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
    }
    //
    public Object decode(byte[] bytes) throws IOException {
        ClassLoader tccl = Thread.currentThread().getContextClassLoader();
        Thread.currentThread().setContextClassLoader(Hessian_DecoderEncoder.class.getClassLoader());
        HessianInput input = new HessianInput(new ByteArrayInputStream(bytes));
        input.setSerializerFactory(this.serializerFactory);
        Object resultObject = input.readObject();
        Thread.currentThread().setContextClassLoader(tccl);
        return resultObject;
    }
View Full Code Here
TOP

Related Classes of com.caucho.hessian.io.HessianInput

  • com.caucho.hessian.client.HessianProxyFactory
  • com.caucho.soa.rest.HessianRestProtocolServlet
  • com.caucho.soa.rest.HessianRestProxy
  • com.taobao.metamorphosis.utils.codec.impl.Hessian1Deserializer
  • com.telenav.tnt.benchmark.serialization.HessianSerializer
  • de.netseeker.ejoe.adapter.HessianAdapter
  • mx4j.tools.remote.caucho.hessian.HessianCauchoInput
  • net.hasor.rsf.serialize.coder.Hessian_DecoderEncoder
  • org.apache.cayenne.remote.hessian.service._HessianServlet
  • org.apache.cayenne.remote.hessian.service.HessianUtil
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.