Package com.opengamma.livedata.client

Examples of com.opengamma.livedata.client.DistributedLiveDataClient$AbstractSubscriptionResponseReceiver


public class LiveDataClientTestUtils {
 
  public static DistributedLiveDataClient getInMemoryConduitClient(StandardLiveDataServer server) {
    ByteArrayFudgeRequestSender subscriptionRequestSender = getSubscriptionRequestSender(server);
    ByteArrayFudgeRequestSender entitlementRequestSender = getEntitlementRequestSender(server);
    DistributedLiveDataClient liveDataClient = new DistributedLiveDataClient(subscriptionRequestSender, entitlementRequestSender);
   
    FudgeSenderFactory factory = new FudgeSenderFactory(
        new ByteArrayFudgeMessageSender(
            new DirectInvocationByteArrayMessageSender(
                new ByteArrayFudgeMessageReceiver(liveDataClient))));
    server.setMarketDataSenderFactory(factory);
   
    liveDataClient.setFudgeContext(liveDataClient.getFudgeContext());
   
    return liveDataClient;
  }
View Full Code Here

TOP

Related Classes of com.opengamma.livedata.client.DistributedLiveDataClient$AbstractSubscriptionResponseReceiver

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.