Class SyncBlockingMessagePumper.MessageBufferWorker
Inheritance
System.Object
SyncBlockingMessagePumper.MessageBufferWorker
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: FixAntenna.FixEngine.Session.IOThreads
Assembly: FixAntenna.Core.dll
Syntax
public class MessageBufferWorkerConstructors
MessageBufferWorker(SyncBlockingMessagePumper, Int32)
Declaration
public MessageBufferWorker(SyncBlockingMessagePumper outerInstance, int maxMessagesInBatch)Parameters
| Type | Name | Description |
|---|---|---|
| SyncBlockingMessagePumper | outerInstance | |
| System.Int32 | maxMessagesInBatch |
Methods
GetBuffer()
Declaration
public virtual ByteBuffer GetBuffer()Returns
| Type | Description |
|---|---|
| ByteBuffer |
GetCounter()
Declaration
public virtual int GetCounter()Returns
| Type | Description |
|---|---|
| System.Int32 |
GetFullLength()
Declaration
public virtual int GetFullLength()Returns
| Type | Description |
|---|---|
| System.Int32 |
GetLength(Int32)
Declaration
public virtual int GetLength(int position)Parameters
| Type | Name | Description |
|---|---|---|
| System.Int32 | position |
Returns
| Type | Description |
|---|---|
| System.Int32 |
GetOffset()
Declaration
public virtual int GetOffset()Returns
| Type | Description |
|---|---|
| System.Int32 |
GetStartOffset(Int32)
Declaration
public virtual int GetStartOffset(int position)Parameters
| Type | Name | Description |
|---|---|---|
| System.Int32 | position |
Returns
| Type | Description |
|---|---|
| System.Int32 |
IncrementCounter()
Declaration
public virtual void IncrementCounter()MarkEndOffset()
Declaration
public virtual void MarkEndOffset()MarkStartOffset()
Declaration
public virtual void MarkStartOffset()ResetBuffer()
Declaration
public virtual void ResetBuffer()