public class ActiveMQOutputStream extends OutputStream implements Disposable
Modifier and Type | Field and Description |
---|---|
static 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,
Map<String,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) |
String |
toString() |
void |
write(byte[] b,
int off,
int len) |
void |
write(int b) |
write
protected int count
public static final String AMQ_STREAM_CHUNK_SIZE
public ActiveMQOutputStream(ActiveMQConnection connection, ProducerId producerId, ActiveMQDestination destination, Map<String,Object> properties, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
javax.jms.JMSException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class OutputStream
IOException
public void dispose()
dispose
in interface Disposable
public void write(int b) throws IOException
write
in class OutputStream
IOException
public void write(byte[] b, int off, int len) throws IOException
write
in class OutputStream
IOException
public void flush() throws IOException
flush
in interface Flushable
flush
in class OutputStream
IOException
public boolean isAlwaysSyncSend()
public void setAlwaysSyncSend(boolean alwaysSyncSend)
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.