xmlBlaster 2.1.0 API

org.xmlBlaster.jms
Class XBStreamingMessage

java.lang.Object
  extended by org.xmlBlaster.jms.XBMessage
      extended by org.xmlBlaster.jms.XBTextMessage
          extended by 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  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
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

xmlBlaster 2.1.0 API

Copyright © 1999-2011 The xmlBlaster.org contributers.