Class AbstractByteArraySerializer

java.lang.Object
org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer
All Implemented Interfaces:
Aware, ApplicationEventPublisherAware, Deserializer<byte[]>, Serializer<byte[]>
Direct Known Subclasses:
AbstractPooledBufferByteArraySerializer, ByteArrayLengthHeaderSerializer

public abstract class AbstractByteArraySerializer extends Object implements Serializer<byte[]>, Deserializer<byte[]>, ApplicationEventPublisherAware
Base class for (de)serializers that provide a mechanism to reconstruct a byte array from an arbitrary stream.
Since:
2.0
Author:
Gary Russell, Artme Bilan
  • Field Details

    • DEFAULT_MAX_MESSAGE_SIZE

      public static final int DEFAULT_MAX_MESSAGE_SIZE
      The default maximum message size when deserializing.
      Since:
      5.1.3
      See Also:
    • logger

      protected final LogAccessor logger
  • Constructor Details

    • AbstractByteArraySerializer

      public AbstractByteArraySerializer()
  • Method Details

    • getMaxMessageSize

      public int getMaxMessageSize()
      The maximum supported message size for this serializer. Default 2048.
      Returns:
      The max message size.
    • setMaxMessageSize

      public void setMaxMessageSize(int maxMessageSize)
      The maximum supported message size for this serializer. Default 2048.
      Parameters:
      maxMessageSize - The max message size.
    • setApplicationEventPublisher

      public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
      Specified by:
      setApplicationEventPublisher in interface ApplicationEventPublisherAware
    • checkClosure

      protected void checkClosure(int bite) throws IOException
      Throws:
      IOException
    • publishEvent

      protected void publishEvent(Exception cause, byte[] buffer, int offset)