Package deltix.util.io.aeron
Class AeronPublicationMDOAdapter
- java.lang.Object
-
- deltix.util.io.aeron.AeronPublicationMDOAdapter
-
public class AeronPublicationMDOAdapter extends java.lang.Object
ProvidesMemoryDataOutput
API for Aeron'sPublication
.
-
-
Constructor Summary
Constructors Constructor Description AeronPublicationMDOAdapter(io.aeron.ExclusivePublication publication, org.agrona.concurrent.IdleStrategy publicationIdleStrategy)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancelSend()
void
close()
int
getAeronSessionId()
deltix.util.memory.MemoryDataOutput
getMemoryDataOutput()
boolean
isClosed()
void
sendBuffer()
Sends data from buffer as is.boolean
sendBufferIfConnected()
Sends data from buffer as is.void
sendMessage(int offset, byte multipartMessageHeader, byte multipartAdditionalPartHeader)
Depending on message size sends it as as or splits it into multiple parts.
-
-
-
Method Detail
-
getMemoryDataOutput
public deltix.util.memory.MemoryDataOutput getMemoryDataOutput()
-
sendBuffer
public void sendBuffer()
Sends data from buffer as is. Buffer content must be smaller than Aeron's buffer.- Throws:
PublicationClosedException
- if publication is already closed
-
sendBufferIfConnected
public boolean sendBufferIfConnected()
Sends data from buffer as is. Buffer content must be smaller than Aeron's buffer. If there is no connected clients then just discard data.- Throws:
PublicationClosedException
- if publication is already closed
-
sendMessage
public void sendMessage(int offset, byte multipartMessageHeader, byte multipartAdditionalPartHeader)
Depending on message size sends it as as or splits it into multiple parts. SeesendMultipartMessage(int, byte, byte)
- Throws:
PublicationClosedException
- if publication is already closed
-
getAeronSessionId
public int getAeronSessionId()
-
cancelSend
public void cancelSend()
-
isClosed
public boolean isClosed()
-
close
public void close()
-
-