Class WrappedMessageByteBufferMarshaller

java.lang.Object
org.wildfly.clustering.marshalling.protostream.WrappedMessageByteBufferMarshaller
All Implemented Interfaces:
Predicate<Object>, org.wildfly.clustering.function.Predicate<Object>, org.wildfly.clustering.marshalling.ByteBufferMarshaller, org.wildfly.clustering.marshalling.Marshaller<Object, ByteBuffer>
public class WrappedMessageByteBufferMarshaller extends Object implements org.wildfly.clustering.marshalling.ByteBufferMarshaller
A ByteBufferMarshaller based on a ProtoStream WrappedMessage.
Author:
Paul Ferraro

  • Field Summary

    Fields inherited from interface org.wildfly.clustering.function.Predicate

    ALWAYS, NEVER

  • Constructor Summary

    Constructors
    Constructor
    Description
    WrappedMessageByteBufferMarshaller(org.infinispan.protostream.ImmutableSerializationContext context)
    Creates a new marshaller using the specified context.

  • Method Summary

    Modifier and Type
    Method
    Description
    Object
    readFrom(InputStream input)
     
    OptionalInt
    size(Object object)
     
    boolean
    test(Object object)
     
    void
    writeTo(OutputStream output, Object object)
     

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.wildfly.clustering.marshalling.ByteBufferMarshaller

    read, write

    Methods inherited from interface org.wildfly.clustering.function.Predicate

    and, compose, composeBinary, composeDouble, composeInt, composeLong, handle, negate, or, xor

  • Constructor Details

    • WrappedMessageByteBufferMarshaller

      public WrappedMessageByteBufferMarshaller(org.infinispan.protostream.ImmutableSerializationContext context)
      Creates a new marshaller using the specified context.
      Parameters:
      context - a serialization context

  • Method Details

    • test

      public boolean test(Object object)
      Specified by:
      test in interface Predicate<Object>

    • readFrom

      public Object readFrom(InputStream input) throws IOException
      Specified by:
      readFrom in interface org.wildfly.clustering.marshalling.ByteBufferMarshaller
      Throws:
      IOException

    • writeTo

      public void writeTo(OutputStream output, Object object) throws IOException
      Specified by:
      writeTo in interface org.wildfly.clustering.marshalling.ByteBufferMarshaller
      Throws:
      IOException

    • size

      public OptionalInt size(Object object)
      Specified by:
      size in interface org.wildfly.clustering.marshalling.ByteBufferMarshaller