Table of Contents

Class EventQueue

Namespace
Org.Apache.Kafka.Queue
Assembly
MASES.KNet.dll
public class EventQueue : AutoCloseable, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IEventQueue, IAutoCloseable
Inheritance
EventQueue
Implements
Derived
Inherited Members

Constructors

EventQueue()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

[Obsolete("EventQueue class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public EventQueue()

EventQueue(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

[Obsolete("EventQueue class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public EventQueue(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements Closeable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

Append(Event)

public void Append(EventQueue.Event arg0)

Parameters

arg0 EventQueue.Event

EventQueue.Event

AppendWithDeadline(long, Event)

public void AppendWithDeadline(long arg0, EventQueue.Event arg1)

Parameters

arg0 long

long

arg1 EventQueue.Event

EventQueue.Event

BeginShutdown(String)

public void BeginShutdown(String arg0)

Parameters

arg0 String

String

CancelDeferred(String)

public void CancelDeferred(String arg0)

Parameters

arg0 String

String

Close()

public void Close()

Exceptions

InterruptedException

Enqueue(EventInsertionType, String, Function<OptionalLong, OptionalLong>, Event)

public void Enqueue(EventQueue.EventInsertionType arg0, String arg1, Function<OptionalLong, OptionalLong> arg2, EventQueue.Event arg3)

Parameters

arg0 EventQueue.EventInsertionType

EventQueue.EventInsertionType

arg1 String

String

arg2 Function<OptionalLong, OptionalLong>

Function

arg3 EventQueue.Event

EventQueue.Event

IsEmpty()

public bool IsEmpty()

Returns

bool

bool

Prepend(Event)

public void Prepend(EventQueue.Event arg0)

Parameters

arg0 EventQueue.Event

EventQueue.Event

ScheduleDeferred(String, Function<OptionalLong, OptionalLong>, Event)

public void ScheduleDeferred(String arg0, Function<OptionalLong, OptionalLong> arg1, EventQueue.Event arg2)

Parameters

arg0 String

String

arg1 Function<OptionalLong, OptionalLong>

Function

arg2 EventQueue.Event

EventQueue.Event

Size()

public int Size()

Returns

int

int

Wakeup()

public void Wakeup()