Package deltix.util.io.aeron

Class AeronPublicationDSAdapter

java.lang.Object

deltix.util.io.aeron.AeronPublicationDSAdapter

public class AeronPublicationDSAdapter
extends java.lang.Object

Provides DataOutputStream API for Aeron's Publication.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	CHANNEL

Constructor Summary

Constructors

Constructor	Description
AeronPublicationDSAdapter(io.aeron.ExclusivePublication publication, org.agrona.concurrent.IdleStrategy publicationIdleStrategy)

Method Summary

Modifier and Type	Method	Description
void	close()
static AeronPublicationDSAdapter	create(int publicationStreamId, io.aeron.Aeron aeron, org.agrona.concurrent.IdleStrategy publicationIdleStrategy)
java.io.DataOutputStream	getDataOutputStream()
boolean	isClosed()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CHANNEL

public static final java.lang.String CHANNEL

See Also:

Constant Field Values

Constructor Detail

AeronPublicationDSAdapter

public AeronPublicationDSAdapter(io.aeron.ExclusivePublication publication,
                                 org.agrona.concurrent.IdleStrategy publicationIdleStrategy)

Method Detail

create

public static AeronPublicationDSAdapter create(int publicationStreamId,
                                               io.aeron.Aeron aeron,
                                               org.agrona.concurrent.IdleStrategy publicationIdleStrategy)

getDataOutputStream

public java.io.DataOutputStream getDataOutputStream()

isClosed

public boolean isClosed()

close

public void close()