Package org.teiid.replication.jgroups
Class JGroupsOutputStream
- java.lang.Object
-
- java.io.OutputStream
-
- org.teiid.replication.jgroups.JGroupsOutputStream
-
- All Implemented Interfaces:
Closeable
,Flushable
,AutoCloseable
public class JGroupsOutputStream extends OutputStream
-
-
Field Summary
Fields Modifier and Type Field Description protected List<org.jgroups.Address>
dests
protected org.jgroups.blocks.RpcDispatcher
disp
protected short
methodOffset
protected Serializable
stateId
-
Constructor Summary
Constructors Constructor Description JGroupsOutputStream(org.jgroups.blocks.RpcDispatcher disp, List<org.jgroups.Address> dests, Serializable stateId, short methodOffset, boolean sendCreate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
flush()
void
write(int b)
-
Methods inherited from class java.io.OutputStream
write, write
-
-
-
-
Field Detail
-
disp
protected final org.jgroups.blocks.RpcDispatcher disp
-
dests
protected final List<org.jgroups.Address> dests
-
stateId
protected final Serializable stateId
-
methodOffset
protected final short methodOffset
-
-
Constructor Detail
-
JGroupsOutputStream
public JGroupsOutputStream(org.jgroups.blocks.RpcDispatcher disp, List<org.jgroups.Address> dests, Serializable stateId, short methodOffset, boolean sendCreate) throws IOException
- Throws:
IOException
-
-
Method Detail
-
close
public void close() throws IOException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Overrides:
close
in classOutputStream
- Throws:
IOException
-
flush
public void flush() throws IOException
- Specified by:
flush
in interfaceFlushable
- Overrides:
flush
in classOutputStream
- Throws:
IOException
-
write
public void write(int b) throws IOException
- Specified by:
write
in classOutputStream
- Throws:
IOException
-
-