ThreadLocalBufferProvider (MFClient 1.1.3 API)

java.lang.Object
- com.marketfactory.mfclient.internal.mfproto.ThreadLocalBufferProvider

All Implemented Interfaces:

BufferProvider
```
public class ThreadLocalBufferProvider
extends java.lang.Object
implements BufferProvider
```
There are 2 main ways client's can interact with the API. Either they provide arguments to a 'send' type method like MarketDataRequest - in which case we obtain the buffer, encoder, and apply the parameters correctly. Or, for more complex 'send' type methods like NewOrderSingle, the client will obtain an encoder and write to that directly. Since the client can concurrently obtain an encoder using multiple threads we need a way to allow that - hence the thread locals. Each thread can safely get an encoder, write to it and thus populate their own bytebuffer. Then when each thread calls the appropriate 'send' method (like NewOrderSingle) providing their encoder - we can serialize them to the outputbuffer (synchronizing as late as possible - b/c only 1 thread can write to a given output channel at a time).

Constructor Summary

Constructors
Constructor and Description

ThreadLocalBufferProvider()

Constructors
Constructor and Description
`ThreadLocalBufferProvider()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`MFProtoOutputBufferTrading`	`getExistingNewOrderSingleBuffer()` Returns the newOrderSingle buffer without clearing it
`MFProtoOutputBufferTrading`	`getExistingOrderCancelReplaceRequestBuffer()`
`MFProtoOutputBufferTrading`	`getExistingOrderCancelRequestBuffer()`
`MFProtoOutputBufferStpBooking`	`getExistingStpBookingConfirmationBuffer()` Gets the buffer without clearing it first
`MFProtoOutputBufferStpBooking`	`getExistingStpBookingNewOrderSingleBuffer()`
`MFProtoOutputBufferStpBooking`	`getExistingStpBookingOrderCancelReplaceRequestBuffer()`
`MFProtoOutputBufferStpBooking`	`getExistingStpBookingOrderCancelRequestBuffer()`
`MFProtoOutputBufferStpBooking`	`getExistingStpBookingTradeCaptureReportSpotForwardBuffer()`
`MFProtoOutputBufferStpBooking`	`getExistingStpBookingTradeCaptureReportSwapBuffer()`
`MFProtoOutputBufferMarketData`	`getMarketDataHeartbeatBuffer()`
`MFProtoOutputBufferMarketData`	`getMarketDataLogonEncoderBuffer()`
`MFProtoOutputBufferMarketData`	`getMarketDataLogoutBuffer()`
`MFProtoOutputBufferMarketData`	`getMarketDataLogoutResponseBuffer()`
`MFProtoOutputBufferMarketData`	`getMarketDataRequestBuffer()`
`MFProtoOutputBufferMarketData`	`getMarketDataRequestHistoricBuffer()`
`MFProtoOutputBufferTrading`	`getMarketDefinitionRequestBuffer()`
`MFProtoOutputBufferTrading`	`getNewOrderSingleBuffer()`
`MFProtoOutputBufferTrading`	`getOrderCancelReplaceRequestBuffer()`
`MFProtoOutputBufferTrading`	`getOrderCancelRequestBuffer()`
`MFProtoOutputBufferMarketData`	`getRegisterForBatchBuffer()`
`MFProtoOutputBufferMarketData`	`getSecurityDefinitionRequestBuffer()`
`MFProtoOutputBufferStpBooking`	`getStpBookingConfirmationBuffer()`
`MFProtoOutputBufferStpBooking`	`getStpBookingHeartbeatBuffer()`
`MFProtoOutputBufferStpBooking`	`getStpBookingLogonBuffer()`
`MFProtoOutputBufferStpBooking`	`getStpBookingLogoutBuffer()`
`MFProtoOutputBufferStpBooking`	`getStpBookingLogoutResponseBuffer()`
`MFProtoOutputBufferStpBooking`	`getStpBookingNewOrderSingleBuffer()`
`MFProtoOutputBufferStpBooking`	`getStpBookingOrderCancelReplaceRequestBuffer()`
`MFProtoOutputBufferStpBooking`	`getStpBookingOrderCancelRequestBuffer()`
`MFProtoOutputBufferStpBooking`	`getStpBookingTradeCaptureReportSpotForwardBuffer()`
`MFProtoOutputBufferStpBooking`	`getStpBookingTradeCaptureReportSwapBuffer()`
`MFProtoOutputBufferStpBooking`	`getStpSecurityDefinitionRequestBuffer()`
`MFProtoOutputBufferTradeDateRollover`	`getTradeDateRolloverHeartbeatBuffer()`
`MFProtoOutputBufferTradeDateRollover`	`getTradeDateRolloverLogonBuffer()`
`MFProtoOutputBufferTradeDateRollover`	`getTradeDateRolloverLogoutBuffer()`
`MFProtoOutputBufferTradeDateRollover`	`getTradeDateRolloverLogoutResponseBuffer()`
`MFProtoOutputBufferTradeDateRollover`	`getTradeDateRolloverRequestBuffer()`
`MFProtoOutputBufferTrading`	`getTradingHeartbeatBuffer()`
`MFProtoOutputBufferTrading`	`getTradingLogonBuffer()`
`MFProtoOutputBufferTrading`	`getTradingLogoutBuffer()`
`MFProtoOutputBufferTrading`	`getTradingLogoutResponseBuffer()`
`MFProtoOutputBufferTrading`	`getTradingSecurityDefinitionRequestBuffer()`
`MFProtoOutputBufferTrading`	`getTradingSessionStatusBuffer()`
`MFProtoOutputBufferMarketData`	`getUnregisterForBatchBuffer()`

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

- Constructor Detail
  - ThreadLocalBufferProvider
```
public ThreadLocalBufferProvider()
```
- Method Detail
  - getSecurityDefinitionRequestBuffer
```
public MFProtoOutputBufferMarketData getSecurityDefinitionRequestBuffer()
```
    Specified by:
    
    getSecurityDefinitionRequestBuffer in interface BufferProvider
  - getMarketDataRequestBuffer
```
public MFProtoOutputBufferMarketData getMarketDataRequestBuffer()
```
    Specified by:
    
    getMarketDataRequestBuffer in interface BufferProvider
  - getMarketDataRequestHistoricBuffer
```
public MFProtoOutputBufferMarketData getMarketDataRequestHistoricBuffer()
```
    Specified by:
    
    getMarketDataRequestHistoricBuffer in interface BufferProvider
  - getRegisterForBatchBuffer
```
public MFProtoOutputBufferMarketData getRegisterForBatchBuffer()
```
    Specified by:
    
    getRegisterForBatchBuffer in interface BufferProvider
  - getUnregisterForBatchBuffer
```
public MFProtoOutputBufferMarketData getUnregisterForBatchBuffer()
```
    Specified by:
    
    getUnregisterForBatchBuffer in interface BufferProvider
  - getMarketDataLogonEncoderBuffer
```
public MFProtoOutputBufferMarketData getMarketDataLogonEncoderBuffer()
```
    Specified by:
    
    getMarketDataLogonEncoderBuffer in interface BufferProvider
  - getMarketDataHeartbeatBuffer
```
public MFProtoOutputBufferMarketData getMarketDataHeartbeatBuffer()
```
    Specified by:
    
    getMarketDataHeartbeatBuffer in interface BufferProvider
  - getMarketDataLogoutBuffer
```
public MFProtoOutputBufferMarketData getMarketDataLogoutBuffer()
```
    Specified by:
    
    getMarketDataLogoutBuffer in interface BufferProvider
  - getMarketDataLogoutResponseBuffer
```
public MFProtoOutputBufferMarketData getMarketDataLogoutResponseBuffer()
```
    Specified by:
    
    getMarketDataLogoutResponseBuffer in interface BufferProvider
  - getMarketDefinitionRequestBuffer
```
public MFProtoOutputBufferTrading getMarketDefinitionRequestBuffer()
```
    Specified by:
    
    getMarketDefinitionRequestBuffer in interface BufferProvider
  - getTradingSecurityDefinitionRequestBuffer
```
public MFProtoOutputBufferTrading getTradingSecurityDefinitionRequestBuffer()
```
    Specified by:
    
    getTradingSecurityDefinitionRequestBuffer in interface BufferProvider
  - getTradingSessionStatusBuffer
```
public MFProtoOutputBufferTrading getTradingSessionStatusBuffer()
```
    Specified by:
    
    getTradingSessionStatusBuffer in interface BufferProvider
  - getNewOrderSingleBuffer
```
public MFProtoOutputBufferTrading getNewOrderSingleBuffer()
```
    Specified by:
    
    getNewOrderSingleBuffer in interface BufferProvider
  - getExistingNewOrderSingleBuffer
```
public MFProtoOutputBufferTrading getExistingNewOrderSingleBuffer()
```
    Description copied from interface: BufferProvider
    
    Returns the newOrderSingle buffer without clearing it
    
    Specified by:
    
    getExistingNewOrderSingleBuffer in interface BufferProvider
    
    Returns:
    
    existing NewOrderSingle Buffer
  - getOrderCancelReplaceRequestBuffer
```
public MFProtoOutputBufferTrading getOrderCancelReplaceRequestBuffer()
```
    Specified by:
    
    getOrderCancelReplaceRequestBuffer in interface BufferProvider
  - getExistingOrderCancelReplaceRequestBuffer
```
public MFProtoOutputBufferTrading getExistingOrderCancelReplaceRequestBuffer()
```
    Specified by:
    
    getExistingOrderCancelReplaceRequestBuffer in interface BufferProvider
  - getOrderCancelRequestBuffer
```
public MFProtoOutputBufferTrading getOrderCancelRequestBuffer()
```
    Specified by:
    
    getOrderCancelRequestBuffer in interface BufferProvider
  - getExistingOrderCancelRequestBuffer
```
public MFProtoOutputBufferTrading getExistingOrderCancelRequestBuffer()
```
    Specified by:
    
    getExistingOrderCancelRequestBuffer in interface BufferProvider
  - getTradingLogonBuffer
```
public MFProtoOutputBufferTrading getTradingLogonBuffer()
```
    Specified by:
    
    getTradingLogonBuffer in interface BufferProvider
  - getTradingLogoutBuffer
```
public MFProtoOutputBufferTrading getTradingLogoutBuffer()
```
    Specified by:
    
    getTradingLogoutBuffer in interface BufferProvider
  - getTradingLogoutResponseBuffer
```
public MFProtoOutputBufferTrading getTradingLogoutResponseBuffer()
```
    Specified by:
    
    getTradingLogoutResponseBuffer in interface BufferProvider
  - getTradingHeartbeatBuffer
```
public MFProtoOutputBufferTrading getTradingHeartbeatBuffer()
```
    Specified by:
    
    getTradingHeartbeatBuffer in interface BufferProvider
  - getTradeDateRolloverHeartbeatBuffer
```
public MFProtoOutputBufferTradeDateRollover getTradeDateRolloverHeartbeatBuffer()
```
    Specified by:
    
    getTradeDateRolloverHeartbeatBuffer in interface BufferProvider
  - getTradeDateRolloverLogonBuffer
```
public MFProtoOutputBufferTradeDateRollover getTradeDateRolloverLogonBuffer()
```
    Specified by:
    
    getTradeDateRolloverLogonBuffer in interface BufferProvider
  - getTradeDateRolloverLogoutBuffer
```
public MFProtoOutputBufferTradeDateRollover getTradeDateRolloverLogoutBuffer()
```
    Specified by:
    
    getTradeDateRolloverLogoutBuffer in interface BufferProvider
  - getTradeDateRolloverLogoutResponseBuffer
```
public MFProtoOutputBufferTradeDateRollover getTradeDateRolloverLogoutResponseBuffer()
```
    Specified by:
    
    getTradeDateRolloverLogoutResponseBuffer in interface BufferProvider
  - getTradeDateRolloverRequestBuffer
```
public MFProtoOutputBufferTradeDateRollover getTradeDateRolloverRequestBuffer()
```
    Specified by:
    
    getTradeDateRolloverRequestBuffer in interface BufferProvider
  - getStpBookingHeartbeatBuffer
```
public MFProtoOutputBufferStpBooking getStpBookingHeartbeatBuffer()
```
    Specified by:
    
    getStpBookingHeartbeatBuffer in interface BufferProvider
  - getStpBookingLogonBuffer
```
public MFProtoOutputBufferStpBooking getStpBookingLogonBuffer()
```
    Specified by:
    
    getStpBookingLogonBuffer in interface BufferProvider
  - getStpBookingLogoutBuffer
```
public MFProtoOutputBufferStpBooking getStpBookingLogoutBuffer()
```
    Specified by:
    
    getStpBookingLogoutBuffer in interface BufferProvider
  - getStpSecurityDefinitionRequestBuffer
```
public MFProtoOutputBufferStpBooking getStpSecurityDefinitionRequestBuffer()
```
    Specified by:
    
    getStpSecurityDefinitionRequestBuffer in interface BufferProvider
  - getStpBookingLogoutResponseBuffer
```
public MFProtoOutputBufferStpBooking getStpBookingLogoutResponseBuffer()
```
    Specified by:
    
    getStpBookingLogoutResponseBuffer in interface BufferProvider
  - getStpBookingTradeCaptureReportSpotForwardBuffer
```
public MFProtoOutputBufferStpBooking getStpBookingTradeCaptureReportSpotForwardBuffer()
```
    Specified by:
    
    getStpBookingTradeCaptureReportSpotForwardBuffer in interface BufferProvider
  - getExistingStpBookingTradeCaptureReportSpotForwardBuffer
```
public MFProtoOutputBufferStpBooking getExistingStpBookingTradeCaptureReportSpotForwardBuffer()
```
    Specified by:
    
    getExistingStpBookingTradeCaptureReportSpotForwardBuffer in interface BufferProvider
  - getStpBookingTradeCaptureReportSwapBuffer
```
public MFProtoOutputBufferStpBooking getStpBookingTradeCaptureReportSwapBuffer()
```
    Specified by:
    
    getStpBookingTradeCaptureReportSwapBuffer in interface BufferProvider
  - getExistingStpBookingTradeCaptureReportSwapBuffer
```
public MFProtoOutputBufferStpBooking getExistingStpBookingTradeCaptureReportSwapBuffer()
```
    Specified by:
    
    getExistingStpBookingTradeCaptureReportSwapBuffer in interface BufferProvider
  - getStpBookingConfirmationBuffer
```
public MFProtoOutputBufferStpBooking getStpBookingConfirmationBuffer()
```
    Specified by:
    
    getStpBookingConfirmationBuffer in interface BufferProvider
  - getExistingStpBookingConfirmationBuffer
```
public MFProtoOutputBufferStpBooking getExistingStpBookingConfirmationBuffer()
```
    Description copied from interface: BufferProvider
    
    Gets the buffer without clearing it first
    
    Specified by:
    
    getExistingStpBookingConfirmationBuffer in interface BufferProvider
    
    Returns:
    
    MFProtoOutputBuffer
  - getStpBookingOrderCancelRequestBuffer
```
public MFProtoOutputBufferStpBooking getStpBookingOrderCancelRequestBuffer()
```
    Specified by:
    
    getStpBookingOrderCancelRequestBuffer in interface BufferProvider
  - getExistingStpBookingOrderCancelRequestBuffer
```
public MFProtoOutputBufferStpBooking getExistingStpBookingOrderCancelRequestBuffer()
```
    Specified by:
    
    getExistingStpBookingOrderCancelRequestBuffer in interface BufferProvider
  - getStpBookingOrderCancelReplaceRequestBuffer
```
public MFProtoOutputBufferStpBooking getStpBookingOrderCancelReplaceRequestBuffer()
```
    Specified by:
    
    getStpBookingOrderCancelReplaceRequestBuffer in interface BufferProvider
  - getExistingStpBookingOrderCancelReplaceRequestBuffer
```
public MFProtoOutputBufferStpBooking getExistingStpBookingOrderCancelReplaceRequestBuffer()
```
    Specified by:
    
    getExistingStpBookingOrderCancelReplaceRequestBuffer in interface BufferProvider
  - getStpBookingNewOrderSingleBuffer
```
public MFProtoOutputBufferStpBooking getStpBookingNewOrderSingleBuffer()
```
    Specified by:
    
    getStpBookingNewOrderSingleBuffer in interface BufferProvider
  - getExistingStpBookingNewOrderSingleBuffer
```
public MFProtoOutputBufferStpBooking getExistingStpBookingNewOrderSingleBuffer()
```
    Specified by:
    
    getExistingStpBookingNewOrderSingleBuffer in interface BufferProvider

Class ThreadLocalBufferProvider

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

ThreadLocalBufferProvider

Method Detail

getSecurityDefinitionRequestBuffer

getMarketDataRequestBuffer

getMarketDataRequestHistoricBuffer

getRegisterForBatchBuffer

getUnregisterForBatchBuffer

getMarketDataLogonEncoderBuffer

getMarketDataHeartbeatBuffer

getMarketDataLogoutBuffer

getMarketDataLogoutResponseBuffer

getMarketDefinitionRequestBuffer

getTradingSecurityDefinitionRequestBuffer

getTradingSessionStatusBuffer

getNewOrderSingleBuffer

getExistingNewOrderSingleBuffer

getOrderCancelReplaceRequestBuffer

getExistingOrderCancelReplaceRequestBuffer

getOrderCancelRequestBuffer

getExistingOrderCancelRequestBuffer

getTradingLogonBuffer

getTradingLogoutBuffer

getTradingLogoutResponseBuffer

getTradingHeartbeatBuffer

getTradeDateRolloverHeartbeatBuffer

getTradeDateRolloverLogonBuffer

getTradeDateRolloverLogoutBuffer

getTradeDateRolloverLogoutResponseBuffer

getTradeDateRolloverRequestBuffer

getStpBookingHeartbeatBuffer

getStpBookingLogonBuffer

getStpBookingLogoutBuffer

getStpSecurityDefinitionRequestBuffer

getStpBookingLogoutResponseBuffer

getStpBookingTradeCaptureReportSpotForwardBuffer

getExistingStpBookingTradeCaptureReportSpotForwardBuffer

getStpBookingTradeCaptureReportSwapBuffer

getExistingStpBookingTradeCaptureReportSwapBuffer

getStpBookingConfirmationBuffer

getExistingStpBookingConfirmationBuffer

getStpBookingOrderCancelRequestBuffer

getExistingStpBookingOrderCancelRequestBuffer

getStpBookingOrderCancelReplaceRequestBuffer

getExistingStpBookingOrderCancelReplaceRequestBuffer

getStpBookingNewOrderSingleBuffer

getExistingStpBookingNewOrderSingleBuffer