Package com.opengamma.livedata.client

Examples of com.opengamma.livedata.client.RemoteLiveDataClientFactoryBean

112
113
114
115
116
117
118
119
120
121
122
123
124
      final JmsConnectorFactoryBean jmsFactory = new JmsConnectorFactoryBean(jmsConnector);
      jmsFactory.setClientBrokerUri(jmsUri);
      jmsConnector = jmsFactory.getObjectCreating();
    }

    final RemoteLiveDataClientFactoryBean ldcFb = new RemoteLiveDataClientFactoryBean();
    ldcFb.setJmsConnector(jmsConnector);
    ldcFb.setSubscriptionTopic(metaData.getJmsSubscriptionTopic());
    ldcFb.setEntitlementTopic(metaData.getJmsEntitlementTopic());
    ldcFb.setHeartbeatTopic(metaData.getJmsHeartbeatTopic());
    final LiveDataClient ldcDistributed = ldcFb.getObjectCreating();
    return ldcDistributed;
  }
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
113
114
      final JmsConnectorFactoryBean jmsFactory = new JmsConnectorFactoryBean(jmsConnector);
      jmsFactory.setClientBrokerUri(jmsUri);
      jmsConnector = jmsFactory.getObjectCreating();
    }

    final RemoteLiveDataClientFactoryBean ldcFb = new RemoteLiveDataClientFactoryBean();
    ldcFb.setJmsConnector(jmsConnector);
    ldcFb.setSubscriptionTopic(metaData.getJmsSubscriptionTopic());
    ldcFb.setEntitlementTopic(metaData.getJmsEntitlementTopic());
    ldcFb.setHeartbeatTopic(metaData.getJmsHeartbeatTopic());
    final LiveDataClient ldcDistributed = ldcFb.getObjectCreating();
    return ldcDistributed;
  }
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
  private String _heartbeatTopic;

  //-------------------------------------------------------------------------
  @Override
  public void init(ComponentRepository repo, LinkedHashMap<String, String> configuration) throws Exception {
    RemoteLiveDataClientFactoryBean ldcFb = new RemoteLiveDataClientFactoryBean();
    ldcFb.setJmsConnector(getJmsConnector());
    ldcFb.setSubscriptionTopic(getSubscriptionTopic());
    ldcFb.setEntitlementTopic(getEntitlementTopic());
    ldcFb.setHeartbeatTopic(getHeartbeatTopic());
   
    LiveDataClient ldc = ldcFb.getObjectCreating();
    ComponentInfo info = new ComponentInfo(LiveDataClient.class, getClassifier());
    repo.registerComponent(info, ldc);
  }
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
      final JmsConnectorFactoryBean jmsFactory = new JmsConnectorFactoryBean(jmsConnector);
      jmsFactory.setClientBrokerUri(jmsUri);
      jmsConnector = jmsFactory.getObjectCreating();
    }

    final RemoteLiveDataClientFactoryBean liveDataClientFactory = new RemoteLiveDataClientFactoryBean();
    liveDataClientFactory.setJmsConnector(jmsConnector);
    liveDataClientFactory.setSubscriptionTopic(metaData.getJmsSubscriptionTopic());
    liveDataClientFactory.setEntitlementTopic(metaData.getJmsEntitlementTopic());
    liveDataClientFactory.setHeartbeatTopic(metaData.getJmsHeartbeatTopic());
    final LiveDataClient liveDataClient = liveDataClientFactory.getObjectCreating();

    final MarketDataAvailabilityFilter availability = BloombergDataUtils.createAvailabilityFilter();
    final LiveDataFactory liveDataFactory = new LiveDataFactory(liveDataClient, availability);
    final MarketDataProviderFactory liveMarketDataProviderFactory = new InMemoryLKVLiveMarketDataProviderFactory(liveDataFactory, ImmutableMap.of(description, liveDataFactory));
    final ComponentInfo providerFactoryInfo = new ComponentInfo(MarketDataProviderFactory.class, getClassifier());
View Full Code Here
TOP

Related Classes of com.opengamma.livedata.client.RemoteLiveDataClientFactoryBean

  • com.opengamma.bbg.component.BloombergLiveDataClientComponentFactory
  • com.opengamma.component.factory.engine.LiveDataClientComponentFactory
  • com.opengamma.examples.bloomberg.component.ExampleMarketDataComponentFactory
  • com.opengamma.examples.simulated.component.ExampleMarketDataComponentFactory
  • com.opengamma.livedata.LiveDataClient
  • com.opengamma.transport.ByteArrayFudgeRequestSender
  • com.opengamma.transport.jms.JmsByteArrayMessageSender
  • com.opengamma.transport.jms.JmsByteArrayRequestSender
  • org.springframework.jms.core.JmsTemplate
    • 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.