Examples of SerializationManager

Examples of org.jboss.remoting.serialization.SerializationManager

114
115
116
117
118
119
120
121
122
123
124
125
   public Object read(InputStream inputStream, Map metadata, int version) throws IOException, ClassNotFoundException
   { 
      if(cipher == null)
         throw new IllegalStateException("Cipher is null for algo="+ this.cipherAlgorithm);
      CipherInputStream cis = new CipherInputStream(inputStream,cipher);
      SerializationManager sm = SerializationStreamFactory.getManagerInstance(getSerializationType());
      ObjectInputStream ois = sm.createRegularInput(cis);
      
      Object obj = null;
      if(wrappedUnMarshaller != null)
      {
         if (wrappedUnMarshaller instanceof VersionedUnMarshaller)
View Full Code Here

Examples of org.jboss.remoting.serialization.SerializationManager

102
103
104
105
106
107
108
109
110
111
112
113
    */
   public Object read(InputStream inputStream, Map metadata, int version) throws IOException, ClassNotFoundException
   {
      GZIPInputStream gzis = new GZIPInputStream(inputStream);
      BufferedInputStream bis = new BufferedInputStream(gzis);
      SerializationManager manager = SerializationStreamFactory.getManagerInstance(getSerializationType());
      ObjectInputStream ois =  manager.createInput(bis, getClassLoader());

      if(wrappedUnMarshaller != null)
      {
         if (wrappedUnMarshaller instanceof VersionedUnMarshaller)
            return ((VersionedUnMarshaller)wrappedUnMarshaller).read(ois, metadata, version);
View Full Code Here

Examples of org.jboss.remoting.serialization.SerializationManager

114
115
116
117
118
119
120
121
122
123
124
125
   public Object read(InputStream inputStream, Map metadata, int version) throws IOException, ClassNotFoundException
   { 
      if(cipher == null)
         throw new IllegalStateException("Cipher is null for algo="+ this.cipherAlgorithm);
      CipherInputStream cis = new CipherInputStream(inputStream,cipher);
      SerializationManager sm = SerializationStreamFactory.getManagerInstance(getSerializationType());
      ObjectInputStream ois = sm.createRegularInput(cis);
      
      Object obj = null;
      if(wrappedUnMarshaller != null)
      {
         if (wrappedUnMarshaller instanceof VersionedUnMarshaller)
View Full Code Here

Examples of org.jboss.remoting.serialization.SerializationManager

104
105
106
107
108
109
110
111
112
113
114
115
    */
   public Object read(InputStream inputStream, Map metadata, int version) throws IOException, ClassNotFoundException
   {
      GZIPInputStream gzis = new GZIPInputStream(inputStream);
      BufferedInputStream bis = new BufferedInputStream(gzis);
      SerializationManager manager = SerializationStreamFactory.getManagerInstance(getSerializationType());
      ObjectInputStream ois =  manager.createInput(bis, getClassLoader());

      if(wrappedUnMarshaller != null)
      {
         // HACK for JBREM-927.
         if (wrappedUnMarshaller instanceof HTTPUnMarshaller)
View Full Code Here

Examples of org.jboss.remoting.serialization.SerializationManager

131
132
133
134
135
136
137
138
139
140
141
142
      //EOS intercepts the close() call and does not close the stream
      EncryptionOutputStream eos = new EncryptionOutputStream(output);
      
      CipherOutputStream cos = new CipherOutputStream(eos, cipher);
      
      SerializationManager sm = SerializationStreamFactory.getManagerInstance(getSerializationType());
      ObjectOutputStream oos = sm.createOutput(cos);
     
      if(wrappedMarshaller != null)
      {
         if (wrappedMarshaller instanceof VersionedMarshaller)
            ((VersionedMarshaller) wrappedMarshaller).write(dataObject, oos, version);
View Full Code Here

Examples of org.jboss.remoting.serialization.SerializationManager

119
120
121
122
123
124
125
126
127
128
129
130
   public Object read(InputStream inputStream, Map metadata, int version) throws IOException, ClassNotFoundException
   { 
      if(cipher == null)
         throw new IllegalStateException("Cipher is null for algo="+ this.cipherAlgorithm);
      CipherInputStream cis = new CipherInputStream(inputStream,cipher);
      SerializationManager sm = SerializationStreamFactory.getManagerInstance(getSerializationType());
      ObjectInputStream ois = sm.createRegularInput(cis);
      
      Object obj = null;
      if(wrappedUnMarshaller != null)
      {
         if (wrappedUnMarshaller instanceof VersionedUnMarshaller)
View Full Code Here

Examples of org.jboss.remoting.serialization.SerializationManager

69
70
71
72
73
74
75
76
77
78
         return inputStream;
      }
      else
      {
         BufferedInputStream bis = new BufferedInputStream(inputStream);
         SerializationManager manager = SerializationStreamFactory.getManagerInstance(getSerializationType());
         return manager.createInput(bis, getClassLoader());
      }
     
   }
View Full Code Here

Examples of org.jboss.remoting.serialization.SerializationManager

83
84
85
86
87
88
89
90
91
92
93
         return outputStream;
      }
      else
      {
         BufferedOutputStream bos = new BufferedOutputStream(outputStream);
         SerializationManager manager = SerializationStreamFactory.getManagerInstance(getSerializationType());
         ObjectOutputStream oos = manager.createOutput(bos);
         oos.flush();
         return oos;
      }
   }
View Full Code Here

Examples of org.jboss.remoting.serialization.SerializationManager

365
366
367
368
369
370
371
372
373
374
375
376
            ByteArrayInputStream is = null;
            if (rmiOnewayMarshalling)
            {
               // Legacy treatment, pre 2.4.0
               ByteArrayOutputStream baos = new ByteArrayOutputStream();
               SerializationManager manager = SerializationStreamFactory.getManagerInstance(getSerializationType());
               ObjectOutputStream oos = manager.createOutput(baos);
               oos.writeObject(payload);
               oos.flush();
               oos.close();
               is = new ByteArrayInputStream(baos.toByteArray());
            }
View Full Code Here

Examples of org.jboss.remoting.serialization.SerializationManager

367
368
369
370
371
372
373
374
375
376
377
378
              
               if (rmiOnewayMarshalling)
               {
                  // Legacy treatment, pre 2.4.0.
                  ByteArrayInputStream bais = new ByteArrayInputStream(byteOut.toByteArray());
                  SerializationManager manager = SerializationStreamFactory.getManagerInstance(getSerializationType());
                  ObjectInputStream ois = manager.createInput(bais, getClassLoader());

                  try
                  {
                     byteOut.close();
                     payload = ois.readObject();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.