org.xmlBlaster.jms
Class XBStreamingMessage

java.lang.Object
  org.xmlBlaster.jms.XBMessage
      org.xmlBlaster.jms.XBTextMessage
          org.xmlBlaster.jms.XBStreamingMessage

All Implemented Interfaces:

javax.jms.Message, javax.jms.TextMessage

public class XBStreamingMessage
extends XBTextMessage

XBStreamingMessage. This is an xmlBlaster specific implementation to allow real streaming.

Author:

Michele Laghi

Field Summary

private I_ReplaceContent	contentReplacer
private java.io.InputStream	in
private static java.util.logging.Logger	log
private int	maxBufSize

Fields inherited from class org.xmlBlaster.jms.XBMessage

acknowledged, BYTES, content, DEFAULT_TYPE, destination, global, MAP, OBJECT, props, readOnly, session, STREAM, STREAMING, TEXT, type

Fields inherited from interface javax.jms.Message

DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE

Constructor Summary

XBStreamingMessage(XBSession session, java.io.InputStream in, I_ReplaceContent contentReplacer)

Method Summary

java.io.InputStream	getInputStream()
(package private) void	send(javax.jms.Session session, javax.jms.MessageProducer producer, javax.jms.Destination dest)
void	setInputStream(java.io.InputStream in)

Methods inherited from class org.xmlBlaster.jms.XBTextMessage

getText, setText

Methods inherited from class org.xmlBlaster.jms.XBMessage

acknowledge, addToKeyAndCheck, checkPropertiesReadOnly, clearBody, clearProperties, get, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, isAcknowledged, propertyExists, setAcknowledged, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setPropertyReadOnly, setReadOnly, setShortProperty, setStringProperty

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.Message

acknowledge, clearBody, clearProperties, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, propertyExists, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setShortProperty, setStringProperty

Field Detail

in

private java.io.InputStream in

maxBufSize

private int maxBufSize

contentReplacer

private I_ReplaceContent contentReplacer

log

private static final java.util.logging.Logger log

Constructor Detail

XBStreamingMessage

public XBStreamingMessage(XBSession session,
                          java.io.InputStream in,
                          I_ReplaceContent contentReplacer)

Parameters:

session -

in -

contentReplacer - can be null, in which case the content of the chunk is not modified on publishing.

Method Detail

getInputStream

public java.io.InputStream getInputStream()

setInputStream

public void setInputStream(java.io.InputStream in)

send

void send(javax.jms.Session session,
          javax.jms.MessageProducer producer,
          javax.jms.Destination dest)
    throws javax.jms.JMSException

Throws:

javax.jms.JMSException