public class ActiveMQOutputStream extends java.io.OutputStream implements Disposable
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
AMQ_STREAM_CHUNK_SIZE
JMS Property which is used to specify the size (in kb) which is used as chunk size when splitting the stream.
|
protected int |
count |
Constructor and Description |
---|
ActiveMQOutputStream(ActiveMQConnection connection,
ProducerId producerId,
ActiveMQDestination destination,
java.util.Map<java.lang.String,java.lang.Object> properties,
int deliveryMode,
int priority,
long timeToLive) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
dispose() |
void |
flush() |
boolean |
isAlwaysSyncSend() |
void |
setAlwaysSyncSend(boolean alwaysSyncSend) |
java.lang.String |
toString() |
void |
write(byte[] b,
int off,
int len) |
void |
write(int b) |
protected int count
public static final java.lang.String AMQ_STREAM_CHUNK_SIZE
public ActiveMQOutputStream(ActiveMQConnection connection, ProducerId producerId, ActiveMQDestination destination, java.util.Map<java.lang.String,java.lang.Object> properties, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
javax.jms.JMSException
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in class java.io.OutputStream
java.io.IOException
public void dispose()
dispose
in interface Disposable
public void write(int b) throws java.io.IOException
write
in class java.io.OutputStream
java.io.IOException
public void write(byte[] b, int off, int len) throws java.io.IOException
write
in class java.io.OutputStream
java.io.IOException
public void flush() throws java.io.IOException
flush
in interface java.io.Flushable
flush
in class java.io.OutputStream
java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object
public boolean isAlwaysSyncSend()
public void setAlwaysSyncSend(boolean alwaysSyncSend)
Copyright © 2005-2017. All Rights Reserved.