org.springframework.integration.adapter.stream
Class ByteStreamSourceAdapter

java.lang.Object
  org.springframework.integration.adapter.AbstractSourceAdapter<T>
      org.springframework.integration.adapter.PollingSourceAdapter<byte[]>
          org.springframework.integration.adapter.stream.ByteStreamSourceAdapter

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, SourceAdapter, MessagingTaskSchedulerAware

public class ByteStreamSourceAdapter
extends PollingSourceAdapter<byte[]>

A polling source adapter that wraps a ByteStreamSource.

Author:

Mark Fisher

Field Summary

Fields inherited from class org.springframework.integration.adapter.AbstractSourceAdapter

logger

Constructor Summary

ByteStreamSourceAdapter(java.io.InputStream stream)

Method Summary

void	setBytesPerMessage(int bytesPerMessage)
void	setShouldTruncate(boolean shouldTruncate)

Methods inherited from class org.springframework.integration.adapter.PollingSourceAdapter

getSource, isRunning, processMessages, setInitialDelay, setMaxMessagesPerTask, setMessagingTaskScheduler, setPeriod, start, stop

Methods inherited from class org.springframework.integration.adapter.AbstractSourceAdapter

afterPropertiesSet, getChannel, getMessageMapper, initialize, isInitialized, sendToChannel, setChannel, setMessageMapper, setSendTimeout

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteStreamSourceAdapter

public ByteStreamSourceAdapter(java.io.InputStream stream)

Method Detail

setBytesPerMessage

public void setBytesPerMessage(int bytesPerMessage)

setShouldTruncate

public void setShouldTruncate(boolean shouldTruncate)