AeronPublicationMDOAdapter (java 5.5.18-SNAPSHOT API)

java.lang.Object
- deltix.util.io.aeron.AeronPublicationMDOAdapter

public class AeronPublicationMDOAdapter
extends java.lang.Object

Provides MemoryDataOutput API for Aeron's Publication.

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.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - AeronPublicationMDOAdapter
```
public AeronPublicationMDOAdapter(io.aeron.ExclusivePublication publication,
                                  org.agrona.concurrent.IdleStrategy publicationIdleStrategy)
```
- 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. See sendMultipartMessage(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()
```